检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
已购买设备接入服务的企业版实例或标准版实例。 已购买云数据库MySQL实例。 创建MySQL 登录华为云官方网站,访问云数据库 MySQL,购买实例。设备接入服务企业版实例支持通过内网连接MySQL,标准版实例仅支持通过公网连接MySQL。 在购买的MySQL实例中,根据流转数据格式设计数据库表,可以通过数据
dws联通测试 选择“作业管理>Flink作业”中创建作业。 图11 创建Flink作业 单击“编辑”, 在作业详情中编写SQL语句,详情请参考从Kafka读取数据写入到DWS。 图12 配置Flink作业 配置完Flink作业后,启动作业,完成Flink配置。 配置Astro大屏服务
设备返回响应等处理。 设备数据上报 设备登录成功后,收到设备的上行数据时,可调用SDK的reportProperties将解码后的数据上报到IoT平台。 代码样例参考: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
端侧部署边缘节点支持OPCUA,Modbus等协议,采集各种OT设备的运行数据,状态数据,以及环境监控数据,统一从边缘网关将数据上报至云端IoTDA。 云端IoTDA通过规则引擎将数据流转到DIS,并经过DLI-Flink处理后写入DWS,便于后续数据治理。还可流转到MRS进行大数据清洗和处理,便于后续进行AI分析和数据挖掘。
设备上报数据到物联网平台,物联网平台将数据以CSV格式存储到对象存储服务(OBS),数据可视化服务(DLV)从OBS文件读取数据并展现为多个维度的报表。 操作步骤如下: 在物联网平台创建产品和设备:创建MQTT协议产品、开发产品模型、并注册设备。 在物联网平台进行数据转发规则配置:创建数据转发规则,将数据以CSV格式持久化至OBS服务。
智慧路灯设备SDK与平台通信(Java) 概述 本文基于Java代码演示设备通过MQTTS/MQTT协议接入华为云物联网平台,通过平台接口实现南向“数据上报”、“命令下发”的功能,通过应用侧的示例代码接收北向服务端订阅的消息示例。以智慧路灯为例,设备将光照强度等信息上报到IoT平台,应用服务器再接收从平台推送来的设备数据。
"d4922d8a", "tag_keys" : [ "testTag" ] } 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 资源解绑标签,将标签testkey从设备id为d4922d8a的设备解绑。 1 2 3 4 5 6 7
接入组织:选择上链的身份组织。 背书组织:选择上链背书的组织,需要和链代码的背书策略保持一致才能正常上链。详情请参考这里。 链代码名称:填写上链所需要调用的链代码名称。链代码开发详情请参考这里。 链代码函数:填写上链需要调用的链代码函数。 参数配置: 下标位置:调用合约函数所需参数的下标位置。
设备创建成功后,需要保存设备ID和密钥(后续设备连接的时候需要用到)。 图6 设备-注册设备成功 导入代码样例 下载quickStart(C)样例。 将代码复制到linux运行环境中。代码文件层级如下图。 代码目录简述: src:源码目录 mqtt_c_demo:demo核心源码; util/string_util
ount MySql流转次数 IoTDA.MYSQL_FORWARDING MySql流转次数:iotda_mysql_forwarding_totalCount MySql流转成功次数:iotda_mysql_forwarding_successCount MySql流转失败次
"tag_value" : "testTagValue" } ] } 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 资源绑定标签,将标签绑定到设备id为d4922d8a的设备上。 1 2 3 4 5 6 7 8 9
nnel为ROMA_FORWARDING时,必填。(仅企业版支持) mysql_forwarding MysqlForwarding object 参数说明:转发MySQL消息内容。当channel为MYSQL_FORWARDING时,必填。 influxdb_forwarding
else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 OK 400 Bad Request 401 Unauthorized
nnel为ROMA_FORWARDING时,必填。(仅企业版支持) mysql_forwarding MysqlForwarding object 参数说明:转发MySQL消息内容。当channel为MYSQL_FORWARDING时,必填。 influxdb_forwarding
else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 OK 400 Bad Request 401 Unauthorized
转发给文档数据库服务(DDS),由DDS进行存储(华为云DDS完全兼容MongoDB协议),用户无需做额外的数据存储代码开发即可使用设备数据进行业务处理。本示例为将流转数据转发至文档数据库服务存储。 购买MongoDB实例 登录华为云官方网站,访问文档数据库服务DDS。 单击“进
iot-device-sdk-java:sdk代码 iot-device-demo:普通直连设备的demo代码 iot-gateway-demo:网关设备的demo代码 iot-bridge-sdk:网桥的sdk代码 iot-bridge-demo:网桥的demo代码,用来演示如何将tcp设备桥接到平台
iot-device-sdk-java:sdk代码 iot-device-demo:普通直连设备的demo代码 iot-gateway-demo:网关设备的demo代码 iot-bridge-sdk:网桥的sdk代码 iot-bridge-demo:网桥的demo代码,用来演示如何将tcp设备桥接到平台
nel为ROMA_FORWARDING时,必填。(仅企业版支持) mysql_forwarding 否 MysqlForwarding object 参数说明:转发MySQL消息内容。当channel为MYSQL_FORWARDING时,必填。 influxdb_forwarding
函数开发指南,本例不再介绍函数工作流函数实现的代码。 下载样例源码,解压缩并在Idea中导入工程。代码说明可参考:样例代码说明,其中用户自己的服务器地址通过函数环境变量NA_MOCK_SERVER_ADDRESS传入。 图1 样例代码说明 打包工程 使用Idea的Build Ar