Copy examples from aws-samples repo into here

Author: MikeDombo

examples/BinaryLambdaInvoke/invokee.py

@@ -1,14 +1,14 @@
 #
 # Copyright 2010-2018 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 #
-import sys
 import logging
+import sys
 
 # Setup logging to stdout
 logger = logging.getLogger(__name__)
 logging.basicConfig(stream=sys.stdout, level=logging.DEBUG)
 
 
 def handler(event, context):
-    logger.info('Invoked with payload ' + str(event))
-    return 'Invoked successfully'
+    logger.info("Invoked with payload " + str(event))
+    return "Invoked successfully"

examples/BinaryLambdaInvoke/invoker.py

@@ -9,34 +9,33 @@
 # be able to see 'Invoked successfully' returned by 'invokee' lambda. A lambda
 # function can support non-json payload, which is a new feature introduced in
 # GGC version 1.5.
-#
-import sys
+
 import base64
-import logging
 import json
+import logging
+import sys
+
 import greengrasssdk
 
 # Setup logging to stdout
 logger = logging.getLogger(__name__)
 logging.basicConfig(stream=sys.stdout, level=logging.DEBUG)
 
-client = greengrasssdk.client('lambda')
+client = greengrasssdk.client("lambda")
 
 
 def handler(event, context):
-    client_context = json.dumps({
-        'custom': 'custom text'
-    })
+    client_context = json.dumps({"custom": "custom text"})
 
     try:
         response = client.invoke(
             ClientContext=base64.b64encode(bytes(client_context)),
-            FunctionName='arn:aws:lambda:<region>:<accountId>:function:<targetFunctionName>:<targetFunctionQualifier>',
-            InvocationType='RequestResponse',
-            Payload='Non-JSON Data',
-            Qualifier='1'
+            FunctionName="arn:aws:lambda:<region>:<accountId>:function:<targetFunctionName>:<targetFunctionQualifier>",
+            InvocationType="RequestResponse",
+            Payload="Non-JSON Data",
+            Qualifier="1",
         )
 
-        logger.info(response['Payload'].read())
+        logger.info(response["Payload"].read())
     except Exception as e:
         logger.error(e)

examples/HelloWorld/greengrassHelloWorld.py

@@ -11,18 +11,19 @@
 # Greengrass core.  The handler will NOT be invoked in our example since
 # the we are executing an infinite loop.
 
-import greengrasssdk
 import logging
 import platform
 import sys
 from threading import Timer
 
+import greengrasssdk
+
 # Setup logging to stdout
 logger = logging.getLogger(__name__)
 logging.basicConfig(stream=sys.stdout, level=logging.DEBUG)
 
 # Creating a greengrass core sdk client
-client = greengrasssdk.client('iot-data')
+client = greengrasssdk.client("iot-data")
 
 # Retrieving platform information to send from Greengrass Core
 my_platform = platform.platform()
@@ -35,22 +36,21 @@
 # hitting the execution timeout of three seconds.  This is expected as
 # this function never returns a result.
 
+
 def greengrass_hello_world_run():
     try:
         if not my_platform:
             client.publish(
-                topic='hello/world',
-                queueFullPolicy='AllOrException',
-                payload='Hello world! Sent from Greengrass Core.')
+                topic="hello/world", queueFullPolicy="AllOrException", payload="Hello world! Sent from Greengrass Core."
+            )
         else:
             client.publish(
-                topic='hello/world',
-                queueFullPolicy='AllOrException',
-                payload='Hello world! Sent from '
-                        'Greengrass Core running on platform: {}'
-                        .format(my_platform))
+                topic="hello/world",
+                queueFullPolicy="AllOrException",
+                payload="Hello world! Sent from " "Greengrass Core running on platform: {}".format(my_platform),
+            )
     except Exception as e:
-        logger.error('Failed to publish message: ' + repr(e))
+        logger.error("Failed to publish message: " + repr(e))
 
     # Asynchronously schedule this function to be run again in 5 seconds
     Timer(5, greengrass_hello_world_run).start()

examples/HelloWorldCounter/greengrassHelloWorldCounter.py

@@ -0,0 +1,61 @@
+#
+# Copyright 2019 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+#
+
+# greengrassHelloWorldCounter.py
+# Demonstrates a simple publish to a topic using Greengrass core sdk
+# This lambda function will retrieve underlying platform information and send a hello world message along with the
+# platform information to the topic 'hello/world/counter' along with a counter to keep track of invocations.
+#
+# This Lambda function requires the AWS Greengrass SDK to run on Greengrass devices.
+# This can be found on the AWS IoT Console.
+
+import json
+import logging
+import platform
+import sys
+import time
+
+import greengrasssdk
+
+# Setup logging to stdout
+logger = logging.getLogger(__name__)
+logging.basicConfig(stream=sys.stdout, level=logging.DEBUG)
+
+# Creating a greengrass core sdk client
+client = greengrasssdk.client("iot-data")
+
+# Retrieving platform information to send from Greengrass Core
+my_platform = platform.platform()
+
+# Counter to keep track of invocations of the function_handler
+my_counter = 0
+
+
+def function_handler(event, context):
+    global my_counter
+    my_counter = my_counter + 1
+    try:
+        if not my_platform:
+            client.publish(
+                topic="hello/world/counter",
+                queueFullPolicy="AllOrException",
+                payload=json.dumps(
+                    {"message": "Hello world! Sent from Greengrass Core.  Invocation Count: {}".format(my_counter)}
+                ),
+            )
+        else:
+            client.publish(
+                topic="hello/world/counter",
+                queueFullPolicy="AllOrException",
+                payload=json.dumps(
+                    {
+                        "message": "Hello world! Sent from Greengrass Core running on platform: {}."
+                        + "  Invocation Count: {}".format(my_platform, my_counter)
+                    }
+                ),
+            )
+    except Exception as e:
+        logger.error("Failed to publish message: " + repr(e))
+    time.sleep(20)
+    return

examples/Storyline_MessageLambda/messageLambda.py

@@ -2,29 +2,24 @@
 # Copyright 2010-2017 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 #
 
-import sys
 import logging
+import sys
+
 import greengrasssdk
 
 # Setup logging to stdout
 logger = logging.getLogger(__name__)
 logging.basicConfig(stream=sys.stdout, level=logging.DEBUG)
 
-client = greengrasssdk.client('iot-data')
+client = greengrasssdk.client("iot-data")
 
 
 def message_handler(event, context):
     logger.info("Received message!")
-    if 'state' in event:
-        if event['state'] == "on":
-            client.update_thing_shadow(
-                thingName="RobotArm_Thing",
-                payload='{"state":{"desired":{"myState":"on"}}}')
-            logger.info("Triggering publish to shadow "
-                        "topic to set state to ON")
-        elif event['state'] == "off":
-            client.update_thing_shadow(
-                thingName="RobotArm_Thing",
-                payload='{"state":{"desired":{"myState":"off"}}}')
-            logger.info("Triggering publish to shadow "
-                        "topic to set state to OFF")
+    if "state" in event:
+        if event["state"] == "on":
+            client.update_thing_shadow(thingName="RobotArm_Thing", payload='{"state":{"desired":{"myState":"on"}}}')
+            logger.info("Triggering publish to shadow " "topic to set state to ON")
+        elif event["state"] == "off":
+            client.update_thing_shadow(thingName="RobotArm_Thing", payload='{"state":{"desired":{"myState":"off"}}}')
+            logger.info("Triggering publish to shadow " "topic to set state to OFF")

examples/Storyline_UptimeLambda/uptimeLambda.py

@@ -2,39 +2,32 @@
 # Copyright 2010-2019 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 #
 
-import sys
 import logging
+import sys
+
 import greengrasssdk
 
 # Setup logging to stdout
 logger = logging.getLogger(__name__)
 logging.basicConfig(stream=sys.stdout, level=logging.DEBUG)
 
-client = greengrasssdk.client('iot-data')
+client = greengrasssdk.client("iot-data")
 
 
 def uptime_handler(event, context):
     logger.info("Received message!")
-    if 'state' in event:
-        if event['state'] == "on":
+    if "state" in event:
+        if event["state"] == "on":
             try:
-                client.publish(
-                    topic='/topic/metering',
-                    queueFullPolicy='AllOrException',
-                    payload="Robot arm turned ON")
-                logger.info("Triggering publish to topic "
-                            "/topic/metering with ON state")
+                client.publish(topic="/topic/metering", queueFullPolicy="AllOrException", payload="Robot arm turned ON")
+                logger.info("Triggering publish to topic " "/topic/metering with ON state")
             except Exception as e:
-                logger.error("Failed to trigger publish to topic "
-                             "/topic/metering with ON state: " + repr(e))
-        elif event['state'] == "off":
+                logger.error("Failed to trigger publish to topic " "/topic/metering with ON state: " + repr(e))
+        elif event["state"] == "off":
             try:
                 client.publish(
-                    topic='/topic/metering',
-                    queueFullPolicy='AllOrException',
-                    payload="Robot arm turned OFF")
-                logger.info("Triggering publish to topic "
-                            "/topic/metering with OFF state")
+                    topic="/topic/metering", queueFullPolicy="AllOrException", payload="Robot arm turned OFF"
+                )
+                logger.info("Triggering publish to topic " "/topic/metering with OFF state")
             except Exception as e:
-                logger.error("Failed to trigger publish to topic "
-                             "/topic/metering with OFF state: " + repr(e))
+                logger.error("Failed to trigger publish to topic " "/topic/metering with OFF state: " + repr(e))

examples/StreamManagerKinesis/stream_manager_kinesis.py

@@ -13,7 +13,6 @@
     StreamManagerClient,
 )
 
-
 # This example will create a Greengrass StreamManager stream called "SomeStream".
 # It will then start writing data into that stream and StreamManager will
 # automatically export the written data to a Kinesis Data Stream called "MyKinesisStream".

examples/TES/lambda_function.py

@@ -2,19 +2,20 @@
 # Copyright 2010-2017 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 #
 
-from botocore.session import Session
+import logging
+import sys
+
 import greengrasssdk
 
-import sys
-import logging
+from botocore.session import Session
 
 # Setup logging to stdout
 logger = logging.getLogger(__name__)
 logging.basicConfig(stream=sys.stdout, level=logging.DEBUG)
 
-client = greengrasssdk.client('iot-data')
+client = greengrasssdk.client("iot-data")
 
-logger.info('Hello from pinned lambda. Outside of handler.')
+logger.info("Hello from pinned lambda. Outside of handler.")
 
 # Get creds from TES
 # Note: must make sure that creds are not available within local folder
@@ -24,7 +25,9 @@
 formatted_creds = """
 Access Key: {}\n
 Secret Key: {}\n
-Session Key: {}\n""".format(creds.access_key, creds.secret_key, creds.token)
+Session Key: {}\n""".format(
+    creds.access_key, creds.secret_key, creds.token
+)
 
 # Logging credential information is not recommended. This is for demonstration purposes only.
 # logger.info(formatted_creds)