techwire/chirpstack-docker
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix payload

Browse Source
This commit is contained in:
MinCheTsai 2022-10-13 19:43:42 +08:00
parent 888d86094f
commit 9ac8ade609
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
forwarder/app.py
View File

@ -15,11 +15,13 @@ def on_message(client, userdata, msg):
# @TODO add DevEUI to topic # @TODO add DevEUI to topic
topic = "{}/up".format(os.environ["AWS_IOT_THING_NAME"]) topic = "{}/up".format(os.environ["AWS_IOT_THING_NAME"])
payload = json.loads(str(msg.payload.decode("utf-8"))) payload = json.loads(str(msg.payload.decode("utf-8")))
print(payload['object']) print(payload)
# print(payload['rxInfo']['gatewayId'])
# print(payload['deviceInfo']['devEui'])
message = { message = {
"GatewayEui": payload['rxInfo']['gatewayId'], # "GatewayEui": payload['rxInfo']['gatewayId'],
"DevEui": payload['deviceInfo']['devEui'], # "DevEui": payload['deviceInfo']['devEui'],
"Payload": payload['object'] "Payload": payload
} }
print(message) print(message)
ipc_client = awsiot.greengrasscoreipc.connect() ipc_client = awsiot.greengrasscoreipc.connect()