在AWS Firehose中,可以通过在数据流中添加一个特定的换行符来实现换行。以下是一个使用Python SDK(boto3)的代码示例:
import boto3
# 创建Firehose客户端
firehose_client = boto3.client('firehose', region_name='us-west-2')
# 设置换行符
delimiter = '\n'
# 准备要发送到Firehose的数据
data = 'Data 1' + delimiter + 'Data 2' + delimiter + 'Data 3'
# 发送数据到Firehose
response = firehose_client.put_record(
DeliveryStreamName='your-delivery-stream-name',
Record={
'Data': data.encode('utf-8')
}
)
print(response)
上述示例中,我们使用delimiter变量来设置换行符,然后将数据按照指定的换行符连接起来。最后,我们将数据使用put_record方法发送到Firehose数据流中。
请注意,your-delivery-stream-name应替换为您自己的Firehose数据流名称。