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