in lambda-bulk-importer/main.py [0:0]
def lambda_handler(event, context):
global config
if event.get('Records') is None:
print("ERROR: Configuration incorrect: no event record on invoke")
return
for record in event['Records']:
if record.get('eventSource') == 'aws:sqs':
config = json.loads(record["body"])
process_sqs()