def lambda_handler()

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']))