diff --git a/sonde-api-to-iot-core/lambda_function.py b/sonde-api-to-iot-core/lambda_function.py index 11f0ca8..1af0b9b 100644 --- a/sonde-api-to-iot-core/lambda_function.py +++ b/sonde-api-to-iot-core/lambda_function.py @@ -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()