华为云用户手册

R40配置 在R40上需要对传感器的参数进行配置： 风速变速器相关配置： R40上电后，在自己的电脑上连接King开头的wifi，连上后在浏览器中输入地址192.168.3.1进入R40的配置界面。 输入用户名（默认为admin）和密码（默认无密码）后，单击“登录”按钮。 单击上方菜单栏“RTU I/O”，选中“模拟量接入”，进入模拟输入配置界面。 在AIN1输入一行（因为风速变速器选择的是该口）中，选择“电流4~20mA”（风速变速器的输出为该值）。并且按照传感器推荐的将最小值设置为0，最大值设置为30，单位设置为m/s。 设置完毕后，单击“保存并应用”。 通过旋转风速变速器的扇叶，然后刷新当前的配置页，可以看到“当前值”那一栏中有数据，说明已经能采集到传感器的数据。 气象多要素百叶箱相关配置： R40上电后，在自己的电脑上连接King开头的wifi，连上后在浏览器中输入地址192.168.3.1进入R40的配置界面。 输入用户名（默认为admin）和密码（默认无密码）后，单击“登录”按钮。 单击上方菜单栏“应用”，选择“Modbus”主站，进入Modbus主站配置页面。 在下方的框中填写“noise”，单击“添加”按钮。添加完成后，单击“编辑”按钮（“删除”按钮旁的那一个），进入传感器的配置界面。 在配置界面，将别名设置为“噪声监测”，从机地址设置为“2”，寄存器类型设置为“16位数据”，功能码设置为“03”，寄存器起始地址设置为“0”，数据个数设置为“1”，映射地址分配设置为“手动”，映射起始地址设置为“20004”，从机接口设置为“RS485”。 设置完毕后，单击“保存”。然后单击左下角的“返回至概况”。然后单击“保存并应用”。 单击“noise”这一行的“查询”按钮，可以看到“数据值”，如果周围噪声发生改变，可以通过刷新按钮来查看值的变化。 从机地址、寄存器类型、功能码以及寄存器起始地址可以从气象多要素百叶箱的配置文件中获取到。 映射地址为R40的寄存器地址，建议改为手动，同时设置映射地址。因为该地址跟物模型中的属性是对应的，属性名称需要设置成“REG”+ 映射起始地址。这里设置20004是因为物模型中已经设置了REG20004的属性名。 从噪声查看页单击“返回至概况”，在Modbus设置界面下方的空白框处填写“lightIntensity”，单击“添加”按钮。添加完成后，单击“编辑”按钮（“删除”按钮旁的那一个），进入传感器的配置界面。 在配置界面，将别名设置为“光照强度”，从机地址设置为“5”，寄存器类型设置为“32位数据”，功能码设置为“03”，寄存器起始地址设置为“0”，数据个数设置为“1”，映射地址分配设置为“手动”，映射起始地址设置为“20130”，从机接口设置为“RS485”。 设置完毕后，单击“保存”。然后单击左下角的“返回至概况”。然后单击“保存并应用”。 单击“lightIntensity”这一行的“查询”按钮，可以看到“数据值”，如果周围光照强度发生改变，可以通过刷新按钮来查看值的变化。 从机地址、寄存器类型、功能码以及寄存器起始地址可以从气象多要素百叶箱的配置文件中获取到。 映射地址为R40的寄存器地址，建议改为手动，同时设置映射地址。因为该地址跟物模型中的属性是对应的，属性名称需要设置成“REG”+ 映射起始地址。这里设置20130是因为物模型中已经设置了REG20130的属性名。 从光照强度查看页单击“返回至概况”，在Modbus设置界面下方的空白框处填写“shidu”，单击“添加”按钮。添加完成后，单击“编辑”按钮（“删除”按钮旁的那一个），进入传感器的配置界面。 在配置界面，将别名设置为“湿度”，从机地址设置为“1”，寄存器类型设置为“16位数据”，功能码设置为“03”，寄存器起始地址设置为“500”，数据个数设置为“1”，映射地址分配设置为“手动”，映射起始地址设置为“20015”，从机接口设置为“RS485”。 设置完毕后，单击“保存”。然后单击左下角的“返回至概况”。然后单击“保存并应用”。 单击“shidu”这一行的“查询”按钮，可以看到“数据值”，如果周围光照强度发生改变，可以通过刷新按钮来查看值的变化。 从机地址、寄存器类型、功能码以及寄存器起始地址可以从气象多要素百叶箱的配置文件中获取到。 映射地址为R40的寄存器地址，建议改为手动，同时设置映射地址。因为该地址跟物模型中的属性是对应的，属性名称需要设置成“REG”+ 映射起始地址。这里设置20115是因为物模型中已经设置了REG20115的属性名。 从湿度强度查看页单击“返回至概况”，在Modbus设置界面下方的空白框处填写“wendu”，单击“添加”按钮。添加完成后，单击“编辑”按钮（“删除”按钮旁的那一个），进入传感器的配置界面。 在配置界面，将别名设置为“温度”，从机地址设置为“1”，寄存器类型设置为“16位数据”，功能码设置为“03”，寄存器起始地址设置为“501”，数据个数设置为“1”，映射地址分配设置为“手动”，映射起始地址设置为“20003”，从机接口设置为“RS485”。 设置完毕后，单击“保存”。然后单击左下角的“返回至概况”。然后单击“保存并应用”。 单击“shidu”这一行的“查询”按钮，可以看到“数据值”，如果周围光照强度发生改变，可以通过刷新按钮来查看值的变化。 从机地址、寄存器类型、功能码以及寄存器起始地址可以从气象多要素百叶箱的配置文件中获取到。 映射地址为R40的寄存器地址，建议改为手动，同时设置映射地址。因为该地址跟物模型中的属性是对应的，属性名称需要设置成“REG”+ 映射起始地址。这里设置20003是因为物模型中已经设置了REG20003的属性名。 R40上报到平台的配置： 在上方的菜单栏中选择“云平台”，选择“华为云”。“认证方式”选择“设备密钥”，设备ID和密钥在iot平台注册所得，服务ID填写“basicData”，发布周期填写60。 配置完后，单击“保存并应用”。设置完毕后，R40会自动连上华为云iot平台，并且每隔60s报一次数据。

场景说明 微型气象是不可预测的，基本上不能通过人工手段来分析其变化，因此必须运用新技术，对气象进行实时监测，以便采取相应的措施来避免或解决事故的发生。而常规气象环境数据采集容易造成数据损失、人力成本高、数据安全性差、可追踪性差等问题。为解决上述问题，可以通过网关将设备采集的数据上报到华为云IoT平台，实现对现场设备数据的实时监控，您可通过华为云IoT平台实时查看现场温度、湿度、光照、风速等环境数据，并对数据进行转储、分析等处理，同时也能通过IoT平台对设备进行控制。本文以金鸽的R40设备为例进行演示。

控制台操作概览 在真实设备连接之前，需要在 设备接入服务 控制台创建产品、定义产品模型和注册设备。 创建产品：在 物联网平台 上规定好某一款产品的协议类型、数据格式、厂商名称、设备类型。此处我们需要按照R40的特征，在控制台创建R40的产品。 定义产品模型：产品模型是用来描述设备能力的文件，通过JSON的格式定义了设备的基本属性、上报数据和下发命令的消息格式。定义产品模型，即在物联网平台构建一款设备的抽象模型，使平台理解该款设备支持的属性信息，例如风速、光照强度、温湿度、噪声等。 注册设备：将R40设备注册到物联网平台。

设备简介 R40（如图2）负责将传感器的数据收集上来，上报到华为云IoT平台，同时负责将华为云IoT平台下发的控制信息下发给传感器。其中演示的传感器设备有如下三种： 1. 风速变速器（如图3）将采集到的风速通过电流信号输出给R40； 2. 气象多要素百叶箱（如图4）将采集到的噪声、光照、温湿度信息通过RS485口（Modbus协议）输出给R40。 3. 报警器（如图5）通过R40的DO口接收从华为云IoT下发给的控制信息。

创建产品 某一类具有相同能力或特征的设备的集合称为一款产品。除了设备实体，产品还包含该类设备在物联网能力建设中产生的产品信息、产品模型（Profile）等资源。下面，我们按照R40的基本特征，在控制台上创建R40产品。 访问设备接入服务，单击“立即使用”进入设备接入控制台。选择您的实例，单击实例卡片进入。 选择左侧导航栏的“产品”，然后单击左侧的“创建产品”，创建一个基于MQTT协议的产品，参考下表填写参数后，单击“确定”，完成产品的创建。 基本信息 所属资源空间 选择您需要归属到的资源空间 产品名称 自定义，如“R40” 协议类型 选择“MQTT” 数据格式 选择“JSON” 设备类型选择 选择“自定义类型” 设备类型 EnvironmentalMonitoringDevice 产品创建成功后，单击“详情”按钮进入产品界面，进行后面操作。

硬件连接 将风速变速器的棕色线和黑色线分别接到外部电源的正极和负极，将蓝色线和绿色线分别接入到R40的AIN1口和AGND口（见下图）。 图6 风速变速器连接R40 将气象多要素百叶箱的棕色线和黑色线分别接到电源的正极和负极，将黄色线和蓝色线分别接入到R40的485A口和485B口（见下图）。 图7 气象多要素百叶箱连接R40 将报警器的红色线和黑色线分别接到电源正极和R40的DO2口，将电源的负极接入到R40的DO1口（见下图）。 图8 报警器连接R40

上传产品模型 产品模型是用来描述设备能力的文件，通过JSON的格式定义了设备的基本属性、上报数据和下发命令的消息格式。定义产品模型，即在物联网平台构建一款设备的抽象模型，使平台理解该款设备的功能。我们已提供开发好的产品模型，帮助您快速体验上云流程，如果您想体验产品模型的开发流程，可参考开发产品模型。 操作步骤： 在产品详情“基本信息”页面，单击“上传模型文件”。 在弹出的页面中，上传提供的产品模型（本示例的产品模型），然后单击“确定”。 图9 产品-上传模型文件

创建产品 登录管理控制台，单击左侧导航栏“产品”，单击页面左侧的“创建产品”。 根据页面提示填写参数，然后单击“确认”，完成产品的创建。 基本信息 所属资源空间 平台自动将新创建的产品归属在默认资源空间下。如需归属在其他资源空间下，下拉选择所属的资源空间。如无对应的资源空间，请先创建资源空间。 产品名称 为产品命名。产品名称在相同资源空间有唯一性。长度不超过64，只允许中文、字母、数字、以及_?'#().,&%@!-等字符的组合。 协议类型 选择MQTT。 数据格式 选择JSON。 所属行业 请根据实际情况选择。 设备类型 请根据实际情况选择。 高级配置 产品ID 定制ProductID，用于唯一标识一个产品。如果携带此参数，平台将产品ID设置为该参数值；如果不携带此参数，产品ID在物联网平台创建产品后由平台分配获得。 图3 创建产品-MQTT

开发产品模型 找到新增的产品，单击“查看”进入产品界面。 在产品详情“基本信息”页面，直接上传模型文件BearPi_Agriculture.zip。 图4 上传产品模型-MQTT 在产品列表中，单击对应的产品，进入产品详情页。您可以查看产品ID、产品名称、设备类型、数据格式、厂商名称、所属资源空间、协议类型等产品基本信息。 产品创建成功后，您可以单击“删除”删除不再使用的产品。删除产品后，该产品下的产品模型、编解码插件等资源将被清空，请谨慎操作。

获取AMQP接入凭证 若应用使用AMQP协议接入物联网平台进行数据流转，请先预置接入凭证。您可以通过调用生成接入凭证接口预置，也可以前往控制台页面进行预置，详细方法请参考如下操作： 选择“IoTDA实例 ”，进入您所选择的实例版本，单击“详情”进入实例详情页面。 单击“预置接入凭证”预置接入凭证密钥（accessCode）和接入凭证键值（accessKey）。 图2 实例管理-预置接入凭证 如果您之前预置过接入凭证，重新预置之后，之前的接入凭证密钥将不能再使用。

连接配置说明 AMQP客户端接入物联网平台的连接地址和连接认证参数说明如下： AMQP接入地址：amqps://${server.address}:5671。 连接字符串：amqps://${server.address}:5671?amqp.vhost=default&amqp.idleTimeout=8000&amqp.saslMechanisms=PLAIN 参数 说明 server.address AMQP服务端接入地址，请前往管理控制台-实例-总览页面-实例基本信息-接入信息-AMQPS接入地址处获取。 图1 总览-获取接入信息 amqp.vhost 当前amqp使用是默认的host，只支持default。 amqp.saslMechanisms 连接认证方式当前支持PLAIN-SASL。 amqp.idleTimeout 心跳时间单位为毫秒。如果超过心跳时间，Connection上没有任何帧通信，物联网平台将关闭连接。 端口：5671 客户端身份认证参数 username =“accessKey=${accessKey}|timestamp=${timestamp}|instanceId=${instanceId}” password =“${accessCode}” 参数 是否必须 说明 accessKey 是 接入凭证键值，当前单个键值最多能和32个客户端同时进行建链。 首次建链时候，请参考这里进行预置。 timestamp 是 表示当前时间，13位毫秒值时间戳。 服务端校验客户端的时间戳，且时间戳相差5分钟。 instanceId 否 实例Id，同一Region购买多个标准版实例时需要填设置该参数，实例Id参考这里这里获取。 accessCode 是 接入凭证密钥，长度不超过256个。 首次建链时候，请参考这里进行预置。若密钥丢失，可通过调用接入凭证接口进行重置，也可以参考这里进行重置。

建链认证过程 AMQP客户端与物联网平台建立TCP连接，然后进行TLS握手校验。 为了保障安全，接收方必须使用TLS加密，且使用TLS1.2版本，不支持非加密的TCP传输。客户端的时间不能与标准时间差5分钟及以上，否则接入不进来。 客户端请求建立连接。 客户端向物联网平台发起请求，建立Receiver Link（即平台向客户端推送数据的单向通道）。客户端建立Connection成功后，需在15秒内完成Receiver Link的建立，否则物联网平台会关闭连接。建立Receiver Link后，客户端成功接入物联网平台。 一个Connection上最多能够创建十个Receiver Link，不支持创建Sender Link，即只能由平台向客户端推送消息，客户端不能向平台发送消息。

使用说明 配置自定义 域名 。 选择左侧导航栏“总览”页签，在选择的实例基本信息中，单击“接入信息”。 图1 总览-获取接入信息 单击“接入信息”页面中的“自定义域名”列中的“详情”，进入配置自定义域名的界面。 图2 接入信息-自定义域名详情 在自定义域名界面，单击“添加域名”，根据参数说明配置自定义域名后单击“确定”。 图3 自定义域名-配置自定义域名 创建DNS记录；配置自定义域名后需要联系购买域名的厂商添加域名解析，以便自定义域名指向华为云IoTDA的接入点。您可以参考平台对接信息获取设备的接入点。

使用限制 当且仅当存在一个正常数据转发目标时，支持添加一个异常数据转发目标。 每个IoTDA实例最多支持创建5个异常数据转发目标。 支持异常数据转发目标的规则数据来源：设备、设备属性、设备消息、设备消息状态、设备状态、批量任务、产品和设备异步命令状态。 支持配置异常数据转发的正常转发目标类型： 数据接入服务 （DIS）、分布式消息服务（Kafka）、 对象存储服务 （OBS）、应用与 数据集成平台 （ROMA Connect）、第三方应用服务（HTTP推送）、分布式消息服务（RocketMQ）、 函数工作流 服务 （FunctionGraph）、云数据库（GeminiDB Influx）、云数据库 MySQL（RDS）、云数据库 PostgreSQL（RDS）、 MapReduce服务 （ MRS Kafka）、 区块链 服务（ BCS ）和文档数据库服务（DDS）。 支持作为异常转发目标的通道类型：AMQP推送消息队列。

异常转发数据格式 异常转发数据格式示例如下： { "request_id": "2131d048-234f-4564-9190-6030234678ad", "rule_id": "6519d048-3b7f-442b-9190-6030773879cc", "action_id": "f376ab9f-d060-4fbf-a383-3e52af98ae9d", "channel": "MYSQL_FORWARDING", "base64_original_payload": "ewogICAgInJlc291cmNlIjogImRldmljZS5tZXNzYWdlIiwKICAgICJldmVudCI6ICJyZXBvcnQiLAogICAgImV2ZW50X3RpbWUiOiAiMjAyNDA2MDFUMDAwMDAwWiIsCiAgICAiZXZlbnRfdGltZV9tcyI6ICIyMDI0LTA2LTAxVDAwOjAwOjAwLjAwMFoiLAogICAgInJlcXVlc3RfaWQiOiAiMjEzMWQwNDgtMjM0Zi00NTY0LTkxOTAtNjAzMDIzNDY3OGFkIiwKICAgICJub3RpZnlfZGF0YSI6IHsKICAgICAgICAiaGVhZGVyIjogewogICAgICAgICAgICAiYXBwX2lkIjogIjU4N2MyMzc3ZGRmYzQzMmI4OTMxZGNhYmNhODkyOTUyIiwKICAgICAgICAgICAgImRldmljZV9pZCI6ICIwMDAwMDAwMDAwMDAwMCIsCiAgICAgICAgICAgICJub2RlX2lkIjogIjIwMjAwNzExMTk5OTkxMDAwIiwKICAgICAgICAgICAgInByb2R1Y3RfaWQiOiAiMTIzNDU2Nzg5MDAiLAogICAgICAgICAgICAiZ2F0ZXdheV9pZCI6ICIyMDIwMDcxMTE5OTk5MTAwMCIKICAgICAgICB9LAogICAgICAgICJib2R5IjogewogICAgICAgICAgICAidG9waWMiOiAidGVzdFRvcGljIiwKICAgICAgICAgICAgImNvbnRlbnQiOiAiV2VsY29tZSB0byBIdWF3ZWkgQ2xvdWQgSW9UIERldmljZSBBY2Nlc3MoSW9UREEpIgogICAgICAgIH0KICAgIH0KfQo=", "error_message": "Push failed. Cause: Table 'xxx' doesn't exist. The iot platform will resume the push within 3 minutes after the channel is restored." } 表1 异常转发数据说明 参数 参数类型 描述 request_id String 推送异常的消息ID，由设备侧指定或平台生成，用于跟踪业务流程。 rule_id String 推送异常的规则触发条件ID，用于唯一标识一条规则触发条件，在创建规则时由物联网平台分配获得。 action_id String 推送异常的数据转发目标ID，用于唯一标识一个数据转发目标，在创建数据转发目标时由物联网平台分配获得。 channel String 推送异常的数据转发目标类型。 base64_original_payload String 经过Base64编码的原始流转数据。 error_message String 错误的描述和说明。 异常转发数据格式可能存在增加字段的情况，在使用的时候务必做好序列化兼容性。

概述 在数据被转发至华为云其他服务或第三方应用时，若由于云服务权限不足、 华为云其他服务或第三方应用不可用等原因导致目标服务器不可达，物联网平台会停止消息的推送，并每三分钟进行一次通道恢复探测，若探测成功，通道将恢复正常使用。如果用户消息实时性要求高，为降低通道故障对业务的影响，用户可通过配置异常数据转发目标来获取异常转发数据，以便继续进行业务处理和分析失败原因，从而降低因单一通道异常而对业务产生的影响。 图1 异常数据转发目标示例 在转发规则配置异常数据转发目标后，24小时内若正常数据转发目标不可达，数据将会被直接推送至异常数据转发目标。若超过24小时正常数据转发目标仍未恢复，物联网平台将暂停数据推送。

相关推荐 相关文档 相关产品 设备数据上报 使用HTTP/HTTPS转发 使用AMQP转发 查看运行日志（旧版） 消息通知 服务 SMN 数据接入服务DIS 分布式消息服务Kafka 对象存储服务OBS 应用与数据集成平台ROMA Connect 云日志 服务（LTS） 函数工作流FunctionGraph 分布式消息服务（RocketMQ） 云数据库 GeminiDB Influx MapReduce服务（MRS Kafka） 云数据库MySQL 云数据库PostgreSQL 区块链服务 B CS

概述 数据转发功能用于提供IoTDA与其他第三方以及华为云服务的连接通道，从而实现将设备数据平滑流转至消息中间件、存储、数据分析、业务应用。各转发方式在各规格的支持情况，详见产品规格说明中 基础版、标准版与企业版实例功能差异。当前物联网平台支持如下转发方式： 表1 数据转发概述 分类 转发目标 说明 操作指导 第三方服务 第三方应用服务（HTTP推送） 将数据转发至客户的HTTP服务器，客户可以在数据转发界面创建流转规则，并指定推送的URL，将订阅的数据源信息推送到指定URL的服务器。 使用限制：支持基础版、标准版、企业版。 使用HTTP/HTTPS转发 AMQP推送消息队列 客户可以通过数据转发界面，订阅指定的AMQP通道，将订阅的数据源信息推送到指定AMQP通道，用户可通过AMQP的客户端与IoT平台建立链接，接收数据。 使用限制：支持基础版、标准版、企业版。 使用AMQP转发 MQTT推送消息队列 客户可以通过数据转发界面，订阅指定的MQTT Topic，将订阅的数据源信息推送到指定MQTT Topic，用户可通过Mqtt的客户端与IoT平台建立链接，接收数据。 使用限制：支持标准版、企业版。 使用MQTT转发 设备间通信 物联网平台支持基于MQTT协议实现设备间的消息通信，客户可以通过数据转发界面，订阅指定的Topic，平台会将设备上报的消息推送到指定的Topic，其他设备可以通过订阅该Topic来接收不同设备的消息。 使用限制：支持标准版、企业版。仅支持消息上报。 设备间通信 数据分析 数据接入服务 DIS 将数据流转到华为云DIS云服务。目前DIS支持数据转存储至对象存储服务 OBS、MapReduce服务 MRS、 数据湖探索 DLI 、 数据仓库服务 DWS 、 表格存储服务 CloudTable 。具体DIS支持的转存储任务以实际购买的实例为准。 应用场景：数据接入服务主要解决云服务外的数据实时传输到云服务内的问题。 规格参考：通道规格理论1个分区1M/秒接入，2M/秒读取。 使用限制：支持基础版、标准版、企业版。 数据转发至DIS 分布式消息服务Kafka版 将数据流转到华为云DMS Kafka云服务，适用于构建实时数据管道、流式数据处理、第三方解耦、流量削峰去谷等场景，具有大规模、高可靠、高并发访问、可扩展且完全托管的特点。 应用场景：在日志收集、流式数据传输、在线/离线系统分析、实时监控等领域有广泛的应用。 规格参考：Kafka实例规格。 使用限制：支持基础版、标准版、企业版。 数据转发至Kafka存储 应用与数据集成平台ROMAConnect 将数据流转到华为云ROMA Connect，可以实现无缝联接应用、消息、数据、API、设备，帮助企业快速、简单的打通并管理遗留系统与云原生应用，ROMA Connect是一个全栈式的应用与数据集成平台，源自华为数字化转型集成实践，聚焦应用和数据连接，适配多种企业常见的使用场景。 规格参考：ROMA实例规格。 使用限制：支持企业版。 - 分布式消息服务RocketMQ版 将数据流转到华为云RocketMQ云服务，兼容开源RocketMQ客户端。提供顺序、延迟、定时、重投、死信、事务消息等功能。提供消息追踪、消息溯源、链路诊断、死信导出、监控告警等能力，帮助您全方面的了解服务状况，保证业务正常运行。 应用场景：适用于电商、金融等多样的业务场景。 规格参考：RocketMQ实例规格。 使用限制：支持标准版、企业版。 数据转发至RokcetMQ 云日志服务 LTS 将数据流转到华为云LTS云服务，实现一站式日志采集、秒级搜索、海量存储、结构化处理、转储和可视化图表等功能。 应用场景：适用于应用运维、网络日志可视化分析、等保合规和运营分析等应用场景。 规格参考：日志流规格。 使用限制：支持基础版、标准版、企业版。 查看运行日志 函数工作流 FunctionGraph 将数据流转到华为云FunctionGraph云服务，客户只需要在FunctionGraph中编写业务函数代码并设置运行的条件，无需配置和管理服务器等基础设施，函数以弹性、免运维、高可靠的方式运行。此外，按函数实际执行资源计费，不执行不产生费用。 使用限制：支持标准版、企业版。 数据转发转发至FunctionGraph函数工作流 MapReduce服务 MRS 将数据转发到华为云MRS Kafka云服务，它的Kafka集群是一个分布式的、分区的、多副本的消息发布-订阅系统，它提供了类似于JMS的特性，但在设计上完全不同，它具有消息持久化、高吞吐、分布式、多客户端支持、实时等特性，适用于离线和在线的消息消费，如常规的消息收集、网站活性跟踪、聚合统计系统运营数据（监控数据）、日志收集等大量数据的互联网服务的数据收集场景。 使用限制：支持企业版。 - 区块链服务 BCS 将数据转发到华为云BCS云服务，作为面向企业及开发者提供的区块链技术服务平台，可以帮助客户快速部署、管理、维护区块链网络，降低客户使用区块链的门槛，让客户可以更专注于自身业务的开发与创新，实现业务快速上链。 规格参考：BCS产品规格。 使用限制：支持企业版。 数据转发至BCS可信上链 数据存储 云数据库 GeminiDB Influx 将数据流转到华为云GeminiDB Influx，兼容InfluxDB生态的云原生时序数据库。提供高性能读写、高压缩率、冷热分层存储以及弹性扩容、监控告警等服务能力，可以实现大并发的时序数据读写，压缩存储和类SQL查询等功能，支持多维聚合计算和 数据可视化 分析能力。 应用场景：广泛应用于资源监控、业务监控分析、物联网设备实时监控、工业生产监控、生产质量评估和故障回溯等。提供了高吞吐量和并发性，可以通过快速的响应时间来支持大量的连接，非常适合要求苛刻的物联网应用。 规格参考：InfluxDB规格。 使用限制：支持标准版、企业版。 数据转发至GeminiDB Influx 云数据库 RDS for MySQL 将数据流转到华为云RDS MySQL，相比自建数据库，RDS价格便宜、 即开即用，便捷运维，支持弹性伸缩并具备实例管理、实例监控、备份恢复、日志管理、参数管理等功能，支持单机和主备部署。 应用场景：网站业务、移动应用、游戏业务、电商业务、金融业务以及企业应用等。 规格参考：Mysql性能规格。 使用限制：支持标准版、企业版。 数据转发至MySQL 对象存储服务 OBS 将数据流转至华为云OBS云服务，OBS为客户提供海量、安全、高可靠、低成本的数据存储能力，使用时无需考虑容量限制，并且提供多种存储类型供选择，满足客户各类业务场景诉求，OBS也支持对接实时计算CS云服务，实时分析数据流，分析结果对接到其他云服务或者第三方应用进行数据可视化等。 应用场景：适用于海量大数据存储分析的场景。 规格参考：OBS存储规格。 使用限制：支持基础版、标准版、企业版。 数据转发至OBS长期存储 文档数据库服务DDS功能 将数据流转至华为云文档数据库服务DDS，DDS完全兼容MongoDB协议，具备安全审计，多账号管理，时间点备份恢复能力，支持集群和副本集部署架构。10倍备份恢复能力，分钟级横向扩容，轻松承载海量数据的高并发写入。 应用场景：游戏业务，物联网业务，电商、考勤系统等有典型高并发场景，对数据库性能要求较高。 规格参考：DDS性能规格 使用限制：支持企业版。 数据转发至MongoDB存储 云数据库 RDS for PostgreSQL 将数据流转到华为云RDS for PostgreSQL，RDS for PostgreSQL提供安全可靠、易用稳定、管理便捷的云数据库服务，支持弹性伸缩并具备备份恢复、参数模板管理、插件管理、日志管理等功能，支持单机和主备部署。 应用场景：电商、游戏、金融、政企等核心数据库等。 规格参考：PostgreSQL性能规格。 使用限制：支持企业版。 数据转发至PostgreSQL存储 通过公网进行数据转发流量限制不超过1M/s，超过后消息会直接丢弃。如果要使用更大的流量进行数据转发，推荐使用企业版，企业版支持私网进行数据转发，无此限制。

软固件升级失败原因 物联网平台上报的失败原因： 失败原因 原因解释 处理建议 Device Abnormal is not online 设备异常未在线 请检查设备侧。 Task Conflict 任务冲突 请检查当前设备是否有软件升级、固件升级、日志收集或设备重启的任务正在进行。 Waiting for the device online timeout 等待设备上线超时 请检查设备侧。 Wait for the device to report upgrade result timeout 等待设备上报升级结果超时 请检查设备侧。 Waiting for report device firmware version timeout 等待上报设备固件版本超时 请检查设备侧。 Waiting for report cellId timeout 等待上报cellId超时 请检查设备侧。 Updating timeout and query device version for check timeout 等待升级结果超时，且等待设备版本信息超时 请检查设备侧。 Waiting for device downloaded package timeout 等待设备完成下载固件包超时 请检查设备侧。 Waiting for device start to update timeout 等待设备启动更新超时 请检查设备侧。 Waiting for device start download package timeout 等到设备开始下载固件包超时 请检查设备侧。 设备上报的失败原因： 失败原因 原因解释 处理建议 Not enough storage for the new firmware package 下载的固件包存储空间不足 请检查设备存储。 Out of memory during downloading process 下载过程中内存不足 请检查设备内存。 Connection lost during downloading process 下载过程中连接断开 请检查设备连接状态。 Integrity check failure for new downloaded package 下载的固件包完整性校验失败 请检查设备下载的固件包是否完整。 Unsupported package type 固件包类型不支持 请检查设备状态和厂商提供的固件包是否正确。 Invalid URI URI不可用 检查设备侧的固件包下载地址是否正确。 Firmware update failed 固件更新失败 请检查设备侧。

上传软固件包 创建批量设备软件、固件升级任务前需要上传软件升级包，平台支持两种方式上传软件、固件包： 应用服务器通过调用“创建OTA升级包”API接口，创建OTA升级包，详情请参考创建OTA升级包。 通过控制台，在软固件升级页面上传软件、固件升级包，详情请参考软固件包上传。 通过API接口创建的OTA升级包，只支持MQTT协议设备升级。 升级包为OBS对象时，无论OBS桶是否配置了CDN域名加速功能，下发的升级包链接都为OBS链接地址。

证书资源 当设备和应用需要对IoT平台进行校验时可使用以下证书。 此证书文件只适用于华为云物联网平台，且必须配合对应域名使用。 CA证书具有一个过期日期，在该日期后，这些证书将无法用于验证服务器的证书；请在 CA证书的过期日期前替换这些证书，以确保设备可以正常的连接到IoT平台。 表3 证书资源 证书包名称 region&版本 证书类型 证书格式 说明 下载 certificate 北京四基础版 设备侧证书 pem、jks、bks 用于设备校验平台的身份。该证书必须配合当前设备侧接入域名使用。 注：之前的老域名(iot-acc.cn-north-4.myhuaweicloud.com)必须要配合老证书使用。 证书文件 certificate 北京四、上海一和广州标准版 设备侧证书 pem、jks、bks 用于设备校验平台的身份。该证书必须配合当前设备侧接入域名使用。 证书文件 certificate（设备发放） 通用 设备侧证书 pem、jks、bks 用于设备校验平台（设备发放）的身份。该证书必须配合设备发放使用。 证书文件 certificate 中国-香港、亚太-新加坡、亚太-曼谷、亚太-雅加达、非洲-约翰内斯堡、拉美-圣地亚哥、拉美-圣保罗一、拉美-墨西哥城二、中东-利雅得 设备侧证书 pem、jks、bks 用于设备校验平台的身份。该证书必须配合当前设备侧接入域名使用。 证书文件 certificate 北京四、上海一、广州、中国-香港、亚太-新加坡、亚太-曼谷、亚太-雅加达、非洲-约翰内斯堡、拉美-圣地亚哥、拉美-圣保罗一、拉美-墨西哥城二、中东-利雅得标准版 应用侧证书 pem 用于https订阅推送场景，应用侧校验平台的身份。 证书文件 certificate 北京四、上海一、广州、中国-香港、亚太-新加坡、亚太-曼谷、亚太-雅加达、非洲-约翰内斯堡、拉美-圣地亚哥、拉美-圣保罗一、拉美-墨西哥城二、中东-利雅得标准版 应用侧证书 pem、jks、bks 应用接入：HTTPS/AMQPS/MQ TTS 平台CA证书。 证书文件

第三方协议 第三方协议由生态伙伴基于华为云IoT泛协议设备端SDK开发。需至云市场单独购买协议解析插件，加载到设备侧网关，再结合IoTDA共同使用。通过网关来完成协议转换，将第三方协议转成MQTT协议，从而实现泛协议接入华为物联网平台。原理请见：说明文档。 支持方式：IoTDA + 生态协议插件，协议解析插件需通过云市场购买。 表2 第三方协议 使用场景 协议 协议描述 云市场 消防 JB-3208 火灾报警控制器协议 是一种为防火保护系统设计的智能报警控制器。它采用8路独立控制，可通过网络连接到多台控制器，可同时控制多台控制器，以实现跨区域的报警控制、系统状态查询及系统自检等功能。 链接 GB26875消防监测系统协议 是一种城市消防远程监控系统通讯协议，可全天候远程实现火灾报警联动、消防设施状态监测。 链接 报警主机协议 用于报警监控防火设备。可实现实时监控报警主机的状态信息、报警信息，并提供操作相关设备。可快速接入报警主机，将主机下各类传感器的信息及时传输上报。 链接 城市建设 智慧灯杆(路灯)协议 是一种智慧灯杆(路灯)协议插件，可以提供智能灯杆屏：远程管理，多屏同步，自动亮度和定时亮度，天气信息显示，远程断电，集群管理，AI智能审核等能力。 链接 管理 会议室管理系统协议 是一种可扩展的音视频解决方案，用于视频会议，可以有效提高员工参与度，帮助客户实现更佳的会议效果。 链接 DCIM能耗管理系统标准协议 是一种用于数据中心基础设施管理系统的协议，适用于微/小型数据中心、中大型数据中心、室外预制化数据中心。 链接 SNMP标准协议 SNMP是专门设计用于在 IP 网络管理网络节点（服务器、工作站、路由器、交换机及HUBS等）的一种标准协议，它是一种应用层协议。该协议可以使网络管理员能够管理网络效能，发现并解决网络问题以及规划网络增长。 链接 门禁 门禁协议 适用于小区入口门禁。采用人脸门禁系统，利用相关数据实现数字化安全管理，具备人员防夹、防尾随功能。 链接 AI门禁协议 用于自助闸机，可以实现现场采集信息与本地信息库进行黑/白名单的身份查验的功能，具有高安全性、高稳定性、高效率等特点。 链接 人脸门禁协议 用于门禁考勤，是一款可脱机或联网的人脸门禁考勤产品，支持刷卡四种验证方式，支持TCP/IP、U盘两种通信方式。 链接 环境监测 环境监测协议 可用于环境监测，监测设备是否出现故障，可以实现实时、远程、自动监测颗粒物浓度以及现场数据通过网络传输。 链接 环境监测与智慧路灯协议 这是一个用于对接环境监测以及智慧路灯系统的协议插件，插件中对接了智慧路灯的包括了智能照明、环境监测、视频监控、LED屏幕控制、广播任务发布等。实现了智能照明、绿色能源、智能安防、互通互联。 链接 视频监控 IVS协议 IVS监控是一款智能视频监控系统，可用于安防、交通、公共安全等领域。它具有高清图像、智能分析、实时响应等特点，能够帮助用户快速、准确地捕捉、分析现场信息。 链接 云平台协议 为用户提供视频监控服务的云端平台。它支持多种类型的视频监控设备，包括摄像机、网络摄像机、枪机、半球机等，可以通过云端平台进行远程监控和管理。 链接 DVR摄像头协议 用于实现图像的多画面显示，一般用于监看多个来自摄像头的画面录像功能。该插件主要完成视频信号的数字化和存储，通过矩阵切换模拟视频上电视墙显示，可以达到很好的图像效果。 链接 停车场 智慧停车场协议 为停车场提供围绕智慧停车业务的智能硬件、软件及云服务、智慧停车运营、城市级停车，实现智慧停车领域的全生态覆盖。 链接 充电桩协议 是一种充电桩协议插件，可以用于解决停车场景和充电场景的车场及车主需求，同时为管理方提供可持续性增益的运营办法。 链接 宣传 公共广播系统协议 是一种公共广播协议插件，可以用于帮助用户实现专业的广播播出和营销活动。通过移动网络或宽带网络，将节目、音乐、图片、视频等内容以公共广播的方式发送到指定的客户机。 链接 智慧云屏协议 用于商场屏幕投屏。该协议采用了云端管理的方式，使得用户可以随时随地更新显示内容，能够实时展示信息，并支持互动，提高显示效率。 链接 其他 科技汽车在线平台协议 用于汽车在线平台24小时实时定位。在使用汽车在线定位平台查看车辆的时候，平台上显示是实时定位信息，可用于个人及单位查找车辆。 链接 大屏协议 适用于多种终端设备与会议一体机智能互联可用于多场景进行如：智慧城市 云+端，行业指挥中心，新商业显示，智慧会议显示终端等。 链接

设备接入协议 华为云物联网平台支持多种接入方式和接入协议，满足各类设备和接入场景要求。请根据设备类型，选择合适方式接入到平台。 表1 协议清单 类型 子类型 协议编码 版本 适用场景 指导链接 通用协议 直连云端 MQTT/MQTTS 5.0 3.1.1 3.1 协议描述：MQTT是基于TCP/IP协议的一种轻量级的发布、订阅信息传输协议，特点报文紧凑、轻量可靠、支持QoS等。 应用场景：为物联网行业推荐协议之一，广泛应用于智能硬件、车联网、能源、电力等场景。 支持方式：IoTDA原生支持。 使用指导 CoAP - 协议描述：CoAP（Constrained Application Protocol）是一种在物联网世界的类web协议，使用了请求/响应交互模型。协议设计精炼， 采用 UDP 协议进行数据传输，适用在资源受限的低功耗设备上，尤其是NB-IoT的设备使用。 应用场景：在水表、电表等资源受限的低功耗设备上应用广泛。 支持方式：IoTDA原生支持。 使用指导 LwM2M 1.1 协议描述：LwM2M是建立在COAP上层的应用层协议。 应用场景：在水表、电表等资源受限的低功耗设备上应用广泛。 支持方式：IoTDA原生支持。 HTTPS 1.0 1.1 协议描述：HTTP协议超文本传输协议，基于请求/响应模型进行数据传输。 应用场景：适用于对设备硬件和网络带宽充裕的场景。 支持方式：IoTDA原生支持。 使用指导 网关接入 Modbus - 协议描述：Modbus协议是一项应用层报文传输协议，包括ASCII、RTU、TCP三种报文类型。通过此协议，控制器相互之间、控制器经由网络（例如以太网）和其它设备之间可以通信。 应用场景：在工业领域应用广泛。 支持方式：IoTEdge+IoTDA。 - OPC-UA - 协议描述：全称为OPC Unified Architecture（OPC统一架构），是一项开源的、独立于平台的标准协议；通过此协议，使用不同系统的设备可以通过网络在客户端和服务器之间发送消息进行通信。 应用场景：适用于现场设备，控制系统，制造执行系统和企业资源规划系统等应用领域的制造软件。 支持方式：IoTEdge+IoTDA。 使用指导 OPC-DA - 协议描述：OPC-DA对比OPC-UA, OPC-UA更适用于远程访问，OPC-DA适用于单系统数据访问。OPC-DA为实时数据访问规范,定义了包括数据值，更新时间与数据品质信息的相关标准。 应用场景：适用于多个供应商设备和控制应用程序之间实现数据交换。 支持方式：IoTEdge+IoTDA。 - Onvif - 协议描述：Onvif协议是安防监控设备的通用协议。涵盖了设备发现、设备配置、事件、PTZ控制、视频分析和实时流媒体直播功能，以及搜索，回放和录像录音管理功能。 应用场景：安防监控，用于录像机和摄像机。 支持方式：IoTEdge+IoTDA。 使用指导 GB28181 2016版 协议描述：国家标准GB/T 28181—2016《公共安全视频监控联网系统信息传输、交换、控制技术要求》,是视频监控领域的国家标准。 应用场景：视频联网传输和设备控制。 支持方式：IoTEdge+IoTDA。 - LoRa - 协议描述：LoRa是基于Semtech公司开发的一种低功耗局域网无线标准，解决了在同样的功耗条件下比其他无线方式传播的距离更远的技术问题，实现了低功耗和远距离的统一。 应用场景：主要在智慧城市、智慧建筑、智能家居、智能农业、无线工业等各个领域。 支持方式：IoTDA+协议转换网关（网关请前往云市场购买）。 云市场链接 行业协议 交通 JT/T 808 - 协议描述：《道路运输车辆卫星定位系统终端通信协议及数据格式》，主要用于“两客一危”车辆。 应用场景：交通行业应用。 支持方式：IoTDA原生支持，需要加载协议镜像，详情见使用指导。 使用指导- 水务 SL651 - 协议描述：《水文监测数据通信规约》，水文监测等设备需要遵循该规范。 应用场景：水文监测。 支持方式：IoTDA原生支持，需要加载协议镜像，详情见使用指导。 使用指导- 环境 HJ212 - 协议描述：《污染物在线监控（监测）系统数据传输标准》环保行业中使用的数据传输标准协议。 应用场景：环保行业。 支持方式：IoTDA原生支持，需要加载协议镜像，详情见使用指导。 使用指导- 电力 IEC104 - 全称为Telecontrol equipment and systems - Part 5-104, 是一种电力规约协议，是电力行业的国际标准。 应用场景：电力、城市轨道交通。 支持方式：IoTDA+生态协议插件 （插件请前往云市场购买）。 云市场链接 GB3761 - 协议描述：是一种国标电表协议插件，采用新型的数据采集技术，将电能表的实时工况数据转换成电信号，提供给计量系统，并能进行电能的实时记录、统计、抄表和结算等。 应用场景：电表。 支持方式：IoTDA+生态协议插件 （插件请前往云市场购买）。 云市场链接 其他协议 - TCP私有协议 - 厂商内部发展和采用的标准。私有协议具有灵活性，它往往会在某个公司或者组织内部使用，按需定制，升级方便，灵活性好。具体实现需要客户手动部署。 使用指导 第三方协议 - 适用于具体的场景。第三方协议由生态伙伴基于华为云IoT泛协议SDK开发，需至云市场单独购买协议解析插件，结合IoTDA共同使用。 表2 第三方协议

创建PostgreSQL数据库表 登录华为云官方网站，访问云数据库 PostgreSQL，进入云数据库PostgreSQ L实例 。 设备接入服务企业版实例支持通过内网连接PostgreSQL，支持通过公网连接PostgreSQL。 在PostgreSQL实例中，根据流转数据格式设计创建数据库表，具体操作指导可以参见通过数据管理服务DAS连接RDS for PostgreSQL实例。 图1 创建数据库表样例 访问设备接入服务，可以通过数据过滤语句编辑流转数据。本示例使用设备属性上报通知，将流转数据中的resource、event、device_id、service_id、properties、event_time分别转存至数据库表中的resource、event、device_id、service_id、properties、event_time字段。

验证操作 触发规则数据来源的事件，比如设备属性上报。 您可以使用配置设备接入服务时注册的真实设备接入平台，上报任意数据。 您也可以使用模拟器模拟设备上报数据，操作方法请参考在线开发MQTT协议的智慧路灯。 您也可以使用规则引擎提供的连通性测试，测试上报数据，本示例通过连通性测试进行验证。 在连通性测试对话框的测试数据页签下，输入用于转发的测试数据，或单击右上角“模拟输入模板”，使用模板数据，然后单击“连通性测试”。 图5 转发目标-连通性测试结果 进入PostgreSQL管理控制台，登录PostgreSQL数据库，打开目标表格，可以查看到表格目标字段转存的数据。 图6 查询数据上报信息

响应示例 状态码：200 请求成功 { "cluster_id" : "fac59513-6c18-4266-bc81-5d412dfc1925", "job_id" : "fac59513-6c18-4266-bc81-5d412dfc1925", "name" : "eventRoute-ifpcv5u4", "description" : "", "scene_type" : "DISASTER_BACKUP", "source_type" : "KAFKA", "source_config" : null, "sink_type" : "KAFKA", "sink_config" : null, "advance_config" : null, "status" : "CREATING", "err_code" : null, "err_message" : null, "created_time" : "2024-05-16T11:46:07Z", "updated_time" : "2024-05-16T11:46:07Z", "vpc_id" : "199f632d-34e7-4915-b4d8-1bc4e2824867", "subnet_id" : "0d1799e1-116e-4551-92dc-02dd8a860072", "log_group_id" : "3cfe3347-43b9-4aa4-b62e-xxxxxxxxxxx", "log_stream_id" : "1a5b9d49-3003-49d3-93af-xxxxxxxxxxx" }

响应参数 状态码：200 表3 响应Header参数 参数 参数类型 描述 X-Request-Id String 请求ID 表4 响应Body参数 参数 参数类型 描述 cluster_id String 专业版事件流集群ID job_id String 专业版事件流作业ID name String 作业名称。约束：作业名称由大小英文字母、数字、点、中划线和下划线组成，必须以大小英文字母或数字开头，最多128个字符。 description String 作业描述，约束：作业描述不能超过256位。 scene_type String 场景类型 source_type String 源端类型 sink_type String 目标端类型 subnet_id String 子网ID vpc_id String 虚拟私有云ID source_config EventRouterJobSource object 专业版事件流作业源端配置 sink_config EventRouterJobSink object 专业版事件流作业目标端配置 advance_config EventRouterAdvanceConfig object 专业版事件流作业高级配置 status String 作业状态 err_code String 错误码 err_message String 错误原因 created_time String 创建UTC时间 updated_time String 更新UTC时间 sink_status String 目标端连通性状态 sink_status_info String 目标端连通性状态信息 source_status String 源端连通性状态 source_status_info String 源端连通性状态信息 log_group_id String 用户侧保存事件流作业日志的日志组ID log_stream_id String 用户侧保存事件流作业日志的日志流ID 表5 EventRouterJobSource 参数 参数类型 描述 source_kafka KafkaParameters object kafka配置 source_rocketmq RocketmqParameters object rocketmq配置 source_dcs DcsParameters object dcs配置 表6 EventRouterJobSink 参数 参数类型 描述 sink_kafka KafkaParameters object kafka配置 sink_rocketmq RocketmqParameters object rocketmq配置 sink_dcs DcsParameters object dcs配置 表7 KafkaParameters 参数 参数类型 描述 config_type String 实例类型 CLOUD：云服务DMS kafka实例 region String 区域ID project_id String 资源空间ID instance_id String kafka实例ID，配置类型选择CLOUD时必填 cluster_alias String kafka集群别名 address String kafka地址 authenticate_mode String kafka认证方式 sasl_mechanism String SASL认证机制 user_name String 用户名，开启SASL_SSL时必填 password String 用户密码，开启SASL_SSL时必填 表8 RocketmqParameters 参数 参数类型 描述 config_type String 实例类型。 CLOUD：云服务DMS Rocketmq实例 region String 区域id project_id String 资源空间ID instance_id String rocketmq实例ID，配置类型选择CLOUD时必填 cluster_alias String rocketmq集群别名 address String rocketmq地址 ssl_open String rocketmq SSL开关 true: 开启 false: 关闭 acl_open Boolean rocketmq ACL开关 true: 开启 false: 关闭 user_name String 用户名，开启ACL时必填 password String 用户密码，开启ACL时必填 表9 DcsParameters 参数 参数类型 描述 config_type String 实例类型 CLOUD：云服务DCS实例 region String 区域id project_id String 资源空间ID instance_id String dcs实例ID，配置类型选择CLOUD时必填 address String dcs地址 password String 用户密码 表10 EventRouterAdvanceConfig 参数 参数类型 描述 kafka2kafka Kafka2KafkaAdvanceConfig object kafka同步自定义配置 rocketmq2rocketmq Rocketmq2RocketmqAdvanceConfig object rocketmq同步自定义配置 dcs2dcs Dcs2DcsAdvanceConfig object dcs同步自定义配置 表11 Kafka2KafkaAdvanceConfig 参数 参数类型 描述 topics String 要同步的topic名称，精确匹配，用","间隔，与topic_regex参数二选一 topic_regex String 要同步的topic正则表达式，与topics参数二选一 replica_cnt Integer 副本数，不能大于broker数量 seek_to String 数据同步点 compress_alg String 压缩算法 none：不使用压缩算法 gzip：gzip压缩算法 snappy：snappy压缩算法 lz4：lz4压缩算法 zstd：zstd压缩算法 is_sync_progress Boolean 是否同步消费进度 true：同步 false：不同步 is_add_header Boolean 是否添加来源Header rename_topic Boolean 是否重命名Topic topic_mappings Array of KafkaTopicMapping objects topic映射 表12 KafkaTopicMapping 参数 参数类型 描述 source_topic String 源主题 sink_topic String 目标主题 表13 Rocketmq2RocketmqAdvanceConfig 参数 参数类型 描述 topics String 要同步的topic名称，精确匹配，用","间隔，与topic_regex参数二选一 topic_regex String 要同步的topic正则表达式，与topics参数二选一 is_sync_progress Boolean 是否同步消费进度 seek_to String 数据同步点 最早（first），最新（last），自定义时间戳（long类型） compress_alg String 压缩算法 none：不使用压缩算法 gzip：gzip压缩算法 lz4：lz4压缩算法 zstd：zstd压缩算法 表14 Dcs2DcsAdvanceConfig 参数 参数类型 描述 synchronize_type String 同步类型 默认全量加增量 connect_retry_time String 无法连接后重试时间，默认60秒 other_retry_time String 出现其他问题后的重试时间，默认60秒 use_rate_limit Boolean 是否限制增量同步速率，默认5MS/s true：限制 false：不限制 rate_limit String 限制增量同步速率，默认5MB/s use_salve_node Boolean 是否使用Slave节点 true：使用从节点同步数据 false：不使用从节点同步数据，即使用主节点

响应示例 状态码：200 请求成功 { "size" : 1, "total" : 1, "items" : [ { "cluster_id" : "fac59513-6c18-4266-bc81-5d412dfc1925", "job_id" : "fac59513-6c18-4266-bc81-5d412dfc1925", "name" : "eventRoute-ifpcv5u4", "description" : null, "scene_type" : "DISASTER_BACKUP", "source_type" : "KAFKA", "source_config" : null, "sink_type" : "KAFKA", "sink_config" : null, "advance_config" : null, "status" : "NO_CONFIGURATION", "err_code" : null, "err_message" : null, "created_time" : "2024-05-16T11:46:07Z", "updated_time" : "2024-05-16T11:46:07Z", "vpc_id" : "199f632d-34e7-4915-b4d8-1bc4e2824867", "subnet_id" : "0d1799e1-116e-4551-92dc-02dd8a860072" } ] }

响应参数 状态码：200 表4 响应Header参数 参数 参数类型 描述 X-Request-Id String 请求ID 表5 响应Body参数 参数 参数类型 描述 total Integer 总数 size Integer 本页数量 items Array of EventRouterJobInfo objects 对象列表 表6 EventRouterJobInfo 参数 参数类型 描述 cluster_id String 专业版事件流集群ID job_id String 专业版事件流作业ID name String 作业名称。约束：作业名称由大小英文字母、数字、点、中划线和下划线组成，必须以大小英文字母或数字开头，最多128个字符。 description String 作业描述，约束：作业描述不能超过256位。 scene_type String 场景类型 source_type String 源端类型 sink_type String 目标端类型 subnet_id String 子网ID vpc_id String 虚拟私有云ID source_config EventRouterJobSource object 专业版事件流作业源端配置 sink_config EventRouterJobSink object 专业版事件流作业目标端配置 advance_config EventRouterAdvanceConfig object 专业版事件流作业高级配置 status String 作业状态 err_code String 错误码 err_message String 错误原因 created_time String 创建UTC时间 updated_time String 更新UTC时间 sink_status String 目标端连通性状态 sink_status_info String 目标端连通性状态信息 source_status String 源端连通性状态 source_status_info String 源端连通性状态信息 log_group_id String 用户侧保存事件流作业日志的日志组ID log_stream_id String 用户侧保存事件流作业日志的日志流ID 表7 EventRouterJobSource 参数 参数类型 描述 source_kafka KafkaParameters object kafka配置 source_rocketmq RocketmqParameters object rocketmq配置 source_dcs DcsParameters object dcs配置 表8 EventRouterJobSink 参数 参数类型 描述 sink_kafka KafkaParameters object kafka配置 sink_rocketmq RocketmqParameters object rocketmq配置 sink_dcs DcsParameters object dcs配置 表9 KafkaParameters 参数 参数类型 描述 config_type String 实例类型 CLOUD：云服务DMS kafka实例 region String 区域ID project_id String 资源空间ID instance_id String kafka实例ID，配置类型选择CLOUD时必填 cluster_alias String kafka集群别名 address String kafka地址 authenticate_mode String kafka认证方式 sasl_mechanism String SASL认证机制 user_name String 用户名，开启SASL_SSL时必填 password String 用户密码，开启SASL_SSL时必填 表10 RocketmqParameters 参数 参数类型 描述 config_type String 实例类型。 CLOUD：云服务DMS Rocketmq实例 region String 区域id project_id String 资源空间ID instance_id String rocketmq实例ID，配置类型选择CLOUD时必填 cluster_alias String rocketmq集群别名 address String rocketmq地址 ssl_open String rocketmq SSL开关 true: 开启 false: 关闭 acl_open Boolean rocketmq ACL开关 true: 开启 false: 关闭 user_name String 用户名，开启ACL时必填 password String 用户密码，开启ACL时必填 表11 DcsParameters 参数 参数类型 描述 config_type String 实例类型 CLOUD：云服务DCS实例 region String 区域id project_id String 资源空间ID instance_id String dcs实例ID，配置类型选择CLOUD时必填 address String dcs地址 password String 用户密码 表12 EventRouterAdvanceConfig 参数 参数类型 描述 kafka2kafka Kafka2KafkaAdvanceConfig object kafka同步自定义配置 rocketmq2rocketmq Rocketmq2RocketmqAdvanceConfig object rocketmq同步自定义配置 dcs2dcs Dcs2DcsAdvanceConfig object dcs同步自定义配置 表13 Kafka2KafkaAdvanceConfig 参数 参数类型 描述 topics String 要同步的topic名称，精确匹配，用","间隔，与topic_regex参数二选一 topic_regex String 要同步的topic正则表达式，与topics参数二选一 replica_cnt Integer 副本数，不能大于broker数量 seek_to String 数据同步点 compress_alg String 压缩算法 none：不使用压缩算法 gzip：gzip压缩算法 snappy：snappy压缩算法 lz4：lz4压缩算法 zstd：zstd压缩算法 is_sync_progress Boolean 是否同步消费进度 true：同步 false：不同步 is_add_header Boolean 是否添加来源Header rename_topic Boolean 是否重命名Topic topic_mappings Array of KafkaTopicMapping objects topic映射 表14 KafkaTopicMapping 参数 参数类型 描述 source_topic String 源主题 sink_topic String 目标主题 表15 Rocketmq2RocketmqAdvanceConfig 参数 参数类型 描述 topics String 要同步的topic名称，精确匹配，用","间隔，与topic_regex参数二选一 topic_regex String 要同步的topic正则表达式，与topics参数二选一 is_sync_progress Boolean 是否同步消费进度 seek_to String 数据同步点 最早（first），最新（last），自定义时间戳（long类型） compress_alg String 压缩算法 none：不使用压缩算法 gzip：gzip压缩算法 lz4：lz4压缩算法 zstd：zstd压缩算法 表16 Dcs2DcsAdvanceConfig 参数 参数类型 描述 synchronize_type String 同步类型 默认全量加增量 connect_retry_time String 无法连接后重试时间，默认60秒 other_retry_time String 出现其他问题后的重试时间，默认60秒 use_rate_limit Boolean 是否限制增量同步速率，默认5MS/s true：限制 false：不限制 rate_limit String 限制增量同步速率，默认5MB/s use_salve_node Boolean 是否使用Slave节点 true：使用从节点同步数据 false：不使用从节点同步数据，即使用主节点

URI GET /v1/{project_id}/eventrouter/jobs 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户资源空间ID 表2 Query参数 参数 是否必选 参数类型 描述 fuzzy_name 否 String 名称模糊查询 sink_region 否 String 目标端的region sink_instance_id 否 String 目标端的实例ID sink_address 否 String 目标端的地址 status 否 String 作业的状态 cluster_id 否 String 作业所属集群ID offset 否 String 偏移量 limit 否 String 每页显示的数量