检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
RabbitMqProducer类说明 路径 com.roma.apic.livedata.client.v1.RabbitMqProducer 说明 生产RabbitMQ消息。若发送消息没有异常,则消息发送成功;若发送消息抛出异常,则消息发送失败。 使用示例 用direct交换
最大值:9999999999999 remarks String 执行详细信息。 最小长度:1 最大长度:256 step_begin_time Integer 本次步骤启动时间,格式timestamp(ms),使用UTC时区。 最小值:1 最大值:9999999999999 step_end_time Integer
2:共享,表示绑定到流控策略的所有API流控时间内能够被调用多少次。 enable_adaptive_control String 是否开启动态流控: TRUE FALSE 暂不支持 user_call_limits Integer 用户流量限制是指一个API在时长之内每一个用户
附录:API的Swagger扩展定义 ROMA Connect在Swagger原有定义的基础上,定义了特有的API定义项,即扩展定义,如认证方式、后端服务定义等。本章节主要介绍API使用的扩展定义。 1:x-apigateway-auth-type 含义:基于Swagger的apiKey认证格式,定义ROMA
MD5Encoder类说明 路径 com.huawei.livedata.lambdaservice.util.MD5Encoder 说明 计算Md5值。 方法列表 返回类型 方法和说明 static String md5(String source) 计算字符串的Md5值 方法详情
1分钟一次)的任务执行时间存在5-6分钟波动,导致单次任务执行时间会覆盖多次调度计划。建议先停止所有数据集成任务,等待规格变更完成后再重新启动任务。 如果定时任务正好在规格变更过程中调度时,部分调度日志显示时间可能比用户制定的调度时间晚2-3分钟,为正常现象,属于Quartz补偿调度任务机制影响。
开启日志分析。 在“日志分析”页签单击“配置访问日志”。 在配置访问日志弹窗配置日志接入信息,完成后单击“确定”。 表1 配置访问日志 参数 说明 启动日志记录 选择是否启用日志记录,仅启用后才能查看API的调用日志。 日志组 选择日志流所在的日志组。 如果没有可选的日志组,单击“查看日志
附录:API的Swagger扩展定义 ROMA Connect在Swagger原有定义的基础上,定义了特有的API定义项,即扩展定义,如认证方式、后端服务定义等。本章节主要介绍API使用的扩展定义。 1:x-apigateway-auth-type 含义:基于Swagger的apiKey认证格式,定义ROMA
除等操作。 任务监控管理 任务监控相关API,可查询任务的运行信息。 任务管理 数据集成任务相关API,包括任务的创建、修改、查询、删除、启动等操作。 服务集成API API分组管理 API分组相关API,包括分组的创建、修改、查询、删除等操作。 API管理 API管理相关API
开启日志分析。 在“日志分析”页签单击“配置访问日志”。 在配置访问日志弹窗配置日志接入信息,完成后单击“确定”。 表1 配置访问日志 参数 配置说明 启动日志记录 选择是否启用日志记录,仅启用后才能查看API的调用日志。 日志组 选择日志流所在的日志组。 如果没有可选的日志组,单击“查看日志
查看组合应用监控 本章节指导您如何查看组合应用的监控信息。 查看监控 登录新版ROMA Connect控制台。 在左侧导航栏选择“组合应用”,在组合应用页面单击要查看监控的组合应用。 在组合应用详情页面,选择“监控”页签。 根据需要,可查看组合应用流任务的“运行监控”、“耗时监控”和“失败次数监控”的监控数据。
JSON2XMLHelper类说明 路径 com.huawei.livedata.util.JSON2XMLHelper 说明 提供Json与Xml之间的相互转换。 方法列表 返回类型 方法和说明 static String JSON2XML(String json, boolean
Capture),即数据变更抓取,通过为源端数据源开启CDC,ROMA Connect可实现数据源的实时数据同步以及数据表的物理删除同步。 本章节主要介绍如何为MySQL数据库开启Binlog模式CDC功能。 前提条件 不支持采集二进制类型的字段,例如:TINYBLOB、BLOB、MEDIUMBLOB、LONGBLOB。
Connect,会导致部分消息之间的生产顺序无法保证,存在消息乱序的问题。 此方案适用于对端到端时延有要求,却对消息顺序不敏感的业务。 迁移流程 启动新的消费客户端,配置Kafka连接地址为ROMA Connect实例的消息集成MQS连接地址,消费ROMA Connect实例中的数据。
2:共享,表示绑定到流控策略的所有API流控时间内能够被调用多少次。 enable_adaptive_control String 是否开启动态流控: TRUE FALSE 暂不支持 user_call_limits Integer 用户流量限制是指一个API在时长之内每一个用户
起点以新版ROMA Connect实例创建成功的时间点为准,终点以实例删除时间点的小时整点为准。 新版ROMA Connect实例从创建到启动需要一定时长,计费的起点是创建成功的时间点,而非创建时间。 计费示例 假设您在2023/10/16 9:30:00创建成功了一个按需计费的新版ROMA
realtime (实时) timing (定时) 最小长度:1 最大长度:10 status String 任务状态。 stop (停止\未启动) running (运行中) 最小值:0 最大值:1 project_id String 项目ID。 最小长度:1 最大长度:64 source_datasource_id
the Creating, Starting or Restarting state cannot be deleted. 实例状态为创建中、启动中、停止中、重启中时不允许执行删除操作。 请检查实例状态。 400 MQS.00400100 The number of instance
s Studio)可以通过订阅Kafka或MRS Kafka获取消息,并根据实际需要选择是否执行数据抽取任务。 本章节介绍任务执行完成后,如何配置消息发送,如果不需要发送消息可不配置。 前提条件 已经在对应的应用下创建Kafka和MRS Kafka数据源,数据源创建参考接入Kafka数据源和接入MRS
配置源端数据信息 概述 本节主要提供数据集成任务源端信息的配置说明。源端信息用于告诉ROMA Connect如何从源端获取待集成的数据,包括数据源、数据格式、数据范围等。对于不同的数据源类型,其源端信息配置有所差异。 支持“定时”模式的源端数据类型 支持“实时”模式的源端数据类型