in Solutions/AWSSCV-CTRLogger/Code/awsscv_ctr_logger/awsscv_ctr_logger.py [0:0]
def lambda_handler(event, context):
for record in event['Records']:
payload = json.loads(base64.b64decode(record['kinesis']['data']))
if (write_to == 'console' or write_to == 'both'):
log_to_console(payload)
if (write_to == 's3' or write_to == 'both'):
log_to_s3(payload)