amazon-web-services - 配置 Firehose 以便每个 S3 对象只写入一条记录?
问题描述
我正在使用 Firehose 传输流将 JSON 写入 S3。这些 JSON 代表调用。流通常会收到新版本的 JSON,它会带来有关所代表调用的新信息。
我希望我的 Firehose 将每个 JSON 记录写入一个单独的 S3 对象,因此不要像默认情况下那样将它们组合在一起。每个 JSON 都将写入一个标识调用的 S3 密钥,因此当出现新版本的 JSON 时,Firehose 会替换其在 S3 中的先前版本。这可能吗?
我看到我可以设置触发写入 S3 的缓冲区大小,但是我可以显式配置我的 Firehose 流,以便每条记录只写入一个 S3 对象吗?
不涉及红移。
解决方案
这对于Amazon Kinesis Data Firehose是不可能的。这是一个简化的服务,只有几个配置选项。
相反,您可以使用Amazon Kinesis Data Streams:
- 将数据发送到流
- 创建一个 AWS Lambda 函数,该函数将在流接收到数据时触发
- 编写 Lambda 函数代码以将数据写入适当的 Amazon S3 对象
推荐阅读
- python - 将 Pandas DataFrame 转换为单行 DataFrame,将一列的值保存为标题
- c# - 我将如何制作一个返回数据的函数
- javascript - 无法获取特定频道 - Discord.js v11.6.4
- smtp - 在 Apache/Debian/Linode 上为多个客户网站设置多个联系表格的最佳方式
- python - 努力理解如何在 qtdesigner 设计的选项卡布局中嵌入 matplotlib 小部件图形
- node.js - 无法将应用程序/八位字节流解析为节点 js 中的图像
- .net - 如何验证 devextreme 文本框中的输入格式?
- javascript - 在 `useEffect()` 中手动调用 api
- dropdown - 想要在页面加载时将下拉值放入文本框中,下拉值从 asp.net C# 中的数据库中获取
- python - 使用命令后如何检查消息;不和谐.py