问题标签 [aws-iot-analytics]

我正在尝试从我的 java sdk 中获取来自 iot analytics(AWS) 的数据，我已经创建了通道和管道，并且数据在数据集中

有人知道 aws iot 分析数据获取机制吗？

我在 AWS IoT Analytics 中创建了以下内容：

• 频道：Iot Core 主题模式 => $aws/things/+/shadow/update/accepted
• 管道：从上一个通道馈送，从消息中选择属性
• 用于保存消息的数据存储

通道的传入消息是影子更新/已接受，如下所示：

我想从主题结构中提取事物名称，我在这里将其作为通配符：

有没有办法做到这一点，或者如果我想在这里使用它进行处理，它必须直接包含在消息正文中吗？

谢谢。

我可以将 JSON 中的相同键值发送到 AWS IOT Analytics 管道吗？有谁知道如何解决这个问题？这是我的 JSON：

{“数据”：[{“传感器”：{“值”：100.1}，“ts”：1401000}，{“传感器”：{“值”：120.5}，“ts”：1401154}，{“slave2” ：{“point1”：50}，“ts”：1401250}，{“slave2”：{“point2”：假}，“ts”：140350}，{“current_sensor”：10，“ts”：150400}， {“水位”：50，“ts”：1504450 }，{“开关”：真，“ts”：154030 }]}

在消息为 lambda 中的转换后，我从 AWS IoT Analytics 服务收到此错误：我的 lambda 获取作为输入的 json 格式字符串

数据键在特定时间跨度上保存我的 IoT 数据值

lambda 解析上述输入并返回 dict 数组：

我没有成功创建 my_data_store 如果有人可以提供帮助，我会很高兴。谢谢

我们可以在从 AWS IoT Analytics 的数据集中检索数据时使用查询吗？我想要两个时间戳之间的数据。我使用 boto3 来获取数据。我没有看到在获取数据集内容中使用查询的任何选项下面是 boto3 代码： response = client.get_dataset_content( datasetName='string', versionId='string' )

有没有人建议如何使用查询或如何在 AWS IoT Analytics 中检索 2 个时间戳之间的数据？

谢谢， 潘卡伊

我有一个使用 boto3 创建 IoT Analytics 路径的 python 程序。我的程序能够成功创建通道和数据存储，但是当我尝试通过创建管道功能连接两者时失败。我的代码如下：

错误代码如下：

根据文档，管道活动可以包含 1 到 25 个条目，只要它们位于 1 个对象的数组中。我不知道为什么这继续失败。任何帮助表示赞赏。

我想通过指定 Lambda 的 IoT Analytics 数据集来获取最新数据。

如果使用 aws sdk 的 IoTAnalytics 的 getDatasetContent，则只会返回下载文件的链接。无法获取数据本身。

我想知道如何从 Lambda 获取有关 IoT Analytics 数据集的信息。

我在 IoT Core 中有一条规则，将消息发送到 IoT Analytics 通道，然后将数据传递到 Analytics 管道，但是在管道中，我想利用管道活动来转换消息，特别是： Transform 消息使用 Lambda 函数活动。

我的 Lambda 函数返回它从 DynamoDB 检索的值，我已经在 AWS Lambda 中测试了 Lambda，它按应有的方式执行和工作，但是，一旦我单击更新预览，现在应该向我显示转换后的消息，我收到以下错误：

我们无法运行管道活动。ERROR : 由于权限不足，无法执行 Lambda 函数；丢弃消息，丢弃的消息数量：1，functionArn：arn:aws:lambda:eu-west-1:x:function:y

与 Lambda y 函数关联的 IAM 角色具有以下权限：

• AmazonDynamoDBFullAccess
• AWSIoTAnalyticsFullAccess
• AWSIoTFullAccess

是否有可能我在 IAM 角色中没有针对 Lambda 的策略阻止它执行我需要它执行的操作？

AWS IOT Analytics Pipeline 无法从设备注册表或设备影子中丰富数据，因为它无法在消息中找到事物的元数据和影子详细信息。这些数据是如何被带入消息中以进行丰富的？ 是否有某种设置，或者我必须明确获取这些详细信息并包含在消息中？

我已将 IOT 分析通道配置为从 $aws/things/+/shadow/update/documents 获取消息。

查询操作：SELECT topic() as topic, * AS message FROM "$aws/things/+/shadow/update/documents"

从 IOT Core 中的 Action 配置的通道。

我一次从我的频道中的 IoT 设备接收多个数据记录作为 JSON 数组。收到的消息如下所示：

我使用以下 SQL 查询创建了一个数据集：

当我运行数据集时，返回的结果是：

我想要的结果是：

如何让 IoT Analytics 在数据存储中为接收到的 JSON 数组中的每个元素创建一个新行？