Hello!
I want to ask a question about inject node and HTTP requests.
I have an inject node that is configured working on an interval of 5 seconds.
My goal is to be able to trigger the inject node by using HTTP requests in order to start and stop.
Any help would be appreciated.
Best regards.
You can't stop/start an inject node, but you could use a node-red-contrib-simple-gate node to block or allow through the messages from the inject node.
Easy enough to pause a repeating inject by blocking the msg.
demo flow (use CTRL-I to import)
[{"id":"46f1036c0b5f6b8c","type":"http in","z":"fe471bfa726693b8","name":"","url":"/pause","method":"get","upload":false,"swaggerDoc":"","x":1090,"y":580,"wires":[["fc3612c3a8301232"]]},{"id":"06fb4054f7ef1d7c","type":"http in","z":"fe471bfa726693b8","name":"","url":"/resume","method":"get","upload":false,"swaggerDoc":"","x":1090,"y":620,"wires":[["afdf484497bb0a27"]]},{"id":"fc3612c3a8301232","type":"change","z":"fe471bfa726693b8","name":"Set flow.pauseInject = true","rules":[{"t":"set","p":"pauseInject","pt":"flow","to":"true","tot":"bool"}],"action":"","property":"","from":"","to":"","reg":false,"x":1300,"y":580,"wires":[["4f9ddd7c2cb98bf5"]]},{"id":"afdf484497bb0a27","type":"change","z":"fe471bfa726693b8","name":"Set flow.pauseInject = false","rules":[{"t":"set","p":"pauseInject","pt":"flow","to":"false","tot":"bool"}],"action":"","property":"","from":"","to":"","reg":false,"x":1300,"y":620,"wires":[["4f9ddd7c2cb98bf5"]]},{"id":"6cb64f61850390f1","type":"http response","z":"fe471bfa726693b8","name":"HTTP Response 200","statusCode":"200","headers":{},"x":1660,"y":580,"wires":[]},{"id":"fb8df2844a9de85a","type":"inject","z":"fe471bfa726693b8","name":"Every 5 sec","props":[{"p":"payload"},{"p":"topic","vt":"str"}],"repeat":"5","crontab":"","once":false,"onceDelay":0.1,"topic":"","payload":"","payloadType":"date","x":1100,"y":500,"wires":[["ac47afbe45a8f609"]]},{"id":"ac47afbe45a8f609","type":"switch","z":"fe471bfa726693b8","name":"is paused? \\n not paused!","property":"pauseInject","propertyType":"flow","rules":[{"t":"true"},{"t":"else"}],"checkall":"true","repair":false,"outputs":2,"x":1290,"y":500,"wires":[["14b18453af9198a7"],["87abb18314482647"]]},{"id":"14b18453af9198a7","type":"debug","z":"fe471bfa726693b8","name":"flow.pauseInject === true - do nothing","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"payload","targetType":"msg","statusVal":"","statusType":"auto","x":1590,"y":480,"wires":[]},{"id":"87abb18314482647","type":"debug","z":"fe471bfa726693b8","name":"flow.pauseInject !== true - do something","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"payload","targetType":"msg","statusVal":"","statusType":"auto","x":1580,"y":520,"wires":[]},{"id":"4f9ddd7c2cb98bf5","type":"function","z":"fe471bfa726693b8","name":"Pause Status","func":"const paused = flow.get('pauseInject') || false\n\nif (paused) {\n node.status({fill:\"red\",shape:\"ring\",text:\"Paused\"})\n} else {\n node.status({fill:\"green\",shape:\"dot\",text:\"Unpaused\"})\n}\n\nreturn msg","outputs":1,"timeout":0,"noerr":0,"initialize":"","finalize":"","libs":[],"x":1485,"y":600,"wires":[["6cb64f61850390f1","0ed5945d20cfb087"]],"icon":"font-awesome/fa-question-circle-o","l":false},{"id":"0ed5945d20cfb087","type":"debug","z":"fe471bfa726693b8","name":"debug 307","active":false,"tosidebar":true,"console":false,"tostatus":false,"complete":"true","targetType":"full","statusVal":"","statusType":"auto","x":1670,"y":620,"wires":[]}]
Here is my example using node-red-contrib-queue-gate
using url parameters to start and stop updating of a timestamp.
Start - http://yourip:1880/nr-help-timestamp?action=start
If you refresh the page the timestamp will change every 5 seconds
Stop - http://yourip:1880/nr-help-timestamp?action=stop
when you refresh the page the timestamp will remain the same
[
{
"id": "839ddaad8d0899de",
"type": "inject",
"z": "c272682f840e082e",
"name": "",
"props": [
{
"p": "timestamp",
"v": "",
"vt": "date"
}
],
"repeat": "5",
"crontab": "",
"once": true,
"onceDelay": 0.1,
"topic": "",
"x": 650,
"y": 100,
"wires": [
[
"553fd81486ef7866"
]
]
},
{
"id": "402eea59f3ef5733",
"type": "change",
"z": "c272682f840e082e",
"name": "",
"rules": [
{
"t": "set",
"p": "nr_help_timestamp",
"pt": "flow",
"to": "timestamp",
"tot": "msg"
}
],
"action": "",
"property": "",
"from": "",
"to": "",
"reg": false,
"x": 1040,
"y": 140,
"wires": [
[]
]
},
{
"id": "3de4a4d8269e31f2",
"type": "http in",
"z": "c272682f840e082e",
"name": "",
"url": "/nr-help-timestamp",
"method": "get",
"upload": false,
"swaggerDoc": "",
"x": 200,
"y": 180,
"wires": [
[
"2c7eecc2f2d6f0e7",
"03bc98d66492f823",
"0cdfd60ecbdef030"
]
]
},
{
"id": "553fd81486ef7866",
"type": "q-gate",
"z": "c272682f840e082e",
"name": "",
"controlTopic": "control",
"defaultState": "open",
"openCmd": "open",
"closeCmd": "close",
"toggleCmd": "toggle",
"queueCmd": "queue",
"defaultCmd": "default",
"triggerCmd": "trigger",
"flushCmd": "flush",
"resetCmd": "reset",
"peekCmd": "peek",
"dropCmd": "drop",
"statusCmd": "status",
"maxQueueLength": "100",
"keepNewest": false,
"qToggle": false,
"persist": false,
"storeName": "memory",
"x": 830,
"y": 140,
"wires": [
[
"402eea59f3ef5733"
]
]
},
{
"id": "1c18c01330c5be67",
"type": "function",
"z": "c272682f840e082e",
"name": "headders, paylod and status code",
"func": "msg.statusCode = \"200\";\nmsg.headers = {};\nmsg.headers['X-Robots-Tag'] = \"noindex\";\nmsg.headers['content-type'] = 'text/html';\n\n\nreturn msg;\n",
"outputs": 1,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 700,
"y": 240,
"wires": [
[
"a13ecdd84523da3b"
]
]
},
{
"id": "a13ecdd84523da3b",
"type": "http response",
"z": "c272682f840e082e",
"name": "",
"statusCode": "",
"headers": {},
"x": 930,
"y": 240,
"wires": []
},
{
"id": "2c7eecc2f2d6f0e7",
"type": "debug",
"z": "c272682f840e082e",
"name": "",
"active": true,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "true",
"targetType": "full",
"statusVal": "",
"statusType": "auto",
"x": 410,
"y": 200,
"wires": []
},
{
"id": "0cdfd60ecbdef030",
"type": "change",
"z": "c272682f840e082e",
"name": "",
"rules": [
{
"t": "set",
"p": "payload",
"pt": "msg",
"to": "nr_help_timestamp",
"tot": "flow"
}
],
"action": "",
"property": "",
"from": "",
"to": "",
"reg": false,
"x": 440,
"y": 240,
"wires": [
[
"1c18c01330c5be67"
]
]
},
{
"id": "03bc98d66492f823",
"type": "switch",
"z": "c272682f840e082e",
"name": "",
"property": "payload.action",
"propertyType": "msg",
"rules": [
{
"t": "eq",
"v": "start",
"vt": "str"
},
{
"t": "eq",
"v": "stop",
"vt": "str"
}
],
"checkall": "true",
"repair": false,
"outputs": 2,
"x": 410,
"y": 160,
"wires": [
[
"95f2702c1e79dfa3"
],
[
"8cfba2cb0cb70f38"
]
]
},
{
"id": "95f2702c1e79dfa3",
"type": "change",
"z": "c272682f840e082e",
"name": "",
"rules": [
{
"t": "set",
"p": "payload",
"pt": "msg",
"to": "open",
"tot": "str"
},
{
"t": "set",
"p": "topic",
"pt": "msg",
"to": "control",
"tot": "str"
}
],
"action": "",
"property": "",
"from": "",
"to": "",
"reg": false,
"x": 620,
"y": 140,
"wires": [
[
"553fd81486ef7866"
]
]
},
{
"id": "8cfba2cb0cb70f38",
"type": "change",
"z": "c272682f840e082e",
"name": "",
"rules": [
{
"t": "set",
"p": "payload",
"pt": "msg",
"to": "close",
"tot": "str"
},
{
"t": "set",
"p": "topic",
"pt": "msg",
"to": "control",
"tot": "str"
}
],
"action": "",
"property": "",
"from": "",
"to": "",
"reg": false,
"x": 620,
"y": 180,
"wires": [
[
"553fd81486ef7866"
]
]
}
]
You can send the http request and have it action a trigger node
e.g
[{"id":"184f4bd41cfa6871","type":"http in","z":"b9860b4b9de8c8da","name":"","url":"/my_trigger","method":"get","upload":false,"swaggerDoc":"","x":180,"y":60,"wires":[["7e7eddab92114949","586d5c3c36b05da6"]]},{"id":"7e7eddab92114949","type":"http response","z":"b9860b4b9de8c8da","name":"","statusCode":"","headers":{},"x":430,"y":40,"wires":[]},{"id":"586d5c3c36b05da6","type":"switch","z":"b9860b4b9de8c8da","name":"","property":"payload.reset","propertyType":"msg","rules":[{"t":"eq","v":"stop","vt":"str"},{"t":"else"}],"checkall":"true","repair":false,"outputs":2,"x":270,"y":100,"wires":[["a45820d6622d54a7"],["e530a41c5ce1de3f"]]},{"id":"a45820d6622d54a7","type":"change","z":"b9860b4b9de8c8da","name":"","rules":[{"t":"set","p":"reset","pt":"msg","to":"true","tot":"bool"}],"action":"","property":"","from":"","to":"","reg":false,"x":420,"y":80,"wires":[["25d23891bc61af28"]]},{"id":"e530a41c5ce1de3f","type":"change","z":"b9860b4b9de8c8da","name":"","rules":[{"t":"set","p":"delay","pt":"msg","to":"$number($$.payload.delay)","tot":"jsonata"},{"t":"set","p":"payload","pt":"msg","to":"payload.msg","tot":"msg"}],"action":"","property":"","from":"","to":"","reg":false,"x":420,"y":120,"wires":[["25d23891bc61af28"]]},{"id":"25d23891bc61af28","type":"trigger","z":"b9860b4b9de8c8da","name":"","op1":"","op2":"0","op1type":"pay","op2type":"str","duration":"-250","extend":false,"overrideDelay":true,"units":"ms","reset":"","bytopic":"all","topic":"topic","outputs":1,"x":660,"y":100,"wires":[["1b1e36805660c0bf"]]},{"id":"1b1e36805660c0bf","type":"debug","z":"b9860b4b9de8c8da","name":"debug 324","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"true","targetType":"full","statusVal":"","statusType":"auto","x":730,"y":200,"wires":[]}]
to start trigger http://ip:1880/my_trigger?msg={%22test%22:1}&delay=5000
To stop trigger http://ip:1880/my_trigger?reset=stop
This could be done in numerous ways. This is an example and may need additional checks.
Loving this thread .... In less than an hour you have 3 ways to to do it. .... Any other Ideas?. Threads like this open your mind to the possibilities.
I would like to thank you all for your kind replies!
I will try all the suggestions.
It's true meeki007, this is the power of the community!!!
Best regards to all.
Copyright OpenJS Foundation and Node-RED contributors. All rights reserved. The OpenJS Foundation has registered trademarks and uses trademarks. For a list of trademarks of the OpenJS Foundation, please see our Trademark Policy and Trademark List. Trademarks and logos not indicated on the list of OpenJS Foundation trademarks are trademarks™ or registered® trademarks of their respective holders. Use of them does not imply any affiliation with or endorsement by them.
The OpenJS Foundation | Terms of Use | Privacy Policy | OpenJS Foundation Bylaws | Trademark Policy | Trademark List | Cookie Policy