Skip to content Skip to sidebar Skip to footer

Aws Firehose Lambda Function Invocation Gives Wrong Output Strcuture Format

When i insert a data object to aws firhose stream using a put operation it works fine .As lambda function is enabled on my firehose stream .hence a lambda function is invoked but

Solution 1:

import json import base64 import gzip import io import zlib

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

for record in event['records']:
    payload = base64.b64decode(record['data']).decode('utf-8')
    output_record = {
        'recordId': record['recordId'],
        'result': 'Ok',
        'data': base64.b64encode(payload.encode('utf-8')).decode('utf-8')
    }
    output.append(output_record)

return {'records': output}

Post a Comment for "Aws Firehose Lambda Function Invocation Gives Wrong Output Strcuture Format"