Changes between Version 5 and Version 6 of nodered

Timestamp:

12/17/2021 11:14:33 PM (3 years ago)

Author:

Ryan Erbstoesser

Comment:

add resources, also update script

nodered

@@ -45 +45 @@
 
 == Gateworks Python Script to send MQTT Messages
+
+The below is a sample python script to pass MQTT messages from the Gateworks SBC to the Node-Red server (broker). The script will pass the Gateworks SBC temperature as the payload and send it specific to the devices serial number. 
+
 {{{
-root@focal-venice:~# cat gateworks.py 
 # Compatible with python 2.* version
 import sys
@@ -56 +58 @@
 from datetime import datetime
 
-def callbackMessage(msg):
-    if msg:
-        print("\n--- Command Message Received ---")
-        print(str(msg['ack']))
-        print(str(msg['ackId']))
-        print(str(msg['command']))
-        print(str(msg['uniqueId']))
+def on_message(client, userdata, message):
+ print("message received " ,str(message.payload.decode("utf-8")))
+ print("message topic=",message.topic)
+ print("message qos=",message.qos)
+ print("message retain flag=",message.retain)
 
-def callbackTwinMessage(msg):
-    if msg:
-        print("\n--- Twin Message Received ---")
-        print(json.dumps(msg))
+def on_connect(client, userdata, rc,a):
+ print("Connected with result code "+str(rc))
+ # Subscribing in on_connect() means that if we lose the connection and
+ # reconnect then subscriptions will be renewed.
+ client.subscribe("gateways/id/#")
 
 def main(argv):
+ client = mqtt.Client("clientone")
+ client.on_connect = on_connect 
+ client.on_message = on_message 
+ broker = "122.24.55.93"
+ client.connect(broker) 
+ client.loop_start()
+ time.sleep(5)
  while True:
     try:
-        env = "enter_evn_name_here"
-
-        uniqueId = "enter_device_id_here_example_device1"
-        cpId = "enter_company_id_here_from_avnet_portal"
         print("in loop")
-        client = mqtt.Client("clientone")
-        broker = "122.24.11.93"
-        client.connect(broker) 
-        client.subscribe("house/bulbs")
-        client.publish("house/bulbs","OFF")
+        temp = float(open('/sys/class/hwmon/hwmon0/temp1_input', 'r').read().strip())/1000
+        client.publish("gateways/id/45",temp,1)
         print("done publishing")
 
@@ -87 +88 @@
         print(ex.message)
         sys.exit(0)
-    time.sleep(10)
+    time.sleep(5)
 
 
@@ -93 +94 @@
     main(sys.argv)
 
+
 }}}
 
 
-
+== Links & Resources
+* [https://nodered.org/]
+* [http://www.steves-internet-guide.com/into-mqtt-python-client/] 
+* [https://nodejs.org/en/about/releases/]