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"