云服务器内容精选
-
请求示例 PUT https://{endpoint}/v1/{project_id}/forwarding-configs/{forwarding_config_id}?forwarding_type={forwarding_type}Content-Type:application/jsonX-Auth-Token:********Instance-Id:********{ "kafka_config" : { "topic_prefix" : "abc", "user_topics" : [ "v2x-v1-tracks", "v2x-v1-bsm", "v2x-v1-rsi", "v2x-v1-rsm", "v2x-v1-spat", "v2x-v1-edge-flow", "realtime-traffic", "junction-realtime-traffic", "forecast-traffic", "recommended-strategies", "executed-strategies", "strategy-evaluations", "confirmed-event", "traffic-event", "compositive-tracks", "model-data", "request-strategies", "congestion-event", "congestion-prediction-event" ], "brokers" : [ "127.0.0.1:1000" ], "username" : "1234567890", "password" : "1234567890", "model_ids" : [ "40f96952-ea2f-4a10-8a92-e641aa1c6e49" ] }}
-
响应示例 状态码： 200 OK { "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", "junction-realtime-traffic", "forecast-traffic", "recommended-strategies", "executed-strategies", "strategy-evaluations", "confirmed-event", "traffic-event", "compositive-tracks", "model-data", "request-strategies", "congestion-event", "congestion-prediction-event" ], "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", "junction-realtime-traffic", "forecast-traffic", "recommended-strategies", "executed-strategies", "strategy-evaluations", "confirmed-event", "traffic-event", "compositive-tracks", "model-data", "request-strategies", "congestion-event", "congestion-prediction-event" ], "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" }}
-
响应参数 状态码： 200 表7 响应Body参数 参数 参数类型 描述 forwarding_type String 参数说明：转发配置的类型。 取值范围：当前仅支持“kafka、mrskafka”。 kafka_config KafkaConfigResponseDTO object 参数说明：Kafka配置信息。 mrs_kafka_config MrsKafkaConfigResponseDTO object 参数说明：mrsKafka配置信息。 表8 KafkaConfigResponseDTO 参数 参数类型 描述 kafka_config_id String 参数说明：每一套Kafka配置的唯一ID。 取值范围：只允许字母、数字、下划线（_）、连接符（-）的组合。 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上报的车流量统计信息数据 brokers Array of strings 参数说明：Kafka broker列表。 username String 参数说明：kafka用户名。 取值范围：只允许字母、数字、下划线（_）、连接符（-）的组合。 topic_prefix String 参数说明：Topic前缀。 取值范围：长度不超过255，只允许字母、数字、下划线（_）、连接符（-）的组合。 status String 参数说明：一套kafka的连接状态。 取值范围： OFFLINE：离线 ONLINE：在线 cert_info CertificateInfo object 参数说明：证书信息。 model_ids Array of strings 参数说明：模型ID列表。 user_topics包含model-data时必选，仅支持非系统、分层为gdm的动态模型。 可通过 GET /{project_id}/models 查询模型列表接口获取。 取值范围：仅支持字母，数字以及中划线（-）的组合，长度为36。 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 表9 CertificateInfo 参数 参数类型 描述 effective_date String 证书生效日期 expiry_date String 证书失效日期 表10 MrsKafkaConfigResponseDTO 参数 参数类型 描述 kafka_config_id String 参数说明：每一套Kafka配置的唯一ID。 取值范围：只允许字母、数字、下划线（_）、连接符（-）的组合。 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上报的车流量统计信息数据 brokers Array of strings 参数说明：Kafka broker列表。 username String 参数说明：mrskafka用户名，若开启安全认证该参数必填。 取值范围：只允许字母、数字、下划线（_）、连接符（-）的组合。 status String 参数说明：一套kafka的连接状态。 取值范围： OFFLINE：离线 ONLINE：在线 authentication Boolean 参数说明：是否开启kerberos安全认证的开关。若开启安全认证则需要先上传kerberos安全认证的凭证。 model_ids Array of strings 参数说明：模型ID列表。 user_topics包含model-data时必选，仅支持非系统、分层为gdm的动态模型。 可通过 GET /{project_id}/models 查询模型列表接口获取。 取值范围：仅支持字母，数字以及中划线（-）的组合，长度为36。 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
-
场景说明 对于设备上报到平台的数据，使用 函数工作流 FunctionGraph处理实时流数据。通过函数服务，用户只需编写业务函数代码并设置运行的条件，无需配置和管理服务器等基础设施，即可跟踪设备的设备属性、消息上报，状态变更，分析、整理和计量数据流。 本示例为将所有设备上报的属性转发至FunctionGraph函数工作流，根据设备资源空间Id的不同推送到用户Http服务器的不同路径，请您提供自行部署的Http服务器。本示例通过设备接入服务的数据转发能力来驱动事件函数，不需要额外配置触发器。
-
构建函数工程 本例提供了设备属性上报格式转换并转发到第三方应用的源码（包含函数依赖），用户可以下载学习使用。 创建工程 本例使用Java语言实现设备接入属性数据流式转换功能与推送功能，有关函数开发的过程请参考FunctionGraph的Java函数开发指南，本例不再介绍函数工作流函数实现的代码。 下载样例源码，解压缩并在Idea中导入工程。代码说明可参考：样例代码说明，其中用户自己的服务器地址通过函数环境变量NA_MOCK_SERVER_ADDRESS传入。 图1 样例代码说明 打包工程 使用Idea的Build Artifacts打包Jar，Idea配置及打包如下图所示。 图2 工程Artifacts Output 配置参考 图3 Build Artifacts
-
转发方式概述 设备接入到 物联网平台 后，便可与物联网平台进行通信。设备通过自定义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和智能设备之间进行消息通信。 设备联动，设备间进行数据传输与消息通信。 实现设备间通信 请参考设备间消息通信概述。 父主题： 数据转发至第三方应用
-
请求示例 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" ]}
-
错误码 HTTP状态码 错误码 错误码英文描述 错误码中文描述 处理建议 400 IOTDA.000006 Invalid input data. 请求参数不合法 请排查请求参数是否符合华为云文档要求。 IOTDA.001001 Invalid input for this application. 应用参数不合法 请排查请求参数是否符合华为云文档要求。 IOTDA.010000 Invalid input for this rule. 规则参数不合法 请排查请求参数是否符合华为云文档要求。 IOTDA.010004 Invalid parameter in the rule condition. 规则条件不合法 请排查请求参数是否符合华为云文档要求 IOTDA.010005 Invalid parameter in the rule action. 规则动作参数不合法 请排查请求中action参数是否符合华为云文档要求。 IOTDA.010006 Repeated condition ID in the same rule. 规则条件ID重复 请重新命名规则条件ID后重试。 IOTDA.010007 Repeated action ID in the same rule. 规则动作ID重复 请重新命名规则动作ID后重试。 IOTDA.010008 The device with this condition does not exist. 规则条件中对应的设备不存在 请检查请求参数是否正确或设备在平台是否已经存在。 IOTDA.010009 The device with this action does not exist. 规则动作中对应的设备不存在 请检查请求参数是否正确或设备在平台是否已经存在。 IOTDA.010010 The device data with this condition does not exist. 规则条件中对应的设备信息不存在 请检查请求参数是否正确或设备在平台是否已经存在。 IOTDA.010011 The device data with this action does not exist. 规则动作中对应的设备信息不存在 请检查请求参数是否正确或设备在平台是否已经存在。 IOTDA.010012 The tag with this condition does not exist. 规则条件中对应的标签不存在 请检查请求参数是否正确或标签在平台是否已经存在 IOTDA.010013 Invalid rule parameter. 规则参数不合法 请排查请求参数是否符合华为云文档要求 IOTDA.010015 The rule count of each user has reached the upper limit, the current up limit is 10 entries. 用户下规则数量超过上限 请删除多余的规则后再注册。 403 IOTDA.000004 Invalid access token. 非法token 请排查请求中的token是否正常。 IOTDA.000021 Operation not allowed. User not found by IAM token or the authorized user has not subscribed IOTDA service. 没有找到IAM Token所对应的用户信息或该用户没有订阅设备接入服务（IOTDA） 请排查IAM Token所在用户是否订阅了设备接入服务(IOTDA)。 IOTDA.001000 The application does not exist. 该应用不存在 请确定是否已在平台注册应用并检查应用ID是否正确。 IOTDA.001002 Operation not allowed. The application has not been authorized. 该应用没有权限访问 请检查该应用是否已被授权。 IOTDA.001005 Operation not allowed. The parameter 'app_id' is not carried, and the authorized user has more than one applications. Include the parameter 'app_id', or contact Huawei technical support engineers to merge application data. 该用户下有多个应用的情况下未携带appId访问接口 请携带对应的appId或联系华为工程师合并应用数据。 IOTDA.001006 Operation not allowed. Application not found by authorized user or the authorized user has no application. 用户下没有应用或应用与用户不匹配 请排查用户下是否有应用或是否有指定的应用。 IOTDA.001007 Operation not allowed. The application does not belong to the authorized user. 应用与用户信息不匹配 请排查该用户下是否有指定的应用。 IOTDA.010003 The number of rules has reached the upper limit. 规则数量已达到上限 请删除多余的规则后重试。 404 IOTDA.010002 The rule does not exist. 该规则不存在 请确认平台是否存在该规则或请求参数是否正确。 500 IOTDA.000007 The data in database is abnormal. 数据库中的数据不正常 请联系华为工程师分析解决。 IOTDA.000020 Decrypt IAM token failed. IAM Token解析失败 请联系华为工程师分析解决。
-
响应示例 Status Code: 201 Created Content-Type: application/json{ "rule_id" : "string", "name" : "string", "description" : "string", "condition_group" : { "conditions" : [ { "type" : "string", "device_property_condition" : { "device_id" : "string", "product_id" : "string", "filters" : [ { "path" : "string", "operator" : "string", "value" : "string" } ] }, "device_message_condition" : { "product_id" : "string", "topic" : "string" }, "device_status_condition" : { "status_list" : [ "string" ] } } ], "logic" : "string", "time_range" : { "start_time" : "string", "end_time" : "string", "days_of_week" : "string" } }, "actions" : [ { "type" : "string", "addition" : [ "string" ], "dis_forwarding" : { "region_name" : "string", "project_id" : "string", "stream_name" : "string", "stream_id" : "string" }, "obs_forwarding" : { "region_name" : "string", "project_id" : "string", "bucket_name" : "string", "location" : "string" }, "roma_forwarding" : { "region_name" : "string", "project_id" : "string", "roma_push_type" : "string" }, "iota_forwarding" : { "region_name" : "string", "project_id" : "string" }, "kafka_forwarding" : { "region_name" : "string", "project_id" : "string", "kafka_addresses" : [ { "ip" : "string", "port" : 0, "domain" : "string" } ], "kafka_topic" : "string", "kafka_username" : "string", "kafka_password" : "string", "kafka_mechanism" : "string" } } ], "rule_type" : "string", "status" : "string", "app_id" : "string", "edge_node_id" : [ "string" ], "last_update_time" : "string"}
更多精彩内容
CDN加速
GaussDB
文字转换成语音
免费的服务器
如何创建网站
域名网站购买
私有云桌面
云主机哪个好
域名怎么备案
手机云电脑
SSL证书申请
云点播服务器
免费OCR是什么
电脑云桌面
域名备案怎么弄
语音转文字
文字图片识别
云桌面是什么
网址安全检测
网站建设搭建
国外CDN加速
SSL免费证书申请
短信批量发送
图片OCR识别
云数据库MySQL
个人域名购买
录音转文字
扫描图片识别文字
OCR图片识别
行驶证识别
虚拟电话号码
电话呼叫中心软件
怎么制作一个网站
Email注册网站
华为VNC
图像文字识别
企业网站制作
个人网站搭建
华为云计算
免费租用云托管
云桌面云服务器
ocr文字识别免费版
HTTPS证书申请
图片文字识别转换
国外域名注册商
使用免费虚拟主机
云电脑主机多少钱
鲲鹏云手机
短信验证码平台
OCR图片文字识别
SSL证书是什么
申请企业邮箱步骤
免费的企业用邮箱
云免流搭建教程
域名价格
