MQTT Node-RED
Flow to consume and publish MQTT messages in Node-RED.
[{"id":"7d551c48106025c7","type":"tab","label":"MQTT","disabled":false,"info":"","env":[]},{"id":"32db09c9fa53208a","type":"mqtt in","z":"7d551c48106025c7","name":"","topic":"test/nodered","qos":"2","datatype":"auto-detect","broker":"4ae871e7af2bec38","nl":false,"rap":true,"rh":0,"inputs":0,"x":120,"y":100,"wires":[["201a08568190af2e"]]},{"id":"201a08568190af2e","type":"debug","z":"7d551c48106025c7","name":"debug 1","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"payload","targetType":"msg","statusVal":"","statusType":"auto","x":340,"y":100,"wires":[]},{"id":"b441fc1a3029794b","type":"mqtt out","z":"7d551c48106025c7","name":"","topic":"test/nodered","qos":"2","retain":"false","respTopic":"","contentType":"","userProps":"","correl":"","expiry":"","broker":"4ae871e7af2bec38","x":530,"y":260,"wires":[]},{"id":"e00113df604cc5bf","type":"inject","z":"7d551c48106025c7","name":"","props":[{"p":"payload"},{"p":"topic","vt":"str"}],"repeat":"","crontab":"","once":false,"onceDelay":0.1,"topic":"","payload":"","payloadType":"date","x":120,"y":200,"wires":[["b3fbc4a08ea3103a"]]},{"id":"b3fbc4a08ea3103a","type":"function","z":"7d551c48106025c7","name":"function 1","func":"msg.payload = {\n data:{\n temperature: 34,\n windspeed: 2.3\n }\n}\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","libs":[],"x":300,"y":260,"wires":[["b441fc1a3029794b"]]},{"id":"4ae871e7af2bec38","type":"mqtt-broker","name":"EMQX","broker":"cb8ee20e.ala.us-east-1.emqxsl.com","port":"8883","tls":"6b62b414c3dccdfc","clientid":"","autoConnect":true,"usetls":true,"protocolVersion":"4","keepalive":"60","cleansession":true,"birthTopic":"","birthQos":"0","birthPayload":"","birthMsg":{},"closeTopic":"","closeQos":"0","closePayload":"","closeMsg":{},"willTopic":"","willQos":"0","willPayload":"","willMsg":{},"userProps":"","sessionExpiry":""},{"id":"6b62b414c3dccdfc","type":"tls-config","name":"EMQX_CA","cert":"","key":"","ca":"","certname":"","keyname":"","caname":"emqxsl-ca (1).crt","servername":"","verifyservercert":true,"alpnprotocol":""}]