本文主要是介绍将AWS iot消息数据发送Kinesis Firehose Stream存向S3，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
观看此文章之前，请先学习AWS iot的数据收集：
使用Linux SDK客户端向AWS Iot发送数据-CSDN博客
1、工作原理：
1.1 规则
规则可让您的设备与 AWS 服务进行交互。分析规则并根据物品发送的消息执行操作。您可以使用规则来支持任务，例如补充或筛选从设备接收的数据。
1.2 目的地
目的地是定义规则引擎可将数据路由至何处的资源。目的地可以跨规则重复使用，并且可能需要经过确认或配置才能使用。目的地可让规则引擎将数据发送到未与 AWS IoT 原生集成的其他服务。
2、创建消息路由
2.1 点击消息路由，并创建规则
2.2 规则名称
2.3 选择SQL语句
使用以下值输入 SQL 语句：SELECT <Attribute> FROM <Topic Filter> WHERE <Condition>。例如：SELECT temperature FROM 'iot/topic' WHERE temperature > 50。 要了解更多信息，请参阅 AWS IoT SQL 参考。
SELECT * FROM 'sdk/test/python'
2.4 操作写入KFS
2.5 创建Firehose流
源选择 Direct PUT 目标选择Amazon S3
2.5 创建存储桶
2.6 设置目标
2.7 创建新角色
至此，完成消息路由的创建
3、测试
3.1 客户端操作
3.2 检查S3数据
这篇关于将AWS iot消息数据发送Kinesis Firehose Stream存向S3的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
