Python Kinesis Data Stream to S3 Example 源码

Python Kinesis数据流到S3示例 此示例( )从获取随机生成的用户数据,然后将每个记录放入Kinesis Data Stream中。 然后,可以将Kinesis Data Firehose传递流配置为处理数据流,使用Lambda转换记录(请参阅代码),然后将它们放入S3存储桶中。 ###设置Lambda 通过AWS控制台创建一个新的Lambda函数: 在控制台的代码编辑器中,双击lambda_function.py 。 将所有代码替换为的代码: 点击部署 选择测试>配置测试事件 输入事件名称(“ BasicTest”) 将的内容复制到事件主体(这是JSON的很大一部分) 点击创建 单击测试以确认Lambda的作品 ###设置S3存储桶创建S3存储桶以接收数据 ###设置Kinesis数据流通过AWS控制台配置Kinesis数据流: 输入名字 输入多个分片(1