Add IPC

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:

forwarder/app.py

@@ -1,12 +1,10 @@
 import os
-# import awsiot.greengrasscoreipc
+import awsiot.greengrasscoreipc
-# import awsiot.greengrasscoreipc.client as client
+import awsiot.greengrasscoreipc.client as client
-# import awsiot.greengrasscoreipc.model as model
+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()
+  ipc_client = awsiot.greengrasscoreipc.connect()
-  # publish_operation.activate(
+
-  #   request = model.PublishToIoTCoreRequest(
+  publish_operation = ipc_client.new_publish_to_iot_core()
-  #     topic_name = 'MCT/PY/FD',
+
-  #     qos = model.QOS.AT_MOST_ONCE,
+  publish_operation.activate(
-  #     payload = json.dumps(message).encode()
+    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