检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
对于设备上报的数据,可以选择让平台将设备上报数据推送给应用服务器,由应用服务器进行保存;还可以选择让平台将设备上报数据转发给分布式消息服务(Kafka),由Kafka进行存储。 本示例为将所有设备上报的数据转发至Kafka存储。 购买Kafka实例 登录华为云官方网站,访问分布式消息服务。 单击
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
backoff_with_jitter) wait_time_s = round(wait_time_ms / 1000, 2) print("client will try to reconnect after " + str(wait_time_s) + " s")
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
异常数据转发目标 概述 在数据被转发至华为云其他服务或第三方应用时,若由于云服务权限不足、 华为云其他服务或第三方应用不可用等原因导致目标服务器不可达,物联网平台会停止消息的推送,并每三分钟进行一次通道恢复探测,若探测成功,通道将恢复正常使用。如果用户消息实时性要求高,为降低通道
台,成功接入后,在您的服务端运行AMQP客户端,即可接收订阅的消息。 协议版本说明 AMQP协议标准的详细介绍,请参见AMQP协议标准。 华为云物联网平台服务端订阅仅支持AMQP 1.0版的协议标准。 建链认证过程 AMQP客户端与物联网平台建立TCP连接,然后进行TLS握手校验。
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
连接参数。 const container = require('rhea'); //获取当前时间戳 var timestamp = Math.round(new Date()); //建立连接。 var connection = container.connect({
"default"; /** * IoTDA仅支持PLAIN */ @Builder.Default private String saslMechanisms = "PLAIN"; /** * true: SDK自动ACK(默认)
配置AMQP服务端 本文介绍如何在物联网平台设置和管理AMQP服务端订阅。 访问设备接入服务,单击“管理控制台”进入设备接入控制台。选择您的实例,单击实例卡片进入。 选择左侧导航栏的“规则 > 数据转发”,单击页面左侧的“创建规则”。 参考下表填写参数后,单击“创建规则”。 表1
数据订阅成功后,物联网平台推送到应用侧的数据格式样例请参考流转数据。 使用限制 描述 限制 支持的MQTT协议版本 3.1.1 与标准MQTT协议的区别 支持Qos 0 支持Topic自定义 支持共享订阅 不支持QoS1,QoS2 不支持will、retain msg 不支持客户端Publish
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
设备间消息通信示意图如下: 图1 设备间消息通信 如何进行设备订阅 设备订阅方式请参考设备间消息通信使用说明。 父主题: 数据转发至第三方应用
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
C# SDK接入示例 本文介绍使AMQPNetLite客户端接入华为云物联网平台,接收服务端订阅消息的示例。 开发环境要求 本示例使用的开发环境为.NETFramework V4.6及以上版本。 获取SDK 1、在工程目录上单击鼠标右键打开"管理NuGet程序包" 2、在"NuG