检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
timeout:读取超时时间,最大值为30000毫秒,建议timeout设置值小于前端API的“后端超时”时间值 maxItems:读取消息的最大数量 返回信息 Kafka已消费的消息数组,消息数组即将多条消息的内容组成一个数组 父主题: 自定义后端开发(函数后端)
连接数据库的用户密码。 描述 填写连接器的描述信息,用于识别不同的连接器。 支持的动作 获取数据库变更 实时获取数据库变更 ,需要在数据库中启动LogMiner。 配置参数 表1 获取数据库变更 参数 说明 表名 填写或者选择要获取数据变更的数据表名。 数据库操作 选择数据库变更的操作。 父主题: 触发器
rule_express String 完整的规则表达式。 最小长度:0 最大长度:2000 created_user CreatedUser object 创建时的用户。 last_updated_user LastUpdatedUser object 最后更新时的用户。 created_datetime
rule_express String 完整的规则表达式。 最小长度:0 最大长度:2000 created_user CreatedUser object 创建时的用户。 last_updated_user LastUpdatedUser object 最后更新时的用户。 created_datetime
instance_id 是 String 实例ID。 group 是 String 消费组ID。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 [数组元素] Array of ShowGroupResp objects 查询实例集群的消费组信息成功。 表3 ShowGroupResp
是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。 表3 请求Body参数 参数 是否必选 参数类型 描述 sql 否 String 需要检测的SQL。 最小长度:1
es 表1 路径参数 参数 是否必选 参数类型 描述 instance_id 是 String 实例ID。 project_id 是 String 项目ID,获取方式请参见API参考的“附录 > 获取项目ID”章节。 请求参数 表2 请求Header参数 参数 是否必选 参数类型
2022-07-19 优化“查询API指标统计值”的“cycle”参数描述。 2021-07-31 上线API的应用示例。 2021-07-20 公共资源API中新增“查询实例列表”接口。 2021-01-06 补充API接口的权限和授权项说明。 2021-01-04 上线V2版本数据集成API和设备集成API。
选择项目。 实例 选择实例,用于后续验证连通性。 连接与安全 选择数据库的连接模式。当前支持“默认”模式,由系统根据用户配置自动拼接数据源连接字符串。 主机IP地址 填写数据库的连接IP地址。 端口 填写数据库的连接端口号。 数据库名 填写要连接的数据库名。 用户名 连接数据库的用户名。
是否必选 参数类型 描述 direction_type 是 String 数据源所在任务位置。 SOURCE 数据源处于任务源端 TARGET 数据源处于任务目标端 最小长度:0 最大长度:6 db_name 否 String 数据库名称,只支持MRSHIVE类型的数据源。 最小长度:0
表1 参数说明 名称 类型 是否必填 描述 project_id string 是 租户每个区域对应的项目ID。 instance_id string 是 租户使用ROMA Connect的实例ID。 请求消息 请求参数 表2 Body参数 参数 类型 是否必填 说明 product_name
rue表示自动删除。自动删除的前提是至少有一个队列或者交换器与该交换器绑定,之后所有与该交换器绑定的队列或者交换器都会解绑。 internal表示是否为内置交换器,true表示是内置的交换器。客户端程序无法直接发送消息到这个交换器,只能通过交换器路由到这个交换器。 arguments表示其他属性。
组合应用可进行应用的复合集成,通过开放的API和事件通道进行应用的多次组装,形成新的组合应用,实现业务快速复制创新。 本章节通过以组合应用的方式开放一个接口为例(当访问这个接口的时候,系统返回“hello world”),帮助您快速熟悉ROMA Connect组合应用的使用过程。 使用ROMA
消息集成MQS是ROMA Connect的消息集成组件,使用统一的消息接入机制,提供跨网络访问的安全、标准化消息通道。使用ROMA Connect进行消息集成,有如下优势: 支持原生Kafka特性 兼容社区版Kafka的API,具备原生Kafka的所有消息处理特性。 支持安全的消息传输 独有的安全加
project_id string 是 租户每个区域对应的项目ID。 instance_id string 是 租户使用ROMA Connect的实例ID。 请求消息 请求参数 无 请求示例 https://example.cloud.com/v1/80e2b******f4a398d640
/dbname。 用户名 连接数据库的用户名。 密码 连接数据库的用户密码。 描述 填写连接器的描述信息,用于识别不同的连接器。 支持的动作 获取记录 添加记录 更新记录 删除记录 配置参数 表1 获取记录 参数 说明 表名 要查询的数据库中的表名。 列名 数据表中列名。 WHERE条件
表名存在乱码导致Camel访问数据库失败 原因分析 访问数据库使用参数不正确,导致组合任务启动失败,任务终止。 解决方案 检查数据库中是否有表名存在乱码的情况,如果存在请和数据库管理员沟通后删除乱码表名的表,然后重新启动任务。 父主题: 数据集成组合任务
参数类型 描述 dict_id 是 String 字典ID。 instance_id 是 String 实例ID。 project_id 是 String 项目ID,获取方式请参见API参考的“附录 > 获取项目ID”章节。 请求参数 表2 请求Header参数 参数 是否必选 参数类型
计费FAQ ROMA Connect实例支持变更计费模式吗? 购买RCU时套餐包,当月未使用完的RCU时下个月是否可以继续使用?
bject-Token的值)。 最小长度:1 最大长度:100000 表3 请求Body参数 参数 是否必选 参数类型 描述 destination_type 是 Integer 操作类型,枚举值:0-目标端为ROMA实例MQS;1-目标端为本ROMA实例内FI KAFKA数据源;