30 import paho.mqtt.client
as mqtt
33 SERIAL_PORT =
"/dev/ttyACM0" 35 MQTT_TOPIC =
"team/%s/field_%d" 36 MQTT_SERVER =
"localhost" 45 parts = data.rstrip().split(
",")
49 for payload
in fields:
51 topic = MQTT_TOPIC % (ci, index)
52 print(
"[MQTT] Sending %s => %s" % (topic, payload))
53 client.publish(topic, payload, MQTT_QOS, MQTT_RETAIN)
56 def on_connect(client, userdata, flags, rc):
57 print(
"[MQTT] Connected")
59 client = mqtt.Client()
60 client.on_connect = on_connect
61 print(
"[MQTT] Connecting...")
62 client.connect(MQTT_SERVER, MQTT_PORT, 60)
65 ser = serial.Serial(SERIAL_PORT, SERIAL_BAUD, timeout=0.5)
68 if len(line)
and line[0] !=
"#":
69 print(
"[SERIAL] Received %s" % line.rstrip())