Transform Records from Kinesis using Lambda Function for JSON data

lambdakinesis.py

import math
print('Loading function')

def lambda_handler(event, context):
    output = []

    for record in event['records']:
        payload = base64.b64decode(record['data'])
        entry = json.loads(payload)
        result = {
        	'date': entry['date'],
            'traxid': entry['traxid'], 
            'discount': entry['discount'],
            'amount': entry['amount'],
            'currency': math.ceil(entry['currency']),
        }
        # Do custom processing on the record payload here
        output_record = {
            'recordId': record['recordId'],
            'result': 'Ok',
            'data': base64.b64encode(json.dumps(result))
        }
        output.append(output_record)