在使用AWS Firehose的FirehoseClient.putRecord()方法时,它不会自动批量处理记录。相反,您需要手动将多个记录组合成一个批量请求并发送给Firehose。
以下是一个示例代码,演示如何使用批量请求将多个记录发送给Firehose:
import boto3
client = boto3.client('firehose')
records = [
{
'Data': 'Record 1'
},
{
'Data': 'Record 2'
},
{
'Data': 'Record 3'
}
]
# 将多个记录组合成一个批量请求
batch_request = {
'DeliveryStreamName': 'your-delivery-stream-name',
'Records': records
}
response = client.put_record_batch(**batch_request)
print(response)
在上面的示例中,records列表包含了多个记录,每个记录都是一个字典,其中'Data'键存储了记录的数据。您可以根据需要添加更多的记录。
然后,我们将多个记录组合成一个批量请求,该请求包含了要发送到的Firehose交付流的名称和记录列表。
最后,我们使用client.put_record_batch()方法发送批量请求,并将响应打印出来。