in src/docproc.py [0:0]
def lambda_handler(event, context):
try:
print("event: {}".format(event))
syncQueueUrl = os.environ['SYNC_QUEUE_URL']
asyncQueueUrl = os.environ['ASYNC_QUEUE_URL']
if("Records" in event and event["Records"]):
for record in event["Records"]:
try:
print("Processing record: {}".format(record))
if("eventName" in record and record["eventName"] == "INSERT"):
if("dynamodb" in record and record["dynamodb"] and "NewImage" in record["dynamodb"]):
processRecord(record, syncQueueUrl, asyncQueueUrl)
except Exception as e:
print("Faild to process record. Exception: {}".format(e))
except Exception as e:
print("Failed to process records. Exception: {}".format(e))