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:36:42 +08:00
parent f71c3dcbb4
commit 888d86094f
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
forwarder/app.py
View File

@ -12,10 +12,14 @@ def on_connect(client, userdata, flags, rc):
client.subscribe("application/+/device/+/event/up") client.subscribe("application/+/device/+/event/up")
def on_message(client, userdata, msg): 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"))) payload = json.loads(str(msg.payload.decode("utf-8")))
print(payload['object']) print(payload['object'])
message = { message = {
payload: payload['object'] "GatewayEui": payload['rxInfo']['gatewayId'],
"DevEui": payload['deviceInfo']['devEui'],
"Payload": payload['object']
} }
print(message) print(message)
ipc_client = awsiot.greengrasscoreipc.connect() ipc_client = awsiot.greengrasscoreipc.connect()
@ -24,7 +28,7 @@ def on_message(client, userdata, msg):
publish_operation.activate( publish_operation.activate(
request = model.PublishToIoTCoreRequest( request = model.PublishToIoTCoreRequest(
topic_name = 'MCT/PY/FD', topic_name = topic,
qos = model.QOS.AT_MOST_ONCE, qos = model.QOS.AT_MOST_ONCE,
payload = json.dumps(message).encode() payload = json.dumps(message).encode()
) )