AWS IoT
开发人员指南
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 Amazon AWS 入门

Kinesis 操作

kinesis 操作允许您将 MQTT 消息中的数据写入 Kinesis 流。使用 kinesis 操作创建 AWS IoT 规则时,您必须指定以下信息:

stream

数据写入的 Kinesis 流。

partitionKey

用于确定将数据写入哪个分区的分区键。分区键通常由表达式 (例如,“${topic()}”或“${timestamp()}”) 组成。

注意

确保与规则关联的策略拥有 kinesis:PutRecord 权限。

下面的 JSON 示例介绍了如何在 AWS IoT 规则中定义 kinesis 操作:

{ "rule": { "sql": "SELECT * FROM 'some/topic'", "ruleDisabled": false, "actions": [{ "kinesis": { "roleArn": "arn:aws:iam::123456789012:role/aws_iot_kinesis", "streamName": "my_kinesis_stream", "partitionKey": "${topic()}" } }], } }

有关更多信息,请参阅 Kinesis 开发人员指南