检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
TDA的消息保序功能后,IoTDA会将同一个设备的消息推送到Kafka的同一个partition,从而实现平台与应用端的转发保序。 应用服务器消费Kafka数据时,同一个设备的消息会分发到同一个消费者,消费者可以按顺序消费设备依次上传上来的数据。 下行消息保序 在需要下行消息保序的场景,可以参考如下图的方案进行设计:
getenv("CLOUD_SDK_SK"); // ENDPOINT:请在控制台的"总览"界面的"平台接入地址"中查看“应用侧”的https接入地址。 String iotdaEndpoint = "<YOUR ENDPOINT>"; String
getenv("CLOUD_SDK_SK"); // ENDPOINT:请在控制台的"总览"界面的"平台接入地址"中查看“应用侧”的https接入地址。 String iotdaEndpoint = "<YOUR ENDPOINT>"; String
getenv("CLOUD_SDK_SK"); // ENDPOINT:请在控制台的"总览"界面的"平台接入地址"中查看“应用侧”的https接入地址。 String iotdaEndpoint = "<YOUR ENDPOINT>"; String
cn-north-4.myhuaweicloud.com 替换为自己的接入地址。 //域名获取方式:登录华为云IoTDA控制台左侧导航栏“总览”页签,在选择的实例基本信息中,单击“接入信息”。选择“设备接入”8883端口对应的接入地址。 IoTDevice device = new IoTDevice("ssl://xxx
表2 参数说明 参数名 参数说明 转发目标 选择“分布式消息服务(Kafka)” 区域 选择“分布式消息服务”区域。 对接地址 选择kafka服务的对接地址。 主题 填写接收推送消息的kafka topic。 SASL认证 若开启SASL认证,请填写您在购买Kafka实例中所选安
REGION_ID = "<YOUR REGION ID>"; // ENDPOINT:请在控制台的"总览"界面的"平台接入地址"中查看“应用侧”的https接入地址。 private static final String ENDPOINT = "<YOUR ENDPOINT>";
设备发放平台 消息接收方 设备 参数说明 表2 下发参数说明 参数 必选/可选 类型 描述 address 必选 String 对应设备接入实例的接入地址。 initConfig 必选 String 客户在创建设备,或者创建注册组时自定义的初始化Json字符串。 示例 设备先订阅Topic后
getenv("CLOUD_SDK_SK"); // ENDPOINT:请在控制台的"总览"界面的"平台接入地址"中查看“应用侧”的https接入地址。 String iotdaEndpoint = "<YOUR ENDPOINT>"; String
REGION_ID = "<YOUR REGION ID>"; // ENDPOINT:请在控制台的"总览"界面的"平台接入地址"中查看“应用侧”的https接入地址。 private static final String ENDPOINT = "<YOUR ENDPOINT>";
实现安全接入、设备管理、数据采集、命令下发等业务场景。 资源包名 描述 下载 应用侧开发 API Java Demo 物联网平台为应用服务器提供了应用侧API,能够让开发者快速验证API开放的能力,体验业务功能,熟悉业务流程。 API Java Demo 应用侧开发 Java SDK
账号以及密码以及自己在云端注册的设备ID和设备密钥,注意此设备仅支持2.4G频段的wifi。 (2)对接地址修改为管理控制台界面“总览”的“接入信息”设备接入MQTT协议地址。 (3)编译和烧录,分为IDE方式和命令行方式,这里不一一介绍。可以参考图1 对应链接。 (4)烧录后,
设备属性上报 用于设备按产品模型中定义的格式将属性数据上报给平台。 设备消息上报 用于设备将自定义数据上报给平台,平台将设备上报的消息转发给应用服务器或华为云其他云服务上进行存储和处理。 网关批量属性上报 用于网关设备将多个子设备的属性数据一次性上报给平台。 业务流程 设备接入前,需创建
端为例,介绍在设备迁移场景下,设备侧如何在只修改接入地址的情况下,实现设备建立MQTT连接、Topc订阅、消息发布等功能。 //接入华为云IoT的域名,在控制台的"总览"界面的"平台接入地址"中获取“设备侧”的MQTTS接入地址。 String server = "ssl://******
getenv("CLOUD_SDK_SK"); // ENDPOINT:请在控制台的"总览"界面的"平台接入地址"中查看“应用侧”的https接入地址。 String iotdaEndpoint = "<YOUR ENDPOINT>"; String
(e.g. server FQDN or YOUR name) []: 名称,如zhangsan。 Email Address []:邮箱地址,如1234567@163.com。 在openssl安装目录的bin文件夹下,获取生成的CA证书(rootCA.pem)。 上传验证证书
String 参数解释: 软固件包下载地址。 file_size 必选 Integer 参数解释: 软固件包文件大小。 file_name 必选 String 参数解释: 升级包文件名 access_token 可选 String 参数解释: 软固件包url下载地址的临时token。 expires
HJ212服务端端口:8890。 当前只有企业版支持,需手动部署。 对接流程 部署:HJ212泛协议插件部署在IoTDA平台内。 设备侧对接:通过IoTDA南向对接地址和插件指定的端口给终端设备提供服务。 应用侧对接:通过IoTDA的数据转发能力为应用提供对接服务。 父主题: HJ212协议接入
若需要发送邮件通知,选择“邮件”。 若需要发送短信通知,选择“短信”。 订阅终端 若协议为“邮件”,填写接收通知邮件的邮箱地址; 若协议为“短信”,输入接收短信通知的手机号码。 需要添加多个终端时,每个终端地址占1行,最多填写10行。 配置设备接入服务 在设备接入服务中创建产品模型、注册设备并设置设备联动
环境要求:Linux操作系统上,并安装好gcc(建议4.8及以上版本)。 库依赖:openssl库(MQTTS需要),paho库。 已在管理控制台获取设备接入地址。获取地址的操作步骤,请参考平台对接信息。 已在管理控制台创建产品和设备。创建产品和设备的具体操作细节,请参考创建产品、注册单个设备或批量注册设备。