Bit of background first…
I have been using Emoncms for quite a number of years, but now I want to try and get more data out of it.
One goal is to try and identify when things like my heat pump…under floor heating etc come on by looking at the increase per phase - for example my under floor heating might use 800w on phase 2. I have the data coming into emoncms from two sources - my old source whihc is a current cost meter, and a new source which is a tibber pulse which plugs into my electricity meter. At the moment i’m only involving the data from tibber for this project.
I have a process set up as follows:
My new addition is the rate of change step (which works:
and then the MQTT bit. I have been messing around for a few hours trying to get it working, assuming it was a config issue on my side - until i moved up the MQTT step to above the rate of change step - once i did this i started getting data. I then moved it back down and stopped getting data. (i used redis-cli and mosquitto_sub to validate that emoncms was adding data to the queue and mosquitto receiveing it from the mqtt_emoncms service)
Should the rate of change step pass onto the next step in the process, as well as output to my feed?
My goal here is to get the +/- data out of emoncms in near real time, and then do some logic in abasic python program to start with - would be great to eventually suggest devices…rather than looking out for hard coded numbers…but figured this would be a good start.
Hopefully the above makes sense as well as gives some background to what i’m trying to do.