Republish - Amazon IoT Core
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

Republish

republish (republish) 操作将MQTT消息重新发布到另一个MQTT主题。

要求

此规则操作具有以下要求:

  • Amazon IoT 可以IAM担任执行iot:Publish操作的角色。有关更多信息,请参阅 授予 Amazon IoT 规则所需的访问权限

    在 Amazon IoT 控制台中,您可以选择或创建 Amazon IoT 允许执行此规则操作的角色。

参数

使用此操作创建 Amazon IoT 规则时,必须指定以下信息:

headers

MQTT版本 5.0 标题信息。

有关更多信息,请参阅 “Amazon API参考MqttHeaders中的 “RepublishAction和”。

topic

要将消息重新发布到MQTT的主题。

若要重新发布到以 $ 开头的预留主题,请使用 $$ 代替。例如,如果要重新发布到设备影子主题 $aws/things/MyThing/shadow/update,请将主题指定为 $$aws/things/MyThing/shadow/update

注意

不支持重新发布到保留的任务主题

Amazon IoT Device Defender 保留主题不支持HTTP发布。

支持替换模板:是

qos

(可选)重新发布消息时要使用的服务质量 (QoS) 级别。有效值:01。默认值为 0。有关 MQTT QoS 的更多信息,请参阅。MQTT

支持替换模板:否

roleArn

允许 Amazon IoT 向MQTT主题发布内容的IAM角色。有关更多信息,请参阅 要求

支持替换模板:否

示例

以下JSON示例在 Amazon IoT 规则中定义了重新发布操作。

{ "topicRulePayload": { "sql": "SELECT * FROM 'some/topic'", "ruleDisabled": false, "awsIotSqlVersion": "2016-03-23", "actions": [ { "republish": { "topic": "another/topic", "qos": 1, "roleArn": "arn:aws:iam::123456789012:role/aws_iot_republish" } } ] } }

以下JSON示例定义了在 Amazon IoT 规则中使用替换模板的重新发布操作。

{ "topicRulePayload": { "sql": "SELECT * FROM 'some/topic'", "ruleDisabled": false, "awsIotSqlVersion": "2016-03-23", "actions": [ { "republish": { "topic": "${topic()}/republish", "roleArn": "arn:aws:iam::123456789012:role/aws_iot_republish" } } ] } }

以下JSON示例在 Amazon IoT 规则headers中定义了重新发布操作。

{ "topicRulePayload": { "sql": "SELECT * FROM 'some/topic'", "ruleDisabled": false, "awsIotSqlVersion": "2016-03-23", "actions": [ { "republish": { "topic": "${topic()}/republish", "roleArn": "arn:aws:iam::123456789012:role/aws_iot_republish", "headers": { "payloadFormatIndicator": "UTF8_DATA", "contentType": "rule/contentType", "correlationData": "cnVsZSBjb3JyZWxhdGlvbiBkYXRh", "userProperties": [ { "key": "ruleKey1", "value": "ruleValue1" }, { "key": "ruleKey2", "value": "ruleValue2" } ] } } } ] } }
注意

不会通过重新发布操作传递原始源 IP。