python - 将字典列表写入 S3 文件中的单独行
问题描述
我正在使用 Kinesis Firehose 从 Kinesis Stream 读取数据并存储在 s3 json 文件中,每个字符串都写入单独的行:
{"DeviceID":"1000000","DeviceTypeID":2,"DeviceRecordTime":"2020-11-10"}
{"DeviceID":"1000000","DeviceTypeID":2,"DeviceRecordTime":"2020-11-10"}
我尝试使用 Lambda 和 boto3 从 Kinesis Stream 读取数据,将所有记录放入单个列表并使用 put_object 函数将其写入 s3,这就是我得到的原因:
{"_1":[{"DeviceID":"1000000","DeviceTypeID":2,"DeviceRecordTime":"2020-11-10"},{"DeviceID":"1000000","DeviceTypeID":2,"DeviceRecordTime":"2020-11-10"}]}
有什么方法可以使用 Lambda 实现与 Kinesis Firehose 相同的输出,将 json 字符串分隔在不同的行中?
谢谢你的任何提示。
解决方案
推荐阅读
- angular - 如何跨多个 Angular 组件搜索静态数据?
- c++ - 重置 dlmopen 命名空间
- python - 计算列表中海龟的步数 - python
- sql-server - 仅当来自选择的单个结果时才从选择更新
- android - 在我的代码中在哪里以及如何开始和停止进度条
- sql-server - STContains - 对多边形内的点进行测试失败
- node.js - 无法在 Node.js 中使用 winston 记录错误
- java - 如何为 TensorFlow Lite 模型指定 Firebase 模型输入以预测 Android 中的项目推荐
- sql - sp_addsrvrolemember 中的转义通配符 *
- c# - dotnet core 3.1 windows 服务无法加载配置设置