建立连接 在com.iot.mqtt.example.demo.MqttConstants中设置接入地址及鉴权参数的值： // IoT平台mqtt接入地址，替换成"连接配置说明中"的"MQTT接入 域名 。 String HOST = "${HOST}"; // 接入凭证，替换成"获取MQTT接入凭证"中获取的接入凭证。 String AC CES S_KEY = "${accessKey}"; String ACCESS_CODE = "${accessCode}"; // 实例ID，当同一region购买多个标准版实例该参数必填。 String INSTANCE_ID = "${instanceId}"; // 接收数据的Topic，替换成"创建规则动作"中的Topic。 String SUBSCRIBE_TOPIC = "${subscribeTopic}"; Demo中涉及的参数说明，请参考连接配置说明。 运行com.iot.mqtt.example.demo.MqttDemo样例代码，根据以下日志信息判断是否订阅成功。该示例忽略服务端证书校验，如需校验服务端证书可参考com.iot.mqtt.example.demo.MqttTlsDemo。 订阅成功。 图1 订阅成功 订阅失败。 用户名或密码错误。 图2 用户或密码错误 订阅的Topic不存在。 图3 订阅topic不存在

查询、修改、删除设备影子 查询设备影子 方法1：应用服务器调用查询设备影子数据接口。 方法2：登录管理控制台，选择您的实例，单击实例卡片进入。在左侧导航栏选择“设备”，单击具体的设备进入到设备的详情页面，在“设备影子”页签中，可以查看当前设备属性数据，包括“上报值”和“期望值”。 如果当前界面中看到“上报值”与“期望值”不一致，原因可能是设备未在线，暂时存储在设备影子中，待同步给设备，期望值会存在深色底纹。 如果当前界面看到的“上报值”与“期望值”一致，则表示设备最近一次上报的属性值与用户期望下发的属性值一致，期望值为白色底纹。 图1 设备影子-查看 修改设备影子 方法1：应用服务器调用配置设备影子预期数据接口。 方法2：登录管理控制台，选择您的实例，单击实例卡片进入。在左侧导航栏选择“设备-所有设备”，在设备列表中单击具体的设备进入到设备的详情页面，在“设备影子”页面，单击“属性配置”，在弹出窗口中输入服务属性对应的期望值，单击"确定"完成设备影子的修改。 图2 设备影子-属性配置 删除设备影子 用户删除设备影子，平台将会将设备影子中的所有数据（包含上报值和期望值）清空。 图3 删除设备影子

业务流程 修改设备属性值 修改desired区属性值，如果设备在线，则设备影子直接同步设备属性值到设备，否则等待设备上线或上报数据时，再同步设备属性值到设备。 用户通过控制台或应用服务器修改设备属性值。消息样例如下： PUT https://{Endpoint}/v5/iot/{project_id}/devices/{device_id}/shadow Content-Type: application/json X-Auth-Token: ******** Instance-Id: ******** { "shadow" : [ { "desired" : { "temperature" : "60" }, "service_id" : "WaterMeter", "version" : 1 } ] } 物联网平台 修改desired区属性值。 物联网平台返回响应消息。 物联网平台判断设备上线或上报数据。 物联网平台将设备属性同步到设备。消息样例如下： Topic: $oc/devices/{device_id}/sys/properties/set/request_id={request_id} 数据格式： { "object_device_id": "{object_device_id} ", "services": [ { "service_id": "Temperature", "properties": { "value": 57, "value2": 60 } }, { "service_id": "Battery", "properties": { "level": 80, "level2": 90 } } ] } 设备返回响应消息。设备影子desired区的属性值发送给设备后，需要设备回响应表示已收到请求。消息样例如下： Topic：$oc/devices/{device_id}/sys/properties/set/response/request_id={request_id} 数据格式： { "result_code": 0, "result_desc": "success" } 7.设备上报数据，当设备进行属性上报时，平台会存储设备最新上报的设备属性值。 设备上报属性时，物联网平台修改设备影子reported区属性值为设备上报的设备属性值。消息样例如下： Topic: $oc/devices/{device_id}/sys/properties/report 数据格式： { "services": [ { "service_id": "Temperature", "properties": { "value": 57, "value2": 60 }, "event_time": "20151212T121212Z" }, { "service_id": "Battery", "properties": { "level": 80, "level2": 90 }, "event_time": "20151212T121212Z" } ] } 设备主动删除设备影子的reported区 设备主动删除reported区service下的单个属性 设备上报属性时，将属性设置为null，平台会将该属性从设备影子reported区删除，消息样例如下： Topic: $oc/devices/{device_id}/sys/properties/report { "services": [ { "service_id": "Temperature", "properties": { "value": null, "value2": 60 }, "event_time": "20151212T121212Z" } ] } 设备主动删除影子reported区的service下的全部的属性 设备上报属性时，将service对应的properties设置为{}时，平台会将reported区该service模块下所有属性从设备影子reported区删除，消息样例如下: Topic: $oc/devices/{device_id}/sys/properties/report { "services": [ { "service_id": "Temperature", "properties": {}, "event_time": "20151212T121212Z" } ] } 查询设备属性值 设备影子保存的是设备最新的设备属性值，一旦设备属性值产生变化，设备会将设备属性值同步到设备影子。用户便可以及时获取查询结果，无需关注设备是否在线。 用户通过控制台或应用服务器查询设备属性值。消息样例如下： GET https://{Endpoint}/v5/iot/{project_id}/devices/{device_id}/shadow Content-Type: application/json X-Auth-Token: ******** Instance-Id: ******** 物联网平台返回desired属性值和report属性值，即期望值和上报值。消息样例如下： Status Code: 200 OK Content-Type: application/json { "device_id" : "********", "shadow" : [ { "desired" : { "properties" : { "temperature" : "60" }, "event_time" : "20151212T121212Z" }, "service_id" : "WaterMeter", "reported" : { "properties" : { "temperature" : "60" }, "event_time" : "20151212T121212Z" }, "version" : 1 } ] }

使用展示 打开界面如下，其中“INSTANCE ID”在同一区域购买多个IoTDA标准版实例时必填，详细参数说明，请参考AMQP客户端接入说明。 图7 Amqp连接配置 修改连接参数后连接成功界面如下： 图8 连接成功 获取流转数据成功界面如下： 图9 接收平台消息 网络连接失败界面如下： 图10 网络连接失败 接入信息（accessKey、accessCode、instanceId）错误界面如下： 图11 接入信息错误 队列不存在错误界面如下： 图12 队列不存在错误

代码示例 下载Amqp Demo样例。 运行Android Studio，单击“Open”，选择1中下载的样例。 图2 导入已有项目 完成代码导入。 图3 导入项目结构 (可选) 可以在res\values\strings.xml文件中提前配置Amqp连接参数，涉及的参数说明，请参考AMQP客户端接入说明。 图4 修改连接参数 AVD Manager配置，选择任意设备模型并且API Level 28的虚拟设备用于调试。 图5 配置AVD Manager 启动demo进行调试。 图6 启动demo

准备工作 安装android studio。访问android studio官网，选择合适系统的版本下载并安装。（本文以windows 64-bit系统Android Studio 4.1.1为例）。 图1 下载android studio 安装JDK（也可以使用IDE自带的JDK）。 访问Oracle官网，选择合适的JDK版本单击“Download”下载（本文以Windows x64 JDK8为例）。 下载完成后，运行安装文件，根据界面提示安装。

安全&数据保护 已获国家安全等保2.0四级认证，通过ISO27001/ISO27017/ ISO27018/ CS A STAR国际安全认证，数据隐私保护遵从中国《个人信息保护法》、欧盟GDPR数据隐私保护要求，建立端到端可信的安全体系。 设备安全：提供一机一密的设备安全认证机制，防止设备非法接入，支持设备的安全检测。 信息传输安全：基于TLS、DTLS、DTLS+加密协议，提供安全的传输通道。 平台安全：基于华为云整体进行威胁防御，充分利用华为 云安全 服务/组件和华为的安全研究部门，建立安全分析、设计、编码、测试、安全攻防等一整套安全防御体系。 数据保护：满足中国《个人信息保护法》、欧盟GDPR数据隐私保护要求。

设备接入IoTDA 特性 物联网平台支持终端设备直接接入，也可以通过工业网关或者家庭网关接入。物联网平台支持多网络接入、多协议接入、系列化Agent接入，解决设备接入复杂多样化和碎片化难题，也提供了丰富完备的设备管理能力，简化海量设备管理复杂性，提升管理效率。IoT设备接入云服务支持的特性详见下表。 表1 IoT设备接入云服务支持特性 特性分类 功能特性 功能说明 设备接入 原生协议接入 支持MQTT/CoAP/LwM2M/HTTPS协议接入。 系列化Device SDK 支持IoT Device SDK和IoT Device SDK Tiny，覆盖的语言包括C、Java等。详情请参考IoT Device SDK介绍。 行业协议接入 支持通过边缘网关接入Modbus、OPCUA，可通过行业协议插件方式支持行业协议接入。 设备接入鉴权 支持一机一密，X.509证书等鉴权方式。 泛协议接入 提供开源SDK和技术框架，需用户自行部署云网关完成TCP协议转换，或部署协议驱动到边缘网关。 设备管理 设备全生命周期管理 设备增删改查、设备状态管理、设备冻结/解冻、子设备管理等。 设备分组&标签 支持对设备进行分组或打标签，详细请参见群组与标签。 设备物模型定义 对设备进行物模型定义（Product Model），详细请参见产品模型。 设备影子 支持影子数据查询和影子设置，详细请参见设备影子。 OTA升级 支持对设备软固件进行升级，详细请参考OTA升级。 设备文件上传 支持设备上传文件到OBS，设备可向云端请求文件，详细请参见文件上传。 设备批量操作 支持对设备的批量操作，包括批量创建设备、批量软固件升级和批量命令下发。 消息通信 双向消息透传 支持设备消息HTTP/AMQP推送到应用服务器，支持应用侧向设备以异步方式下发消息。 物模型Topic通信 应用侧和设备侧基于物模型定义的属性、命令和事件进行解耦通信。 自定义Topic通信 支持用户自定义Topic进行双向消息通信。 数据解析转换 在线开发编解码插件，对设备数据进行数据解析和格式转换。 命令下发 支持以同步方式向在线设备下发命令，NB场景支持异步方式下发命令，详细请参见命令下发。 规则引擎 数据流转 支持数据流转到华为云Kafka/OBS/ GaussDB /DIS/DMS/ROMA等服务，详细请参见规则引擎。 规则联动 支持建立设备联动规则，实现联动控制，详细请参见规则引擎。 数据转发 支持平台将设备上报数据通过HTTP或AMQP转发至应用服务器。 监控运维 日志能力 控制台提供消息跟踪功能，对接LTS提供 日志分析 能力，对接 CTS 提供审计日志功能，详细请参见监控运维。 告警能力 系统类告警（如阈值类告警）和设备规则触发告警对接 AOM 提供告警通知管理能力，详细请参见告警管理。 指标监控 租户级业务指标（如设备状态、命令、订阅推送、消息流转等）对接AOM提供监控报表能力，详细请参见查看报表。 设备发放 设备启动引导 通过Bootstrap流程，引导物联网设备在初次上电时获得正确的目标物联网平台地址，继而完成设备与平台的建链过程。 多种发放策略 支持多种智能发放策略，比如关键字模糊匹配，使用证书进行发放，自定义发放策略等。 设备迁移能力 设备迁移能力，根据业务迁移需要，帮助企业重置设备发放信息，实现更改对端物联网平台的目的。

企业版规格 企业版规格如下表所示。 表4 企业版规格 实例规格 应用侧API调用频率配额限制（次/秒） 设备连接请求（次/秒） NB-IoT设备约束限制（次/秒） 规格名称 消息上下行TPS 可配置同时在线设备数 总调用次数 下发设备消息 下发设备命令 查询设备影子数据 查询设备 MQTT/HTTP连接请求 NB设备消息上报 NB设备命令下发 iotda.enterprise.1000tps.10wonlinedevice 1,000 10万 200 100 50 100 50 500 100 50 iotda.enterprise.1000tps.20wonlinedevice 1,000 20万 200 100 50 100 50 500 100 50 iotda.enterprise.1000tps.50wonlinedevice 1,000 50万 200 100 50 100 50 500 100 50 iotda.enterprise.1000tps.100wonlinedevice 1,000 100万 200 100 50 100 50 500 100 50 iotda.enterprise.1000tps.200wonlinedevice 1,000 200万 200 100 50 100 50 500 100 50 iotda.enterprise.1000tps.500wonlinedevice 1,000 500万 200 100 50 100 50 500 100 50 iotda.enterprise.2000tps.10wonlinedevice 2,000 10万 400 200 100 200 100 500 200 100 iotda.enterprise.2000tps.20wonlinedevice 2,000 20万 400 200 100 200 100 500 200 100 iotda.enterprise.2000tps.50wonlinedevice 2,000 50万 400 200 100 200 100 500 200 100 iotda.enterprise.2000tps.100wonlinedevice 2,000 100万 400 200 100 200 100 500 200 100 iotda.enterprise.2000tps.200wonlinedevice 2,000 200万 400 200 100 200 100 500 200 100 iotda.enterprise.2000tps.500wonlinedevice 2,000 500万 400 200 100 200 100 500 200 100 iotda.enterprise.5000tps.10wonlinedevice 5,000 10万 800 400 200 400 200 1000 500 200 iotda.enterprise.5000tps.20wonlinedevice 5,000 20万 800 400 200 400 200 1000 500 200 iotda.enterprise.5000tps.50wonlinedevice 5,000 50万 800 400 200 400 200 1000 500 200 iotda.enterprise.5000tps.100wonlinedevice 5,000 100万 800 400 200 400 200 1000 500 200 iotda.enterprise.5000tps.200wonlinedevice 5,000 200万 800 400 200 400 200 1000 500 200 iotda.enterprise.5000tps.500wonlinedevice 5,000 500万 800 400 200 400 200 1000 500 200 iotda.enterprise.10000tps.10wonlinedevice 10,000 10万 1600 800 400 800 400 1000 1000 400 iotda.enterprise.10000tps.20wonlinedevice 10,000 20万 1600 800 400 800 400 1000 1000 400 iotda.enterprise.10000tps.50wonlinedevice 10,000 50万 1600 800 400 800 400 1000 1000 400 iotda.enterprise.10000tps.100wonlinedevice 10,000 100万 1600 800 400 800 400 1000 1000 400 iotda.enterprise.10000tps.200wonlinedevice 10,000 200万 1600 800 400 800 400 1000 1000 400 iotda.enterprise.10000tps.500wonlinedevice 10,000 500万 1600 800 400 800 400 1000 1000 400 iotda.enterprise.20000tps.10wonlinedevice 20,000 10万 3200 1600 800 1600 800 2000 2000 800 iotda.enterprise.20000tps.20wonlinedevice 20,000 20万 3200 1600 800 1600 800 2000 2000 800 iotda.enterprise.20000tps.50wonlinedevice 20,000 50万 3200 1600 800 1600 800 2000 2000 800 iotda.enterprise.20000tps.100wonlinedevice 20,000 100万 3200 1600 800 1600 800 2000 2000 800 iotda.enterprise.20000tps.200wonlinedevice 20,000 200万 3200 1600 800 1600 800 2000 2000 800 iotda.enterprise.20000tps.500wonlinedevice 20,000 500万 3200 1600 800 1600 800 2000 2000 800 iotda.enterprise.20000tps.10wonlinedevice 50,000 10万 6000 3200 1600 3200 1600 3000 5000 1600 iotda.enterprise.20000tps.20wonlinedevice 50,000 20万 6000 3200 1600 3200 1600 3000 5000 1600 iotda.enterprise.20000tps.50wonlinedevice 50,000 50万 6000 3200 1600 3200 1600 3000 5000 1600 iotda.enterprise.20000tps.100wonlinedevice 50,000 100万 6000 3200 1600 3200 1600 3000 5000 1600 iotda.enterprise.20000tps.200wonlinedevice 50,000 200万 6000 3200 1600 3200 1600 3000 5000 1600 iotda.enterprise.20000tps.500wonlinedevice 50,000 500万 6000 3200 1600 3200 1600 3000 5000 1600 每秒钟服务端订阅推送和云服务产品数据流转消息条数的总和不超过设备消息上报并发上限，如有超过，需选购更高TPS的规格。 实例消息数超出上下行消息TPS规格后，超出的消息会被丢弃。 用于计算每秒设备上报消息数（TPS并发上限）的最大单消息大小为4KB，超过4KB的消息计算为新的一条或多条。 设备连接请求的最大并发能力是指系统全部资源独占用于建链处理时的能力，在有其他业务并行处理时（如消息上报）能力达不到最大值，但至少会保证20%的并发处理能力。 除上表所列的规格和配额限制外，其他企业版实例对于API的各项默认配额或限制请参考使用限制。 若上述规格或配额限制不能满足您的业务需求（比如您有海量NB-IoT场景诉求，需要更高的并发处理能力），请提交工单说明您的需求。

标准版规格 标准版实例规格=实例单元类型*单个实例购买的单元数。详细产品价格请参见价格计算器，选择您想要购买的配置，然后查看页面下方的“配置费用”。详细计费说明请参见计费说明。 表3 “标准版”规格 规格名称 实例单元类型 同时在线设备数 每日消息数上限 消息上下行TPS 单个实例可购买单元数 iotda.standard.s0 免费单元S0 1,000个 10,000条 10TPS 1个 iotda.standard.st 微频单元ST 10,000个*购买单元数量 400,000条*购买单元数量 10TPS*购买单元数量 1-200个 iotda.standard.s1 低频单元S1 10,000个*购买单元数量 4,000,000条*购买单元数量 200TPS*购买单元数量 1-200个 iotda.standard.s2 中频单元S2 10,000个*购买单元数量 40,000,000条*购买单元数量 1,000TPS*购买单元数量 1-200个 iotda.standard.s3 高频单元S3 10,000个*购买单元数量 150,000,000条*购买单元数量 3,000TPS*购买单元数量 1-200个 iotda.standard.s4 超高频单元S4 10,000个*购买单元数量 300,000,000条*购买单元数量 6,000TPS*购买单元数量 1-200个 支持可注册设备数为在线设备数的20倍，覆盖设备全生命周期。 单个实例的消息上下行TPS峰值最高到10万TPS。比如实例包含100个S3，但TPS峰值最高只能到10万TPS。 单个实例每秒最大建立请求连接数量为100*购买单元数量（最高3,000），同时不超过所购买实例规格的TPS数。 计算实例每日消息数上限和上下行消息TPS的消息包括请参见计费说明-计费项。 实例上下行消息TPS峰值为每秒设备上报到平台的消息和平台发送给设备的消息总和。纳入TPS峰值计算的最大单消息大小为4KB，超过4KB的消息计算为新的一条或多条。 实例消息数超出上下行消息TPS规格后，超出的消息会被丢弃。 除上表所列的实例规格和配额限制外，其他标准版实例对于API的各项默认配额或限制，请参考使用限制。 若上述规格或配额限制不能满足您的业务需求，请提交工单说明您的需求。

基础版、标准版和企业版的对比 设备接入服务 （IoTDA）提供基础版（2023年1月1日前）、标准版（标准实例）和企业版（专享实例）三种实例类型。开通设备接入服务后，默认开通标准版免费单元S0，按需付费使用，标准版更多规格和企业版需要您购买对应实例。详细差异请参考下表。 设备接入服务(IoTDA)计划于2023年1月1日起将原基础版升级为标准版免费单元，原基础版用户可继续使用基础版，新用户可直接使用标准版免费单元，支持平滑扩容至更高规格以及更多的服务组合能力。原基础版用户如需迁移至标准版可参考迁移指导。 表1 基础版、标准版与企业版实例差异 差异项 基础版（2023年1月1日前） 标准版 企业版 开通区域 华北-北京四 华北-北京四/华东-上海一/华南-广州/华南-广州-友好用户环境/中国-香港/亚太-新加坡/亚太-曼谷/非洲-约翰内斯堡 华北-北京四/华东-上海一/华南-广州 计费方式 按消息数使用量计费 按实例规格与使用时长计费 按实例规格与使用时长计费 计算隔离 多个租户共享统一的计算资源 实例隔离 完全独享 网络访问 提供统一的公网域名和IP对接 每个实例提供独立的公网接入域名，非独享设备连接层资源。 实例运行在租户独立的VPC中， 独立分配设备侧和应用侧对接的公网和私网IP，可按需放开公网或私网访问。 该实例独享设备连接层资源，使用独立服务器处理设备连接，进一步提高连接可靠性。 数据隔离 租户隔离，各个租户之间数据不共享 实例隔离，租户可购买多个实例，各个实例资源数据不共享 独享数据存储资源。 安全性 各租户统一的安全策略控制 实例级安全策略控制 可配置独立的安全策略和网络ACL规则，可自定义设备及应用服务器对接的协议端口，可仅开放VPC私网IP对接方式。 功能 基础的设备接入和设备管理功能 基础的设备接入和设备管理功能，及扩展功能 支持更多的服务组合能力 支持行业解决方案集成适配 标准版能力基础上，支持更多独立VPC部署特有的功能（如私网专线对接等）。 性能规格 多租户共享平台整体并发能力 平台整体性能的弹性能力受限于可用资源情况 单实例可包含100个单元，最大支持10W峰值并发 可根据业务模型（每日消息总数和忙时峰值），配置更适合的实例规格 单实例支持10W并发，资源完全独占，不受其他租户影响 峰值并发可24小时全忙时运行，性能更强大 适用场景 小型企业客户，设备并发性能较低 提供灵活可配置的实例规格，适用于各类企业客户场景 中大型企业客户场景， 提供完全独享的实例，支持更高的并发能力， 具备更高的安全性和隔离性。 设备接入的基础版、标准版和企业版，它们之间在功能上的异同点如下表所示。 表2 基础版、标准版与企业版实例功能差异 特性分类 功能描述 基础版 标准版 企业版 说明 设备接入 原生协议/行业协议接入 √ √ √ - 协议插件方式接入私有协议 x x √ 支持云端加载协议插件支持私有协议接入 边云协同接入子系统 x 仅高频单元支持 √ 如园区项目中仅标准版高频单元和企业版支持通过IoT Edge接入子系统 设备接入鉴权 √ √ √ - 设备管理 设备生命周期管理 √ √ √ - 设备物模型定义 √ √ √ - 设备影子 √ √ √ - OTA升级 √ √ √ - 消息通信 双向消息透传 √ √ √ - 物模型Topic通信 √ √ √ - 数据解析转换 √ √ √ - 规则引擎 数据流转 √ √ √ 设备上报数据流转到其他云服务 规则联动 √ √ √ 设备联动规则 SQL数据流转规则 x √ √ 支持对数据先通过类SQL语句进行预处理 HTTP/AMQP订阅推送 √ √ √ - MQTT推送消息队列 x √ √ - 云服务流转 DIS 数据接入服务 √ √ √ - OBS 对象存储服务 √ √ √ - LTS 云日志 服务 √ √ √ - Kafka分布式消息服务 √ √ √ - RocketMQ分布式消息服务 x √ √ - ROMA Connect应用与 数据集成平台 x x √ - FunctionGraph 函数工作流 服务 x √ √ - MRS Kafka流式集群 x x √ - MySQL数据库 x √ √ - InfluxDB 时序数据库 x √ √ - BCS 区块链服务 x x √ - MongoDB数据库 x x √ - 权限管理 子用户权限管理 √ √ √ 基于 IAM 的细粒度用户权限管理 分权分域 √ √ √ 基于资源空间的分权分域管理 公私网接入 公网接入 √ √ √ - 私网接入/专线对接 x x √ - 自定义接入端口 x x √ - IPV6接入 x √ √ 暂不支持NB-IoT设备，支持region为华北-北京四、华东-上海一、华南-广州。 性能规格 设备消息上报并发能力 单账号最大100TPS 单实例最大10万TPS 单实例最大10万TPS 可购买多个企业版实例，支持百万级并发 设备命令下发能力 单账号最大50TPS 单实例最大6000TPS 单实例最大6000TPS 有更高需求，请提交工单说明您的诉求

使用场景 公路隧道中的监控设备种类较多，数量较大，并且隧道内网络环境复杂，网络质量也不稳定。然而，在应急处理时对网络实时性要求较高，因此无法将应急设备间的联动完全依赖于云端规则处理，需要借助端侧规则引擎实现预案联动。在实施时，可以预先针对火灾、交通事故等不同情况制定相应的设备联动预案。监控人员可以根据隧道内发生的情况，一键启动设备预案，通过端侧规则引擎实现多种相关设备同步进行状态变化，从而降低对网络质量的依赖，提高整体设备联动效率。例如，当烟道温度过高时，可以联动排水阀控制器打开排水阀实现降温；当一氧化碳浓度过高时，可以联动covi设备控制风机来通风。

概述 在云端规则中，用户创建的规则的解析及执行均在云端完成，云平台需要判断条件是否满足并触发相应的设备联动操作。端侧规则是指用户在云平台创建的设备联动规则，可以下发到端侧设备，该设备上会运行端侧规则引擎，对云端下发的规则进行解析并执行。端侧规则可以在网络中断或设备无法与云端交互情况下，继续在端侧执行指定规则。端侧规则可以扩展用户应用场景，提升端侧设备运行的稳定性及执行效率等。例如：设置室内光照强度低于20时，打开灯控总开关，自动照明，实现不依赖网络设备的智能控制。 图1 端侧规则架构图 相关背景概念说明可参考基础概念。

创建MySQL 登录华为云官方网站，访问云数据库 MySQL，购买实例。设备接入服务企业版实例支持通过内网连接MySQL，标准版实例仅支持通过公网连接MySQL。 在购买的MySQ L实例 中，根据流转数据格式设计数据库表，可以通过数据过滤语句编辑流转数据。本示例使用设备属性上报通知的默认格式，将流转数据中的resource、event、notify_data、event_time分别转存至数据库表中的resource、event、content、event_time字段。 图1 创建数据库表样例

场景说明 将数据流转到influxDB，兼容InfluxDB生态的云原生时序数据库。提供高性能读写、高压缩率、冷热分层存储以及弹性扩容、监控告警等服务能力，可以实现大并发的时序数据读写，压缩存储和类SQL查询等功能，支持多维聚合计算和 数据可视化 分析能力。广泛应用于资源监控、业务监控分析、物联网设备实时监控、工业生产监控、生产质量评估和故障回溯等。提供了高吞吐量和并发性，可以通过快速的响应时间来支持大量的连接，非常适合要求苛刻的物联网应用。