检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
目标端数据源服务,如下情况时server字段必填:destination_type值为0时, 为MQS连接地址;destination_type值为1、2或3时, 为KAFKA类数据源的连接地址,destination_type值为7时,为设备所属产品的产品名。 最小长度:0 最大长度:64
用direct交换器生产消息,把消息路由到bindingKey与routingKey完全匹配的Queue中。 输入参数 routingKey:消息路由键 props:消息持久化设置,非必填 message:消息内容 public void produceWithTopicExchange(String bindingKey
backend available”错误 原因分析 可能是以下两种原因导致,请逐一排查: 后端服务无法访问。 ECS安全组未开放需要的端口。 解决方案 请修改后端服务。 修改ECS安全组配置,开放需要的端口。 父主题: 服务集成
对响应中的部分元素进行指定类型的编码。如果 delimiter、marker、prefix、nextMarker 和 key 包含xml 1.0标准不支持的控制字符,可通过设置 encodingType 对响应中的 delimiter、marker、prefix(包括commonPrefixes 中的 prefix)、nextMarker
最大长度:64 product_type Integer 产品类型,0-普通产品(不支持子设备) 1-网关产品。 最小值:0 最大值:10 description String 产品描述,长度0-200。 最小长度:0 最大长度:200 protocol_type Integer 产品的协议类型,0-mqtt
间格式:YYYYMMDDTHHMMSSZ。如果API发布到非RELEASE环境时,需要增加自定义的环境名称。 客户端须注意本地时间与时钟服务器的同步,避免请求消息头X-Sdk-Date的值出现较大误差。 ROMA Connect除了校验X-Sdk-Date的时间格式外,还会校验该
错误描述。 最小长度:2 最大长度:512 请求示例 修改指定数据集成组合任务,操作类型修改为插入和更新,并同步已有数据 { "description" : "test" } 响应示例 状态码: 400 Bad Request { "error_code" : "FDI.3150"
"7eb619ecf2a24943b099833cd24a01ba", "acl_name" : "acl_demo", "entity_type" : "IP", "acl_type" : "PERMIT", "acl_value" : "192.168.1.5,192.168.10
ApiDuplicationInfo 参数 参数类型 描述 req_method String 请求方式 req_uri String API的访问地址 match_mode String API的匹配方式 SWA:前缀匹配 NORMAL:正常匹配(绝对匹配) 默认:NORMAL duplicated_apis
脚本配置示例 { "cache_key": { "system_params": [ "$context.sourceIp", "$context.requestId" ], "parameters": [ "demo_parameters"
long maxItems) 消费消息 输入参数 topic:消息队列 timeout:读取超时时间,最大值为30000毫秒,建议timeout设置值小于前端API的“后端超时”时间值 maxItems:读取消息的最大数量 返回信息 Kafka已消费的消息数组,消息数组即将多条消息的内容组成一个数组
API描述 run_env_id String 发布的环境ID id String API编号 req_uri String API的请求地址 type Integer API类型 acl_name String 绑定的其他同类型的ACL策略名称 状态码: 400 表6 响应Body参数
绿色通道的黑名单配置 visit_param String 访问参数。 roma_app_type String ROMA_APP的类型: subscription:订阅应用 integration:集成应用 envname String api授权绑定的环境 appid String APP的编号
API描述 run_env_id String 发布的环境ID id String API编号 req_uri String API的请求地址 状态码: 400 表6 响应Body参数 参数 参数类型 描述 error_code String 错误码 error_msg String
API描述 run_env_id String 发布的环境ID id String API编号 req_uri String API的请求地址 type Integer API类型 signature_name String 已绑定的签名密钥名称 状态码: 400 表6 响应Body参数
apig:存量apig应用,不推荐使用 roma:ROMA集成应用 roma_app_type String ROMA_APP的类型: subscription:订阅应用 integration:集成应用 bind_num Integer 绑定的API数量 状态码: 400 表6 响应Body参数
clickhouse: clickhouse数据源类型 mrshive: mrshive数据源类型(tag:Site_hybrid) description String 数据源描述 url String 数据源连接字符串 user String 用户名 password String
API描述 run_env_id String 发布的环境id id String API编号 req_uri String API的请求地址 tags Array of strings API绑定的标签,标签配额默认10条,可以联系技术调整。 最小长度:1 最大长度:128 数组长度:0
并行处理过程的最长执行时间,如果超过该时间后,仍有未执行完成的分支任务,则该分支的任务将被丢弃,且最终的合并结果中不会包含该分支。 超时时间为0时,表示不设置超时时间,将等待所有分支任务执行完成。 “并行处理”节点的分支名称,需在后续相邻节点的连线上配置。 父主题: 处理器
消息查询”,进入消息查询页面。 在页面右上角选择要查询消息的Topic,界面自动展示该Topic中存储的消息记录。 您也可以单击“高级搜索”,设置查询条件,然后单击“搜索”,查询消息。 查询方式:选择消息的查询方式。 按生产时间查询:按生产消息的时间查询。 按偏移量查询:按分区中记录消息的位置查询。