检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
配置系统间数据集成 前提条件 确保业务系统数据库所在网络与ROMA Connect的网络互通。 若通过公网互通,ROMA Connect实例需绑定弹性IP。 确保源端和目标端业务系统的数据库为ROMA Connect支持的数据源类型 数据集成支持的数据源请参见数据集成支持的数据源。
ConsumeConcurrentlyStatus.CONSUME_SUCCESS; } }; //注册回调实现类来处理从RocketMQ拉取回来的消息 rocketMQConsumer.registerMessageList
使用ROMA Connect集成数据 概述 ROMA Connect支持接入多种类型的数据源,并通过数据集成任务实现源端到目标端的数据集成转换。ROMA Connect支持相同结构数据之间进行集成转换,也支持异构数据之间进行集成转换。 本章节通过完成一个API到MQS的数据集成配置样例,帮助您快速熟悉使用ROMA
消息集成 消息集成流程介绍 创建Topic 配置Topic授权 连接Topic Kafka业务迁移 设备集成 设备集成流程介绍 创建产品 注册设备 接入MQTT协议设备 接入Modbus协议设备 接入OPC UA协议设备 配置数据转发规则 订阅设备通知 06 实践 通过提供多种场景的ROMA
更新时间 app_key String APP的key app_secret String 密钥 register_time String 注册时间 status Integer 状态 1: 有效 app_type String APP的类型: apig:存量apig应用,不推荐使用
查询子设备 功能介绍 查询子设备。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v2/{project_id}/link/instances/{inst
修改设备 功能介绍 修改设备信息。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI PUT /v2/{project_id}/link/instances/{inst
API类型 1:公有API 2:私有API req_protocol String API的请求协议 HTTP HTTPS BOTH:同时支持HTTP和HTTPS 缺省值:HTTPS req_method String API的请求方式 req_uri String 请求地址。可以包含请
API类型 1:公有API 2:私有API req_protocol String API的请求协议 HTTP HTTPS BOTH:同时支持HTTP和HTTPS 缺省值:HTTPS req_method String API的请求方式 req_uri String 请求地址。可以包含请
客户端使用建议 Consumer使用建议 Consumer的owner线程需确保不会异常退出,避免客户端无法发起消费请求,阻塞消费。 确保处理完消息后再做消息commit,避免业务消息处理失败,无法重新拉取处理失败的消息。 Consumer不能频繁加入和退出group,频繁加入和
创建设备 功能介绍 创建设备。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v2/{project_id}/link/instances/{instance_id}/devices
租户每个区域对应的项目ID。 instance_id string 是 租户使用ROMA Connect的实例ID。 请求消息 请求参数 无 请求示例 https://example.cloud.com/v1/80e2b******f4a398d6409a50932d917/link/instan
描述 error_code String 错误码。 error_msg String 错误信息。 请求示例 查询消息偏移量。 GET https://{endpoint}/v2/{project_id}/mqs/instances/{instance_id}/messages?a
String 微服务编号 instance_id String 实例编号 service_type String 微服务类型: CSE:CSE微服务注册中心 CCE:CCE云容器引擎(暂不支持) cse_info MicroServiceInfoCSE object CSE基础信息 cce_info
String 删除失败的消费组ID。 error_message String 删除失败的原因。 请求示例 批量删除消费组。 "POST https://{endpoint}/v2/{project_id}/mqs/instances/{instance_id}/groups/batch-delete"
"min_version" : "", "links" : { "rel" : "self", "href" : "https://roma.example.com/" }, "id" : "v2", "updated" : "2020-06-28T12:20:21Z"
查询目标数据源列表 功能介绍 查询目标数据源列表。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v2/{project_id}/link/instanc
租户每个区域对应的项目ID。 instance_id string 是 租户使用ROMA Connect的实例ID。 请求消息 请求参数 无 请求示例 https://example.cloud.com/v1/80e2b******f4a398d6409a50932d917/link/instan
ase64编码后大小不超过10M。 URL路径 获取图片方式为“URL路径”时,此处填写图片的URL路径。 目前支持: 公网HTTP/HTTPS URL。 华为云OBS提供的URL,使用OBS数据需要进行授权。包括对服务授权、临时授权、匿名公开授权。详情参见配置OBS服务的访问权限。
度最大64,仅支持中文、英文字母、数字、下划线和中划线。 remark string 否 描述信息,不能超过200个字符。 请求示例 https://example.cloud.com/v1/80e2b******f4a398d6409a50932d917/link/instan