转发方式概述 设备接入到物联网平台后，便可与物联网平台进行通信。设备通过自定义Topic或产品模型方式将数据上报到平台，在控制台设置后，通过订阅推送的方式，将设备生命周期变更、设备属性上报、设备消息上报、设备消息状态变更、设备状态变更、批量任务状态变更等消息转发到您指定的服务器。 当前华为物联网平台支持HTTP/HTTPS、AMQP、MQTT和设备间通信四种数据转发方式。 HTTP/HTTPS方式 订阅：应用服务器通过调用物联网平台的创建规则触发条件、创建规则动作、修改规则触发条件接口配置并激活规则，或者在控制台创建订阅任务，向平台获取发生变更的设备业务信息（如设备生命周期管理、设备数据上报、设备消息状态、设备状态等）和管理信息（软固件升级状态和升级结果）。订阅时必须指定应用服务器的URL，也称为回调地址。（什么是回调地址？）。 推送：订阅成功后，物联网平台根据应用服务器订阅的数据类型，将对应的变更信息（推送的通知内容可参考流转数据）推送给指定的URL地址。如果应用服务器没有订阅该类型的数据通知，即使数据发生了变更也不会进行推送。物联网平台进行数据推送时，数据格式为JSON格式，推送协议可以采用HTTP或HTTPS协议，其中HTTPS协议为加密传输协议，需要进行安全认证，更加安全，推荐使用。 HTTP/HTTPS方式详细请参考使用HTTP/HTTPS转发。 AMQP方式 订阅：AMQP（Advanced Message Queuing Protocol）即高级队列消息协议。用户通过控制台创建订阅任务，也可以通过调用物联网平台的创建规则触发条件、创建规则动作、修改规则触发条件接口配置并激活规则，向平台获取发生变更的设备业务信息（如设备生命周期管理、设备数据上报、设备消息状态、设备状态等）和管理信息（软固件升级状态和升级结果）。订阅时必须指定具体的AMQP消息通道。 推送：订阅成功后，物联网平台根据用户订阅的数据类型，将对应的变更信息推送给指定的AMQP消息队列。如果用户没有订阅该类型的数据通知，即使数据发生了变更也不会进行推送。用户可通过AMQP的客户端与IoT平台建立链接，来接收数据。 AMQP详细请参考使用AMQP转发。 MQTT方式 订阅：用户可以通过调用物联网平台的创建规则触发条件、创建规则动作、修改规则触发条件接口配置并激活规则，向平台获取发生变更的设备业务信息（如设备生命周期管理、设备数据上报、设备消息上报、设备状态等）和管理信息（软固件升级状态和升级结果）。订阅时必须指定接收推送消息的Topic。 推送：订阅成功后，物联网平台根据用户订阅的数据类型，将对应的变更信息推送给指定的Topic。如果用户没有订阅该类型的数据通知，即使数据发生了变更也不会进行推送。用户可通过MQTT的客户端与IoT平台建立连接，来接收数据。 MQTT详细请参考使用MQTT转发。 设备间通信 订阅：物联网平台支持基于MQTT协议实现设备间的消息通信，用户可通过控制台创建规则，也可以通过调用物联网平台的创建规则触发条件、创建规则动作、修改规则触发条件接口配置并激活规则，向平台获取设备上报的消息。设备订阅只支持消息上报。 推送：订阅成功后，物联网平台会将设备上报的消息推送到指定的MQTT Topic，当设备接入平台后，可以通过订阅该Topic来接收数据，从而实现设备间的消息通信。 设备间通信详细请参考设备间通信。 数据转发方式 适用场景 优点 限制 HTTP/HTTPS订阅推送 应用作为服务端被动接收IoT云服务的消息。 - 流控限制800TPS，不建议大流量推送使用HTTP/HTTPS方式。 AMQP订阅推送 应用作为客户端，可主动拉取IoT云服务的消息，也可以通过监听被动接收 IoT云服务的消息。 能主动拉取数据 请参考连接规格。 MQTT订阅推送 应用作为客户端，可以通过订阅接收 IoT云服务的消息。 - 请参考使用限制。 设备间通信 智能家居控制场景，手机APP和智能设备之间进行消息通信。 设备联动，设备间进行数据传输与消息通信。 实现设备间通信 请参考设备间消息通信概述。 父主题： 数据转发至第三方应用

购买RocketMQ 登录华为云，访问分布式消息服务RocketMQ版， 进入分布式消息服务管理控制台。 单击右上角“购买RocketMQ实例”, 按照需求选择RocketMQ规格，单击“立即购买”。 图1 购买RocketMQ 单击进入购买的RocketMQ实例，开启ACL访问控制后，单击“用户管理”添加用户，可参考创建用户。 图2 添加用户 单击左侧导航栏“topic管理”，单击“创建topic”创建RocketMQ的topic。

响应参数 状态码： 200 表4 响应Body参数 参数 参数类型 描述 count Integer 参数说明：满足查询条件的记录总数。 最小值：0 最大值：10000 forwarding_configs Array of ForwardingConfig objects 参数说明：转发配置的列表。 数组长度：0 - 50 表5 ForwardingConfig 参数 参数类型 描述 forwarding_type String 参数说明：转发配置的类型。 取值范围：当前仅支持“kafka、mrskafka”。 kafka_config KafkaConfigResponseDTO object 参数说明：Kafka配置信息。 mrs_kafka_config MrsKafkaConfigResponseDTO object 参数说明：mrsKafka配置信息。 表6 KafkaConfigResponseDTO 参数 参数类型 描述 kafka_config_id String 参数说明：每一套Kafka配置的唯一ID。 取值范围：只允许字母、数字、下划线（_）、连接符（-）的组合。 最小长度：1 最大长度：255 kafka_topics Array of strings 参数说明：kafka的主题列表。 取值范围： v2x-v1-tracks：edge上报的车辆轨迹数据 v2x-v1-bsm：车载T-BOX，RSU上报的BSM消息数据 v2x-v1-rsi：RSU，edge上报的RSI消息数据 v2x-v1-rsm： RSU，edge上报的RSM消息数据 v2x-v1-spat：RSU上报的SPAT消息数据 v2x-v1-edge-flow：edge上报的车流量统计信息数据 数组长度：0 - 7 brokers Array of strings 参数说明：Kafka broker列表。 最小长度：1 最大长度：255 数组长度：1 - 255 username String 参数说明：kafka用户名。 取值范围：只允许字母、数字、下划线（_）、连接符（-）的组合。 最小长度：1 最大长度：255 topic_prefix String 参数说明：Topic前缀。 取值范围：长度不超过255，只允许字母、数字、下划线（_）、连接符（-）的组合。 status String 参数说明：一套kafka的连接状态。 取值范围： OFFLINE：离线 ONLINE：在线 枚举值： OFFLINE ONLINE cert_info CertificateInfo object model_ids Array of strings 参数说明：模型ID列表。 user_topics包含model-data时必选，仅支持非系统、分层为gdm的动态模型。 可通过 GET /{project_id}/models 查询模型列表接口获取。 取值范围：仅支持字母，数字以及中划线（-）的组合，长度为36。 数组长度：1 - 10 created_time String 参数说明：创建时间。 格式为yyyy-MM-dd'T'HH:mm:ss'Z' 例如：2015-12-12T12:12:12Z last_modified_time String 参数说明：修改时间。 格式为yyyy-MM-dd'T'HH:mm:ss'Z' 例如：2015-12-12T12:12:12Z 表7 CertificateInfo 参数 参数类型 描述 effective_date String 证书生效日期 expiry_date String 证书失效日期 表8 MrsKafkaConfigResponseDTO 参数 参数类型 描述 kafka_config_id String 参数说明：每一套Kafka配置的唯一ID。 取值范围：只允许字母、数字、下划线（_）、连接符（-）的组合。 最小长度：1 最大长度：255 kafka_topics Array of strings 参数说明：kafka的主题列表。 取值范围： v2x-v1-tracks：edge上报的车辆轨迹数据 v2x-v1-bsm：车载T-BOX，RSU上报的BSM消息数据 v2x-v1-rsi：RSU，edge上报的RSI消息数据 v2x-v1-rsm： RSU，edge上报的RSM消息数据 v2x-v1-spat：RSU上报的SPAT消息数据 v2x-v1-edge-flow：edge上报的车流量统计信息数据 数组长度：0 - 7 brokers Array of strings 参数说明：Kafka broker列表。 最小长度：1 最大长度：255 数组长度：1 - 255 username String 参数说明：mrskafka用户名，若开启安全认证该参数必填。 取值范围：只允许字母、数字、下划线（_）、连接符（-）的组合。 最小长度：0 最大长度：255 status String 参数说明：一套kafka的连接状态。 取值范围： OFFLINE：离线 ONLINE：在线 枚举值： OFFLINE ONLINE authentication Boolean 参数说明：是否开启kerberos安全认证的开关。若开启安全认证则需要先上传kerberos安全认证的凭证。 缺省值：false model_ids Array of strings 参数说明：模型ID列表。 user_topics包含model-data时必选，仅支持非系统、分层为gdm的动态模型。 可通过 GET /{project_id}/models 查询模型列表接口获取。 取值范围：仅支持字母，数字以及中划线（-）的组合，长度为36。 数组长度：1 - 10 created_time String 参数说明：创建时间。 格式为yyyy-MM-dd'T'HH:mm:ss'Z' 例如：2015-12-12T12:12:12Z last_modified_time String 参数说明：修改时间。 格式为yyyy-MM-dd'T'HH:mm:ss'Z' 例如：2015-12-12T12:12:12Z

响应示例 状态码： 200 OK { "count" : 1, "forwarding_configs" : [ { "forwarding_type" : "kafka", "kafka_config" : { "kafka_config_id" : "1234567890", "kafka_topics" : [ "v2x-v1-tracks", "v2x-v1-bsm", "v2x-v1-rsi", "v2x-v1-rsm", "v2x-v1-spat", "v2x-v1-edge-flow", "realtime-traffic", "forecast-traffic", "recommended-strategies", "executed-strategies", "strategy-evaluations", "confirmed-event", "traffic-event", "compositive-tracks", "model-data", "request-strategies" ], "brokers" : [ "127.0.0.1:10000" ], "username" : "1234567890", "topic_prefix" : "abc", "status" : "ONLINE", "model_ids" : [ "40f96952-ea2f-4a10-8a92-e641aa1c6e49" ], "created_time" : "2015-12-12T12:12:12Z", "last_modified_time" : "2015-12-13T12:12:12Z" }, "mrs_kafka_config" : { "kafka_config_id" : null, "kafka_topics" : [ "v2x-v1-tracks", "v2x-v1-bsm", "v2x-v1-rsi", "v2x-v1-rsm", "v2x-v1-spat", "v2x-v1-edge-flow", "realtime-traffic", "forecast-traffic", "recommended-strategies", "executed-strategies", "strategy-evaluations", "confirmed-event", "traffic-event", "compositive-tracks", "model-data", "request-strategies" ], "brokers" : [ "127.0.0.1:10000" ], "username" : null, "status" : null, "authentication" : false, "model_ids" : [ "40f96952-ea2f-4a10-8a92-e641aa1c6e49" ], "created_time" : "2015-12-12T12:12:12Z", "last_modified_time" : "2015-12-12T12:12:12Z" } } ] }

模拟数据上报及结果验证 使用MQTT模拟器连接到平台（模拟器使用请参考：使用MQTT.fx调测）。 使用模拟器进行属性上报(参考：设备属性上报)。 上报内容如下： { "services": [{ "service_id": "order", "properties": { "orderID": "0000002", "area": "罗湖区", "orderTime": "20220815T121215Z", "goods": "商品02", "amount": 30.5 }, "event_time": "20220815T121215Z" } ] } 打开数据可视化服务查看数据是否刷新。 图15 结果查看

创建产品和设备 访问设备接入服务，单击“立即使用”进入设备接入控制台。 选择左侧导航栏的“产品”，单击右上角下拉框，选择新建产品所属的资源空间。 单击左侧的“创建产品”，创建一个基于MQTT协议的产品，填写参数后，单击“确认”。 图3 创建产品-MQTT 为上一步创建的产品导入产品模型，请参考导入产品模型。 选择第3步创建的产品，在该产品下注册设备、请参考注册单个设备。 本文中使用的产品模型和设备仅为示例，您可以使用自己的产品模型和设备进行操作。

数据上报及验证数据是否转发成功 使用MQTT模拟器连接到平台（模拟器使用请参考：使用MQTT.fx调测）。 使用模拟器进行属性上报(参考：设备属性上报)。 上报内容如下： { "services": [{ "service_id": "order", "properties": { "orderID": "0000001", "area": "南山区", "orderTime": "20220815T121215Z", "goods": "商品01", "amount": 30.5 }, "event_time": "20220815T121215Z" } ] } 前往OBS控制台，查看转发目标设置的文件是否生成。 图7 查看OBS桶内文件

场景说明 物联网解决方案中，作为数据主体的“物”可能数量会非常大，产生的数据已经无法通过传统的数据处理服务进行处理。如何分析与利用这庞大的物联网设备数据对物联网企业来说又是一个新的挑战。 华为云物联网平台提供规则引擎能力，支持将设备上报的数据转发至华为云其他云服务，可实现将海量数据通过对象存储服务（OBS）存储，再由数据可视化服务（DLV）读取数据呈现为可视化报表，实现数据的一站式采集、处理和分析。 图1 场景说明 在本示例中，我们实现下述场景： 设备上报数据到物联网平台，物联网平台将数据以CSV格式存储到对象存储服务（OBS），数据可视化服务(DLV)从OBS文件读取数据并展现为多个维度的报表。

场景说明 物联网平台为用户提供了丰富的报表功能，能够将数据直观地呈现出来，当您想将报表中的数据集成到自己的运维系统时，可以使用AOM的订阅功能将IoTDA推送的指标数据推送至DMS Kafka，您可以消费DMS Kafka中的指标数据展示在您自己的运维系统中。本示例为使用AOM订阅功能将指标数据推送至DMS Kafka，并以在线设备数指标为例展示。IoTDA支持的指标数据可参考IoTDA指标详情。

前提条件 已注册华为官方账号。未注册可参考注册华为账户注册华为账户完成注册。 已完成实名制认证。未完成可在华为云上单击实名认证完成认证，否则会影响后续云服务的开通。 已开通设备接入服务。未开通则访问设备接入服务，单击“免费试用”或单击“价格计算器”购买并开通该服务。 已开通AOM服务。访问AOM服务，单击“AOM2.0控制台”，单击“免费开通服务并授权”开通该服务。 已开通DMS Kafka服务。未开通则访问DMS Kafka服务，单击“立即购买”后开通该服务。

Message示例 { "header" : { "instance_id" : "f24b3b95-4a2a-4f6f-a80c-855156b50af7", "event" : "ADDED" }, "body" : { "source" : { "source_type" : "detection", "source_id" : "EDGE0123456789", "esn" : "2102312ETX10K7000037" }, "time" : "2020-09-01T01:37:01.123Z", "cross_id" : "cross0123456789", "track_list" : [ { "track_id" : 50, "ptc_type" : "motor", "ptc_id" : 3, "source" : "rsu", "global_track_id" : 3, "vehicle_class" : 10, "vehicle_color" : "black", "vehicle_model" : "朗逸", "vehicle_brand" : "红旗", "vehicle_style" : "2018,2019,2020", "gat_vehicle_class" : "K33", "plat_no" : "浙A12345", "heading" : 158.23, "speed" : 10.2, "car_direction" : 1, "fuel_type" : 5, "camera_list" : [ { "id" : 0, "ip" : "127.0.0.1" } ], "size" : { "width" : 200, "length" : 400, "height" : 200 }, "location_list" : [ { "lon" : 123.123, "lat" : 11.123, "speed" : 10.2, "accel_set" : { "long_accel" : 3, "lat_accel" : 4, "vert_accel" : 0, "yaw_rate" : 0 }, "heading" : 158.23, "angle" : 0, "car_direction" : 1, "time_stamp" : 1626243657123 } ] } ] } }

Message参数 表1 请求Body参数 参数 是否必选 参数类型 描述 header 是 OpenV2XTracksHeader object 参数说明：轨迹数据信息的附加描述。 body 是 OpenV2XTracksBody object 参数说明：轨迹数据信息。 表2 OpenV2XTracksHeader 参数 是否必选 参数类型 描述 instance_id 是 String 参数说明：实例ID。dris物理实例的唯一标识。 event 是 String 参数说明：操作描述。" 取值范围： MODIFIED：修改 ADDED：新增 DELETED：删除 枚举值： MODIFIED ADDED DELETED 表3 OpenV2XTracksBody 参数 是否必选 参数类型 描述 source 否 TracksSource object 参数说明：消息来源。 time 否 String 参数说明：数据上报的时间。 格式：yyyy-MM-dd'T'HH:mm:ss.SSS'Z'。 例如 2021-01-08T02:03:41.907Z。 cross_id 否 String 参数说明：路口id，对应到一组雷视拟合设备，检测一个特定的路口或者路段。 最小长度：0 最大长度：64 track_list 否 Array of TrackList objects 参数说明：轨迹列表。 数组长度：0 - 100 表4 TracksSource 参数 是否必选 参数类型 描述 source_type 否 String 参数说明：信息来源的具体类型描述。 枚举值： rsu obu detection sne source_id 否 String 参数说明：信息来源的唯一标识码ID。 最小长度：1 最大长度：255 esn 否 String 参数说明：设备编码。 取值范围：长度不超过64，只允许字母、数字、以及_等字符的组合。 表5 TrackList 参数 是否必选 参数类型 描述 track_id 否 Long 参数说明：轨迹id。 最小值：0 最大值：9223372036854775807 ptc_type 否 String 参数说明：路侧单元检测到的交通参与者类型。 取值范围： unknown：未知类型 motor：机动车 non-motor：非机动车 pedestrian：行人 rsu：RSU设备 ptc_id 否 Integer 参数说明：检测单元设置的临时ID。 最小值：0 最大值：65535 source 否 String 参数说明：定义交通参与者数据的来源。 取值范围： unknown：未知数据源类型 rsu：RSU自身信息 v2x：参与者自身的v2x广播消息 video：视频传感器 microwaveRadar：微波雷达传感器 loop：地磁线圈传感器 lidar：激光雷达传感器 integrated：一类或以上感知数据的融合结果 global_track_id 否 Long 参数说明：ITS800通过GlobalTrackID字段标识了车辆唯一ID。 最小值：0 最大值：9223372036854775807 vehicle_class 否 Integer 参数说明：车辆类型。参考车辆基本类型。 最小值：0 最大值：1000 gat_vehicle_class 否 String 参数说明：机动车车辆类型。参考机动车车辆类型。 vehicle_color 否 String 参数说明：车辆颜色。 取值范围： black：黑色 white：白色 gray：灰色 red：红色 blue：蓝色 yellow：黄色 orange：橙色 brown：棕色 green：绿色 purple：紫色 cyan：青色 pink：粉红色 transparent：透明色 other：其他 vehicle_model 否 String 参数说明：车辆型号。 最小长度：0 最大长度：63 vehicle_brand 否 String 参数说明：车辆品牌。 最小长度：0 最大长度：31 vehicle_style 否 String 参数说明：车辆年款，通过年份来表示，多个年份通过逗号分隔。 最小长度：0 最大长度：63 plat_no 否 String 参数说明：车牌。 最小长度：0 最大长度：63 heading 否 Number 参数说明：车的航向角，正北为0度，顺时针增加。单位° 最小值：0 最大值：360 speed 否 Number 参数说明：速度，单位km/h。 最小值：0 最大值：1000 car_direction 否 Integer 参数说明：车辆方向。 取值范围： -1：未知方向 0：车头 1：车尾 最小值：-1 最大值：1 fuel_type 否 Integer 参数说明：定义车辆的燃料动力类型，10-15暂未定义。 取值范围： 0：未知 1：汽油 2：乙醇 3：柴油 4：电动 5：混合燃料类型 6：氢气 7：液化天然气 8：压缩天然气 9：丙烷 最小值：0 最大值：15 size 否 SizeDTO object 参数说明：车辆尺寸。 camera_list 否 Array of TrackCameraInfo objects 拍摄到事件的摄像头信息。 数组长度：0 - 10 location_list 否 Array of LocationList objects 参数说明：位置列表。 数组长度：0 - 100 表6 SizeDTO 参数 是否必选 参数类型 描述 width 否 Integer 参数说明：车辆宽度，单位厘米。 最小值：0 最大值：300 length 否 Integer 参数说明：车辆长度，单位厘米。 最小值：0 最大值：3000 height 否 Integer 参数说明：车辆高度，单位厘米。 最小值：0 最大值：500 表7 TrackCameraInfo 参数 是否必选 参数类型 描述 id 否 Integer 参数说明：SNE的摄像头id,编号从0开始。 最小值：0 最大值：128 ip 否 String 参数说明：摄像头ip。 最小长度：0 最大长度：15 表8 LocationList 参数 是否必选 参数类型 描述 lon 否 Number 参数说明：经度。东经为正，西经为负，单位°，精度小数点后7位。 最小值：-180 最大值：180 lat 否 Number 参数说明：纬度。北纬为正，南纬为负，单位°，精度小数点后7位。 最小值：-90 最大值：90 speed 否 Number 参数说明：速度，单位km/h。 最小值：0 最大值：1000 accel_set 否 AccelerationSet4Way object 参数说明：定义车辆四轴加速度。 heading 否 Number 参数说明：车的航向角，正北为0度，顺时针增加。单位° 最小值：0 最大值：360 angle 否 Integer 参数说明：定义车辆转向轮角度。向右为正，向左为负。单位为1.5°，值为127时代表无效值。 最小值：-126 最大值：127 car_direction 否 Integer 参数说明：车辆方向。 取值范围： -1：未知方向 0：车头 1：车尾 最小值：-1 最大值：1 lane_no 否 Integer 参数说明：车辆所处车道。如果感知设备支持覆盖双向行驶方向时，桩号递增行驶方向，车道号从左到右从1依次递增；桩号递减行驶方向，车道号从左到右从-1依次递减。如果感知设备只支持覆盖单向车道，可以不区分桩号递增或者递减行驶方向，车道号可以按照车辆行驶方向从左到右，从1开始递增。 最小值：-32 最大值：32 time_stamp 否 Long 参数说明：采集车辆数据的毫秒时间戳。 表9 AccelerationSet4Way 参数 是否必选 参数类型 描述 long_accel 是 Integer 参数说明：车辆纵向加速度。单位为0.01米每平方秒。值为2001时代表无效数值。 最小值：-2000 最大值：2001 lat_accel 是 Integer 参数说明：车辆横向加速度。单位为0.01米每平方秒。值为2001时代表无效数值。 最小值：-2000 最大值：2001 vert_accel 是 Integer 参数说明：定义Z轴方向的加速度大小，Z轴方向竖直向下，沿着Z轴方向为正。 分辨率为0.02G，G为重力加速度值9.80665m/s2。 最小值：-127 最大值：127 yaw_rate 是 Integer 参数说明：车辆横摆角速度。指汽车绕垂直轴的偏转，该偏转的大小代表汽车的稳定程度。如果偏转角速度达 到一个阈值，说明汽车发生测滑或者甩尾等危险工况。 顺时针旋转为正，逆时针为负。 数据分辨率为0.01°/s。 最小值：-127 最大值：127

Message示例 { "header" : { "instance_id" : "f24b3b95-4a2a-4f6f-a80c-855156b50af7", "event" : "ADDED" }, "body" : { "source" : { "source_type" : "detection", "source_id" : "705183159624675328_2102312ETX10K7000037" }, "time" : "2020-09-01T01:37:01Z", "period" : 300, "direction" : 180, "flow" : 75, "average_speed" : 72.5, "cross_id" : "cross0123456789", "esn" : "2102312ETX10K7000037", "traffic_direction" : "0,", "road_kind" : "1,", "has_congestion" : "false,", "vehicle_class_flow" : [ { "vehicle_class" : 10, "flow" : 50, "average_speed" : 73.6 }, { "vehicle_class" : 20, "flow" : 25, "average_speed" : 71.4 } ], "occupancy" : [ { "lane_id" : 0, "space_occupancy" : 0.6, "time_occupancy" : 0.5 }, { "lane_id" : 1, "space_occupancy" : 0.6, "time_occupancy" : 0.5 } ], "lane_flow" : [ { "lane_id" : 10, "flow" : 50, "average_speed" : 73.6 }, { "lane_id" : 20, "flow" : 25, "average_speed" : 71.4 } ] } }

响应示例 状态码： 201 Created { "forwarding_type" : "kafka", "kafka_config" : { "kafka_config_id" : 1234567890, "kafka_topics" : [ "v2x-v1-tracks", "v2x-v1-bsm", "v2x-v1-rsi", "v2x-v1-rsm", "v2x-v1-spat", "v2x-v1-edge-flow" ], "topic_prefix" : "prefix", "brokers" : [ "127.0.0.1:10000" ], "username" : "1234567890", "status" : "OFFLINE", "created_time" : "2015-12-12T12:12:12Z", "last_modified_time" : "2015-12-12T12:12:12Z" }, "mrs_kafka_config" : { "kafka_config_id" : null, "kafka_topics" : [ "v2x-v1-tracks", "v2x-v1-bsm", "v2x-v1-rsi", "v2x-v1-rsm", "v2x-v1-spat", "v2x-v1-edge-flow" ], "brokers" : [ "127.0.0.1:10000" ], "username" : null, "status" : null, "authentication" : false, "created_time" : "2015-12-12T12:12:12Z", "last_modified_time" : "2015-12-12T12:12:12Z" }}

请求示例 POST https://{Endpoint}/v5/iot/{project_id}/rulesContent-Type: application/jsonX-Auth-Token: ********Instance-Id: ********{ "name" : "string", "description" : "string", "condition_group" : { "time_range" : { "days_of_week" : "string", "start_time" : "string", "end_time" : "string" }, "logic" : "string", "conditions" : [ { "device_status_condition" : { "status_list" : [ "string" ] }, "device_property_condition" : { "device_id" : "string", "product_id" : "string", "filters" : [ { "path" : "string", "value" : "string", "operator" : "string" } ] }, "type" : "string", "device_message_condition" : { "product_id" : "string", "topic" : "string" } } ] }, "actions" : [ { "iota_forwarding" : { "project_id" : "string", "region_name" : "string" }, "roma_forwarding" : { "project_id" : "string", "region_name" : "string", "roma_push_type" : "string" }, "kafka_forwarding" : { "kafka_mechanism" : "string", "project_id" : "string", "kafka_addresses" : [ { "port" : 0, "ip" : "string", "domain" : "string" } ], "kafka_username" : "string", "region_name" : "string", "kafka_topic" : "string", "kafka_password" : "string" }, "obs_forwarding" : { "project_id" : "string", "bucket_name" : "string", "region_name" : "string", "location" : "string" }, "type" : "string", "dis_forwarding" : { "stream_name" : "string", "project_id" : "string", "stream_id" : "string", "region_name" : "string" }, "addition" : [ "string" ] } ], "rule_type" : "string", "status" : "string", "app_id" : "string", "edge_node_ids" : [ "string" ]}