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