import json import logging logger = logging.getLogger() logger.setLevel(logging.INFO) def handler(event, context): logger.info('Kinesis record has been received') logger.info(json.dumps(event, indent=2)) return { 'statusCode': 200, 'body': 'Kinesis record has been received' }