in cdk-iot-analytics/cdk_sap_blog/analytics/lambda_assets/get_product_range/get_product_range.py [0:0]
def handler(event, context):
logger.info("events before processing: {}".format(event))
transformedEvents = []
for evt in event:
# extract thing 'Type'
try:
item = table.get_item(
Key = {
'Type': evt['registry']['attributes']['Type']
}
)
evt['range'] = item['Item']['range']
evt['Type'] = item['Item']['Type']
evt['FunctLoc'] = item['Item']['FunctLoc']
evt['Equipment'] = item['Item']['Equipment']
logger.info("transformed event {}".format(evt))
except Exception as exc:
logger.info("Exception: " + str(type(exc)))
logger.info("couldn't find range for event: {}".format(traceback.format_exc(), exc_info=True))
finally:
transformedEvents.append(evt)
return transformedEvents