检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
通过在ROMA Connect中创建数据集成任务，您可以实现不同数据源之间的数据集成转换。ROMA Connect根据您在数据集成任务中的配置，决定如何将指定的源端的一个数据表中的数据集成到目标端的一个数据表中。 数据集成任务的配置分为任务基本信息、制定计划（可选）、源端信息、目标端信息、
mqs_topic string 是 转发目的端的MQS的Topic名称。 connect_address string 是 MQS Broker的连接地址。 destination string 是 消息转发的目的端的类型，目前只支持ROMA_MQS，KAFKA。 mqs_sasl_ssl Boolean
API描述 run_env_id String 发布的环境ID id String API编号 req_uri String API的请求地址 type Integer API类型 signature_name String 已绑定的签名密钥名称 状态码： 400 表6 响应Body参数
API描述 run_env_id String 发布的环境ID id String API编号 req_uri String API的请求地址 状态码： 400 表6 响应Body参数 参数 参数类型 描述 error_code String 错误码 error_msg String
String 域名编号 domain String 访问域名 cname_status Integer 域名cname状态： 1：未解析 2：解析中 3：解析成功 4：解析失败 ssl_id String SSL证书编号 ssl_name String SSL证书名称 min_ssl_version
识别和查找。 编码格式 默认“utf-8”格式。 集成应用 选择数据源所归属的集成应用。 描述 填写数据源的描述信息。 连接地址 填写SNMP的连接IP地址和端口号。 网络协议 选择SNMP所使用的网络协议，可选择“UDP”和“TCP”。 版本号 选择SNMP的版本号。 0：表示SNMPv1
API描述 run_env_id String 发布的环境id id String API编号 req_uri String API的请求地址 tags Array of strings API绑定的标签，标签配额默认10条，可以联系技术调整。 最小长度：1 最大长度：128 数组长度：0
数据集成组合任务 源数据库重启等操作对组合任务是否有影响？ 如何修复意外重启等原因导致的XStream模式Oracle CDC功能异常？ 父主题： 数据集成
方案概述 应用现状 在数字化转型过程中，一些大型企业的业务系统数据格式多样化，难以在业务系统间形成有效信息传输。如何实现多种数据类型之间灵活、快速的数据集成和转换，成为企业数字化转型所面临的重要问题。 比如企业中不同业务系统数据的存储格式、存储位置各不相同，当一个业务系统需要获取
大量时间，进一步增加道路交通压力。 交通部门无法实时掌握城市停车位使用情况，难以针对停车问题制定有效的交通缓解措施。 解决方案 本章节介绍如何通过ROMA Connect对传统停车场的管理系统进行数字化改造，实现停车场车辆进出、计费、停车位状态的智能化管理。 停车场车位感应设备和进出门闸设备通过设备集成连接到ROMA
MQS连接开发（开源客户端） Java客户端使用说明 Python客户端使用说明 Go客户端使用说明 C#客户端使用说明 其他语言客户端使用说明 附录：如何提高消息处理效率 附录：spring-kafka对接限制 父主题： 消息集成开发指导
API描述 run_env_id String 发布的环境ID id String API编号 req_uri String API的请求地址 type Integer API类型 throttle_apply_id String 与流控策略的绑定关系编号 throttle_name
API描述 run_env_id String 发布的环境ID id String API编号 req_uri String API的请求地址 type Integer API类型 throttle_apply_id String 与流控策略的绑定关系编号 throttle_name
ReadLine() return data } 示例代码中的参数说明，可参考获取MQS连接信息获取参数值。 brokers：MQS连接地址和端口。 topics：要生产消息的Topic名称。 user和password：开启SASL_SSL认证时所使用的用户名和密码。 caF
endpoint为https://{rest_connect_address}:9292，通过指定实例接口查询rest_connect_address的IP地址。 URI POST /v1/topic/{topic_name}/group/{group_name}/messages 表1 参数说明
BOTH：同时支持HTTP和HTTPS 缺省值：HTTPS req_method String API的请求方式 req_uri String 请求地址。可以包含请求参数，用{}标识，比如/getUserInfo/{userId}，支持 * / %- _ .等特殊字符，总长度不超过512，且满足URI规范。
BOTH：同时支持HTTP和HTTPS 缺省值：HTTPS req_method String API的请求方式 req_uri String 请求地址。可以包含请求参数，用{}标识，比如/getUserInfo/{userId}，支持 * / %- _ .等特殊字符，总长度不超过512，且满足URI规范。
集成应用 选择1中所创建的集成应用。 描述 填写MQS数据源的描述信息。 连接地址 选择当前ROMA Connect实例的“消息集成 MQS内网连接地址”，您可以在ROMA Connect控制台的实例信息页面查看该地址。 是否SSL 仅当ROMA Connect实例的“MQS SASL_
"SHA256-RSA", "create_time" : "2021-08-20T02:03:53Z", "update_time" : "2021-08-20T02:03:53Z", "algorithm_type" : "RSA" } 状态码： 400 Bad Request
DEPRECATED：废弃版本，后续可能会删除。 updated Number API版本发布UTC时间。 links links object API版本URL地址。 表3 links 参数 参数类型 描述 rel String 用途。 href String 该用途的URL。 请求示例 无 响应示例
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
