检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
设备间通信 概述 订阅：物联网平台支持基于MQTT协议实现设备间的消息通信，用户可通过控制台创建规则，也可以通过调用物联网平台的创建规则触发条件、创建规则动作、修改规则触发条件接口配置并激活规则，向平台获取设备上报的消息。设备订阅只支持消息上报。
规则描述 自定义，如“数据转发至Bcs Hyperledger Fabric增强版”。 数据来源 选择“设备属性”。 触发事件 自动匹配“设备属性上报”。 资源空间 选择“所有资源空间”。 单击“设置转发目标”页签，单击“添加”，设置转发目标，设置完成后单击“确定”按钮。
规则描述 自定义，如数据转发至OBS存储。 数据来源 选择“设备属性”。 触发事件 自动匹配“设备属性上报”。 资源空间 选择“所有资源空间”。 图2 新建属性上报流转规则-数据转发至OBS 单击“设置转发目标”页签，单击“添加”，设置转发目标。
图4 新建转发目标-设置Mysql字段映射 单击“启动规则”，激活配置好的数据转发规则。 验证操作 触发规则数据来源的事件，比如设备属性上报。 期望结果： 登录MySQL管理控制台，打开目标表格，可以查看到表格目标字段转存的数据。
选择“规则>数据转发”进入“规则列表”页面。 图2 规则详情-数据转发规则 单击"详情"(如果没有规则请先创建规则)进入规则详情页面后切换到"设置转发目标"页签。
图1 数据转发-新建规则 参考下表填写参数后，单击“创建规则”。 表1 创建规则参数列表 参数名 参数说明 规则名称 创建的规则名称。 规则描述 对该规则的描述。 数据来源 设备：将操作设备的信息，如设备添加、设备删除、设备更新设置为数据来源。
选择左侧导航栏的“规则 > 数据转发”，单击页面左上角的“创建规则”。 参考下表填写参数后，单击“创建规则”。 表1 创建规则参数列表 参数名 参数说明 规则名称 创建的规则名称。 规则描述 对该规则的描述。
图1 购买MongoDB实例 配置设备接入服务 在设备接入服务中创建产品模型、注册设备并设置数据转发规则，实现当设备上报数据时将数据转发至MongoDB。 访问设备接入服务，单击“管理控制台”进入设备接入控制台。选择您的实例，单击实例卡片进入。
MQTT连接心跳时间建议值 心跳时间限定为30秒至1200秒，推荐设置为120秒。 消息发布与订阅 支持共享订阅，订阅同一Topic的客户端轮询消费推送数据，客户端只能订阅流转规则中创建的Topic。 不支持消息发布。 每个订阅请求的最大订阅数 同账号的最大Topic数一致。
图3 新建转发目标-转发至InfluxDB 图4 新建转发目标-设置InfluxDB字段映射 单击“启动规则”，激活配置好的数据转发规则。 验证操作 进入IoTDA管理控制台，创建设备。 期望结果： 使用客户端登录InfluxDB，进入数据库，查询数据成功。
华为云物联网平台支持AMQP队列告警配置，用户可以通过设置告警规则来监控AMQP队列消息的积压以及队列消费速度的情况，规则触发后立即把告警信息推送给用户，方便用户及时发现故障恢复业务。本文介绍如何配置AMQP队列的告警规则。
使用AMQP转发 AMQP转发 配置AMQP服务端 AMQP队列告警配置 AMQP客户端接入说明 Java SDK接入示例 Node.js SDK接入示例 C# SDK接入示例 Android SDK接入示例 Python SDK接入示例 GO SDK接入示例 父主题： 数据转发至第三方应用
使用MQTT转发 MQTT转发 配置MQTT服务端 MQTT客户端接入说明 Java Demo使用说明 Python Demo使用说明 GO Demo使用说明 Node.js Demo使用说明 C# Demo使用说明 父主题： 数据转发至第三方应用
相关API参考 创建规则动作 创建规则触发条件 修改规则触发条件 流转数据 创建AMQP队列 查询AMQP列表 查询单个AMQP队列 生成接入凭证 父主题： 使用AMQP转发
图12 新建属性上报流转规则-数据转发至FunctionGraph 单击“设置转发目标”页签，单击“添加”，设置转发目标，设置完成后单击“确定”按钮。
AMQP客户端接入说明 在调用创建规则触发条件、创建规则动作、修改规则触发条件配置并激活规则后，您需要参考本文将AMQP客户端接入物联网平台，成功接入后，在您的服务端运行AMQP客户端，即可接收订阅的消息。 协议版本说明 AMQP协议标准的详细介绍，请参见AMQP协议标准。
建立连接 在com.iot.mqtt.example.demo.MqttConstants中设置接入地址及鉴权参数的值： // IoT平台mqtt接入地址，替换成"连接配置说明中"的"MQTT接入域名。
build(); AmqpClient amqpClient = new AmqpClient(options); amqpClient.initialize(); 2、通过设置listener消费amqp消息。
amqpAccessKey = 'your AccessKey' # 接入凭证密钥 amqpAccessCode = 'your AccessCode' # 订阅队列名称 amqpQueueName = 'DefaultQueue' # 实例Id，同一Region购买多个标准版实例时需要填设置该参数
_reconnect_on_failure = False # 设置回调函数 self.
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
