diff --git a/docker-compose.yml b/docker-compose.yml index 11595e7..31b7492 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -64,6 +64,13 @@ services: forwarder: build: ./forwarder restart: unless-stopped + environment: + - AWS_REGION + - SVCUID + - AWS_GG_NUCLEUS_DOMAIN_SOCKET_FILEPATH_FOR_COMPONENT + - AWS_CONTAINER_AUTHORIZATION_TOKEN + - AWS_CONTAINER_CREDENTIALS_FULL_URI + - AWS_IOT_THING_NAME volumes: postgresqldata: diff --git a/forwarder/app.py b/forwarder/app.py index b969489..64a7f71 100644 --- a/forwarder/app.py +++ b/forwarder/app.py @@ -1,12 +1,10 @@ import os -# import awsiot.greengrasscoreipc -# import awsiot.greengrasscoreipc.client as client -# import awsiot.greengrasscoreipc.model as model +import awsiot.greengrasscoreipc +import awsiot.greengrasscoreipc.client as client +import awsiot.greengrasscoreipc.model as model import json import paho.mqtt.client as mqtt -# ipc_client = awsiot.greengrasscoreipc.connect() - print(os.environ) def on_connect(client, userdata, flags, rc): @@ -20,14 +18,17 @@ def on_message(client, userdata, msg): payload: payload['object'] } print(message) - # publish_operation = ipc_client.new_publish_to_iot_core() - # publish_operation.activate( - # request = model.PublishToIoTCoreRequest( - # topic_name = 'MCT/PY/FD', - # qos = model.QOS.AT_MOST_ONCE, - # payload = json.dumps(message).encode() - # ) - # ) + ipc_client = awsiot.greengrasscoreipc.connect() + + publish_operation = ipc_client.new_publish_to_iot_core() + + publish_operation.activate( + request = model.PublishToIoTCoreRequest( + topic_name = 'MCT/PY/FD', + qos = model.QOS.AT_MOST_ONCE, + payload = json.dumps(message).encode() + ) + ) client = mqtt.Client() client.on_connect = on_connect