要给AWS Kinesis Firehose转换Lambda权限,您需要执行以下步骤:
创建IAM角色:
创建Lambda函数:
添加Lambda函数到Firehose数据转换:
现在,您的AWS Kinesis Firehose流已配置为使用Lambda函数进行数据转换。
以下是一个示例Lambda函数,将接收Kinesis Firehose数据记录并将其转换为大写:
import base64
import json
def lambda_handler(event, context):
output = []
for record in event['records']:
payload = base64.b64decode(record['data'])
transformed_payload = payload.decode().upper()
output_record = {
'recordId': record['recordId'],
'result': 'Ok',
'data': base64.b64encode(transformed_payload.encode()).decode()
}
output.append(output_record)
return {'records': output}
您可以将此代码复制并粘贴到Lambda函数中,并根据需要进行调整。该函数将遍历传递给它的每个数据记录,并将其转换为大写。然后,它将构建输出记录并返回给Kinesis Firehose。