在 On-The-Fly 上创建 Multi-Account IoT 管道 AWS

通过遥测 Amazon Kinesis 流采集设备遥测数据。

检测亚马逊托管服务何时Apache Flink接收未注册的设备组（分片）。在自定义窗口中缓冲传入的消息并发出事件。

如果账户没有足够的容量，分片AWS Lambda函数会创建一个新账户和亚马逊简单存储服务 (Amazon S3) 存储桶。

使用 AWS 软件开发工具包为新分片创建 AWS 物联网分析频道、管道和数据存储，并将其注册到亚马逊 DynamoD B 中。

发出包含 AWS IoT 分析频道信息的注册事件。此事件触发Apache Flink窗口的亚马逊托管服务继续处理该分片的缓冲消息。

检测组中的新设备并向注册数据集 Lambda 函数发出异步事件。这会创建 AWS IoT 分析数据集，同时继续摄取遥测数据。

对于每个设备组，亚马逊托管服务会Apache Flink读取 AWS 物联网分析频道的注册信息。然后，它将设备数据上传到注册账户中的正确频道。

AWS IoT Analytics 将设备群组消息存储在频道中，并在管道中对其进行转换。 AWS 然后，物联网分析将转换后的数据存储在由亚马逊 S3 支持的数据存储中。

每台设备的 AWS IoT 分析数据集都使用数据存储库上的增量时间查询。这会将最近 5 分钟内的数据筛选到特定设备以简化查询。

使用 AWS Glue 或亚马逊 Redshift Spectrum 查询设备数据。