in functions/DynamoDbToFirehose/lambda_function.py [0:0]
def lambda_handler(event, context):
for record in event['Records']:
if (record['eventName']) == 'INSERT':
put_record_in_firehose(record['dynamodb'])
return 'Successfully processed {} records.'.format(len(event['Records']))