From 888d86094fc8464722ad09667859133ad92fcde5 Mon Sep 17 00:00:00 2001 From: MinCheTsai Date: Thu, 13 Oct 2022 19:36:42 +0800 Subject: [PATCH] Fix payload --- forwarder/app.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/forwarder/app.py b/forwarder/app.py index 64a7f71..664fb0e 100644 --- a/forwarder/app.py +++ b/forwarder/app.py @@ -12,10 +12,14 @@ def on_connect(client, userdata, flags, rc): client.subscribe("application/+/device/+/event/up") def on_message(client, userdata, msg): + # @TODO add DevEUI to topic + topic = "{}/up".format(os.environ["AWS_IOT_THING_NAME"]) payload = json.loads(str(msg.payload.decode("utf-8"))) print(payload['object']) message = { - payload: payload['object'] + "GatewayEui": payload['rxInfo']['gatewayId'], + "DevEui": payload['deviceInfo']['devEui'], + "Payload": payload['object'] } print(message) ipc_client = awsiot.greengrasscoreipc.connect() @@ -24,7 +28,7 @@ def on_message(client, userdata, msg): publish_operation.activate( request = model.PublishToIoTCoreRequest( - topic_name = 'MCT/PY/FD', + topic_name = topic, qos = model.QOS.AT_MOST_ONCE, payload = json.dumps(message).encode() )