I found this thread as I wanted the same functionality. I slightly tweaked the code, but result is the same:
This flow functions and an inject node, but allows the interval to be changed.
The basic principle that the delay node output if fed back to itself through a change node which sets the appropriate delay for each message.
The 3 sample inject node set the interval to 1s, 2s, 5s. The interval is sent in the msg.payload in milliseconds.
These inject nodes can be supplemented with a dashboard input field (slider, dropdown) so it can be controlled from the screen as well.
This flow does not start sending out messages when deployed, if that is required, create another inject node with default rate and set to trigger on startup.
I also added a "Autostart with saved value" this should be used if the flow variable is saved to file (in that case update the change nodes to use the file storage) so it can restart the trigger with the last delay value read from the file system (set this inject node to trigger on startup).
The interval is stored in a flow context variable, and this value is inserted into the message every time (msg.delay) by the change node above the delay node. This ensures that if the rate value in the context value changes, it is applied at the next message.
I added the delay "100ms" and the "msg.reset" nodes, because when the rate changes it introduces a new message the recursive loop and that would mess up the timing.
"Stop" inject node resets the delay node (deleted the message that keeps triggeting itelf) and stops the process.
[
{
"id": "3234f262056babaf",
"type": "delay",
"z": "f6b1667f7ee0d1b0",
"name": "Recursive delay",
"pauseType": "delayv",
"timeout": "5",
"timeoutUnits": "seconds",
"rate": "1",
"nbRateUnits": "1",
"rateUnits": "second",
"randomFirst": "1",
"randomLast": "5",
"randomUnits": "seconds",
"drop": true,
"allowrate": true,
"outputs": 1,
"x": 780,
"y": 720,
"wires": [
[
"63daa2969066caec",
"572e6832bcf30618"
]
]
},
{
"id": "63daa2969066caec",
"type": "debug",
"z": "f6b1667f7ee0d1b0",
"name": "debug 34",
"active": true,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "true",
"targetType": "full",
"statusVal": "",
"statusType": "auto",
"x": 1020,
"y": 720,
"wires": []
},
{
"id": "d6577d4db9cbded4",
"type": "inject",
"z": "f6b1667f7ee0d1b0",
"name": "1s rate",
"props": [
{
"p": "payload"
},
{
"p": "topic",
"vt": "str"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"payload": "1000",
"payloadType": "num",
"x": 130,
"y": 580,
"wires": [
[
"4158a248e1e2b3e4"
]
]
},
{
"id": "b97d8dcaebe9cc85",
"type": "inject",
"z": "f6b1667f7ee0d1b0",
"name": "2s rate",
"props": [
{
"p": "payload"
},
{
"p": "topic",
"vt": "str"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"payload": "2000",
"payloadType": "num",
"x": 130,
"y": 620,
"wires": [
[
"4158a248e1e2b3e4"
]
]
},
{
"id": "9415f762de6c9ced",
"type": "inject",
"z": "f6b1667f7ee0d1b0",
"name": "5s rate",
"props": [
{
"p": "payload"
},
{
"p": "topic",
"vt": "str"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"payload": "5000",
"payloadType": "num",
"x": 130,
"y": 660,
"wires": [
[
"4158a248e1e2b3e4"
]
]
},
{
"id": "4158a248e1e2b3e4",
"type": "change",
"z": "f6b1667f7ee0d1b0",
"name": "",
"rules": [
{
"t": "set",
"p": "ratelimit",
"pt": "flow",
"to": "payload",
"tot": "msg"
},
{
"t": "set",
"p": "topic",
"pt": "msg",
"to": "tick",
"tot": "str"
},
{
"t": "set",
"p": "payload",
"pt": "msg",
"to": "trigger",
"tot": "str"
}
],
"action": "",
"property": "",
"from": "",
"to": "",
"reg": false,
"x": 360,
"y": 620,
"wires": [
[
"b300a73d7dc605ae",
"dc0ddfa85869080c"
]
]
},
{
"id": "572e6832bcf30618",
"type": "change",
"z": "f6b1667f7ee0d1b0",
"name": "",
"rules": [
{
"t": "set",
"p": "delay",
"pt": "msg",
"to": "ratelimit",
"tot": "flow"
}
],
"action": "",
"property": "",
"from": "",
"to": "",
"reg": false,
"x": 780,
"y": 620,
"wires": [
[
"3234f262056babaf"
]
]
},
{
"id": "bf8022099b6ce347",
"type": "inject",
"z": "f6b1667f7ee0d1b0",
"name": "Stop",
"props": [
{
"p": "reset",
"v": "",
"vt": "date"
},
{
"p": "topic",
"vt": "str"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"x": 510,
"y": 780,
"wires": [
[
"3234f262056babaf"
]
]
},
{
"id": "966379b5822bea96",
"type": "comment",
"z": "f6b1667f7ee0d1b0",
"name": "Programmable interval inject",
"info": "This flow functions and an inject node, but allows the interval to be changed.\nThe basic principle that the delay node output if fed back to itself through a change node which sets the appropriate delay for each message.\n\nThe 3 sample inject node set the interval to 1s, 2s, 5s. The interval is sent in the msg.payload in milliseconds.\nThese inject nodes can be supplemented with a dashboard input field (slider, dropdown) so it can be controlled from the screen as well.\nThis flow does not start sending out messages when deployed, if that is required, create another inject node with default rate and set to trigger on startup. \nI also added a \"Autostart with saved value\" this should be used if the flow variable is saved to file (in that case update the change nodes to use the file storage) so it can restart the trigger with the last delay value read from the file system (set this inject node to trigger on startup).\n\nThe interval is stored in a flow context variable, and this value is inserted into the message every time by the change node above the delay node. This ensures that if the rate value in the context value changes, it is applied at the next message.\n\nI added the delay 100ms and the msg.reset nodes, because when the rate changes it introduces a new message the recursive loop and that would mess up the timing.\n\n\"Stop\" inject node resets the delay node (deleted the message that keeps triggeting itelf) and stops the process.",
"x": 170,
"y": 520,
"wires": []
},
{
"id": "20fc9533e15a9b16",
"type": "inject",
"z": "f6b1667f7ee0d1b0",
"name": "Autostart with saved value",
"props": [
{
"p": "payload"
},
{
"p": "topic",
"vt": "str"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "tick",
"payload": "trigger",
"payloadType": "str",
"x": 510,
"y": 560,
"wires": [
[
"572e6832bcf30618"
]
]
},
{
"id": "dc0ddfa85869080c",
"type": "change",
"z": "f6b1667f7ee0d1b0",
"name": "",
"rules": [
{
"t": "set",
"p": "reset",
"pt": "msg",
"to": "reset",
"tot": "str"
}
],
"action": "",
"property": "",
"from": "",
"to": "",
"reg": false,
"x": 460,
"y": 720,
"wires": [
[
"3234f262056babaf"
]
]
},
{
"id": "b300a73d7dc605ae",
"type": "delay",
"z": "f6b1667f7ee0d1b0",
"name": "",
"pauseType": "delay",
"timeout": "100",
"timeoutUnits": "milliseconds",
"rate": "1",
"nbRateUnits": "1",
"rateUnits": "second",
"randomFirst": "1",
"randomLast": "5",
"randomUnits": "seconds",
"drop": false,
"allowrate": false,
"outputs": 1,
"x": 550,
"y": 620,
"wires": [
[
"572e6832bcf30618"
]
]
}
]
