Counter by Topic on a Rolling Window

[gta_br]

Hi,

Sorry if it was answered before but I'm stucked with a problem.

Is it possible to implement the solution described in topic Count the messages uuid values, but on a rolling window? I need to count the messages by topic (uuid on the topic example) but on the last N days.

TIA.

[Trying_to_learn]

You may need to expand a bit more on what you are wanting to do.

And: why more than 1 day?

You open the window. You close it.

Search how to post messages here so they are correctly formatted and maybe post a message and elaborate (expand) on what you want to do.

[Andrei]

I can imagine a solution where you store the incoming data in a CSV file. A specific function would then recover and count topics for the last N days. You could transform the timestamp in the date of the month (at the time you save data to the CSV file) to easy the data recovery (avoiding timestamp calculation for each and every data recovery).

[E1cid]

You could store the topic message time in an context store object by array. You can then filter the array by a time limit, which would be your rolling window.
In this example the window is 1 minute, for testing

[{"id":"1c503a87.b15805","type":"inject","z":"30af2d3e.d94ea2","name":"","props":[{"p":"payload"},{"p":"topic","vt":"str"}],"repeat":"","crontab":"","once":false,"onceDelay":0.1,"topic":"one","payload":"test","payloadType":"str","x":140,"y":980,"wires":[["f3477ed6.6151"]]},{"id":"f3477ed6.6151","type":"function","z":"30af2d3e.d94ea2","name":"","func":"const time_window = 60000;\nlet topic_count = flow.get(\"topic_count.\" + msg.topic) || [];\nconst time_now = new Date().valueOf();\ntopic_count = topic_count.filter(time => time > (time_now-time_window));\ntopic_count.push(time_now);\nmsg.payload = topic_count.length;\nflow.set(\"topic_count.\" + msg.topic, topic_count)\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","libs":[],"x":350,"y":1000,"wires":[["2dfdae9e.4eab8a"]]},{"id":"39e839d4.2a9bc6","type":"inject","z":"30af2d3e.d94ea2","name":"","props":[{"p":"payload"},{"p":"topic","vt":"str"}],"repeat":"","crontab":"","once":false,"onceDelay":0.1,"topic":"two","payload":"another","payloadType":"str","x":150,"y":1040,"wires":[["f3477ed6.6151"]]},{"id":"2dfdae9e.4eab8a","type":"debug","z":"30af2d3e.d94ea2","name":"","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"false","statusVal":"","statusType":"auto","x":540,"y":1160,"wires":[]}]

[gta_br]

My gate controller sends a JSON message each time it's activated. The IP is assigned by DHCP and the message format is:

{"gate_activation":{"ip_address":"192.168.1.XX","gate":"Car"}}
{"gate_activation":{"ip_address":"192.168.1.YY","gate":"Car"}}
{"gate_activation":{"ip_address":"192.168.1.ZZ","gate":"Car"}}
{"gate_activation":{"ip_address":"192.168.1.XX","gate":"Car"}}
{"gate_activation":{"ip_address":"192.168.1.XX","gate":"Ped"}}

I need to identify the first access of a given IP for the last N days, as he can open the gate on the previous days. The following action would be to send a Pushsafer message.

[gta_br]

Seems to be the way. Tks.