testing QoS

This commit is contained in:
Michaela 2021-01-31 08:32:30 +10:00
parent 82dcaf86eb
commit 63313303f2

View File

@ -97,7 +97,7 @@ def lambda_handler(event, context):
(msg, x) = mqtt_connection.publish(
topic=f'sondes/{payload["serial"]}',
payload=json.dumps(payload),
qos=mqtt.QoS.AT_MOST_ONCE)
qos=mqtt.QoS.AT_LEAST_ONCE)
msg.result()