正在生成
详细信息:
检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
端创建函数后端和数据后端时,涉及函数脚本或数据库执行语句的编写开发。 函数后端:创建函数后端时需要编写函数脚本,进行函数功能开发,ROMA Connect提供了部分Java类函数供用户直接使用。 数据后端:创建数据后端时需要编写执行语句,用于对数据源进行操作。 后端服务签名校验开发:若API在ROMA
创建数据集成任务(普通任务) 配置任务基本信息 配置源端数据信息 配置目标端数据信息 配置数据映射规则 配置异常数据存储(可选) 配置任务完成后执行(可选) 父主题: 数据集成指导
默认“utf-8”格式。 集成应用 选择数据源所归属的集成应用。 描述 填写数据源的描述信息。 连接地址 填写Redis的连接地址和端口号。如果有多个连接地址,可单击“添加地址”添加。 说明: 如果Redis数据源为集群版Redis,需要把全部节点地址都写上。如果只写一个节点地址,ROMA
API分组名称 roma_app_id 否 String 集成应用编号 precise_search 否 String 指定需要精确匹配查找的参数名称,多个参数需要支持精确匹配时参数之间使用“,”隔开。 当前支持name,domain_name。 domain_name 否 String 域名
欠费金额”查看,华为云将在您充值时自动扣取欠费金额。 如果您在宽限期内仍未支付欠款,那么就会进入保留期,资源状态变为“已冻结”,您将无法对处于保留期的按需计费资源执行任何操作。 保留期到期后,若您仍未支付账户欠款,那么实例将被释放,数据无法恢复。 图1 按需计费ROMA Connect资源生命周期 华为
start_datetime Integer 调度计划的执行开始时间,上限2147512447000,下限946684800000。 最小值:0 最大值:99999999999999999 period String 调度计划执行周期的时间单位,当使用cron表达式时,为空。 MIN
sub:拥有订阅权限。 tag 否 String 标签列表,权限类型对应的标签。 当权限类型是all时,发布和订阅的标签用符号“&”隔开。 当有多个标签时,标签用符号“||”隔开。 规则:仅能包含数字、字母、中划线(-)、下划线(_),长度不超过48。 响应参数 状态码: 400 表5
支持英文,数字,特殊字符(-_.) 暂不支持 最小长度:3 最大长度:64 precise_search 否 String 指定需要精确匹配查找的参数名称,多个参数需要支持精确匹配时参数之间使用“,”隔开。 目前支持name,member_group_name。 member_host 否 String
定义规则:单击“”编辑匹配条件表达式。若表达式数量大于等于3个,可通过“转子层级”对表达式进行分层设置。 =:等于 !=:不等于 pattern:正则表达式 enum:枚举值,多个参数值之间用英文逗号分隔 单击“确定”,完成插件策略的创建。 插件策略创建后,您还需要为API绑定插件策略,才能使插件策略对API生效。 为API绑定插件策略
error_details String 具体错误消息。 request_id String 请求处理ID。 请求示例 批量删除集成资产,删除多个集成应用和数据集成任务。 { "apps" : [ { "id" : "b1e6b1e6-4f3f-4a80-bb45-f4b9039f95a3"
任务管理 创建普通任务 查询任务列表 统计不同类型不同状态任务数量 更新普通任务 查询指定任务的信息 删除指定任务 手工触发单个任务 手工停止当前执行的任务 创建调度计划 查询调度计划 修改调度计划 批量启动或停止任务 创建组合任务 初始化组合任务 修改组合任务 重置组合任务进度 创建组合任务映射
"sign_id" : "0b0e8f456b8742218af75f945307173c", "sign_name" : "signature_demo", "sign_key" : "a071a20d460a4f639a636c3d7e3d8163", "sign_secret"
是否为创建Topic时所选择的应用。 默认为false。 tag 否 String 权限类型对应的标签。 当权限类型是all时,发布和订阅的标签用符号“&”隔开。 当有多个标签时,标签用符号“||”隔开。 响应参数 状态码: 400 表6 响应Body参数 参数 参数类型 描述 error_code String
该问题是debezium当前版本的一个BUG,需要用户升级MySQL。 对于组合任务,可以尝试通过修改配置的方法规避,首先删除此表的配置,启动任务后会跳过这些数据,等任务执行成功后,再将表配置回来重新采集。 父主题: 数据集成组合任务
error_details String 具体错误消息。 request_id String 请求处理ID。 请求示例 批量导出集成资产,导出多个集成应用和数据集成任务。 POST https://{endpoint}/v2/{project_id}/instances/{insta
run_env_name String 发布的环境名称 存在多个发布记录时,环境名称之间用|隔开 run_env_id String 发布的环境编号 存在多个发布记录时,环境编号之间用|隔开 publish_id String 发布记录编号 存在多个发布记录时,发布记录编号之间用|隔开 publish_time
最大长度:64 表7 VpcHealthConfig 参数 是否必选 参数类型 描述 protocol 是 String 使用以下协议,对VPC中主机执行健康检查: TCP HTTP HTTPS path 否 String 健康检查时的目标路径。protocol = http或https时必选
Connect实例控制台的“实例信息”页面,在“MQS基本信息”下查看Kafka版本信息。C#开源客户端的版本使用请参见客户端版本使用建议。 执行以下命令下载安装C#的Kafka依赖库。 dotnet add package -v 1.5.2 Confluent.Kafka 生产消息
Connect实例控制台的“实例信息”页面,在“MQS基本信息”下查看Kafka版本信息。Python开源客户端的版本使用请参见客户端版本使用建议。 执行以下命令,安装对应版本的Python Kafka客户端: pip install kafka-python==2.0.1 生产消息 SASL认证方式
最大长度:64 表7 VpcHealthConfig 参数 是否必选 参数类型 描述 protocol 是 String 使用以下协议,对VPC中主机执行健康检查: TCP HTTP HTTPS path 否 String 健康检查时的目标路径。protocol = http或https时必选