in lambda-product-providers/main.py [0:0]
def process(payload):
# queue url is
queueUrl = os.environ.get('QUEUE_TARGET')
# Policy is required.
payload['policy_name'] = os.environ.get('POLICY_NAME')
# Thing group is desired, but optional.
# The reason why 'None' has to be set is an environment variable
# on a Lambda function cannot be set to empty
if (os.environ.get('THING_GROUP_NAME') == "None"):
payload['thing_group_name'] = ""
else:
payload['thing_group_name'] = os.environ.get('THING_GROUP_NAME')
# Thing group is desired, but optional.
if (os.environ.get('THING_TYPE_NAME') == "None"):
payload['thing_type_name'] = ""
else:
payload['thing_type_name'] = os.environ.get('THING_TYPE_NAME')
# Pass on to the queue for target processing.
print(json.dumps(payload))
client = boto3.client("sqs")
client.send_message( QueueUrl=queueUrl,
MessageBody=json.dumps(payload))