检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
0-SNAPSHOT.jar & 以MQS数据源作为源端,MySQL作为目标端为例创建实时任务。 参考创建数据集成任务(普通任务)接入源端MQS数据源和目标端MySQL数据源,并创建实时任务。完成后运行任务,可以将源端MQS数据源中的数据,迁移到MySQL数据源的表中。 父主题: 数据集成开发指导
表3 请求Body参数 参数 是否必选 参数类型 描述 task_name 是 String 任务名称,只能以字母、数字为开头,包含字母、数字和 . _ - 3~100个字符。 最小长度:3 最大长度:100 task_id 否 String 任务ID,可以为空。 最小长度:3 最大长度:50
alue值非必填,自定义后端函数使用config_value值需要包含证书public_key(必填),私钥private_key(必填)和密码passphrase(非必填),格式如:"{\"public_key\": ",\"private_key\":\"\",\"passphrase\":\"\"}"
描述 name 是 String 数据字段名称。 type 是 String 字段值类型。支持的类型有:String,Integer,Date和Long。 format 否 String 数据的格式化字符串。当字段值为Date类型时,需要填写该值,用于描述字符串的格式。 path 是
构造一个无参数的HttpClient。 方法列表 com.roma.apic.livedata.client.v1.HttpClient 返回类型 方法和说明 okhttp3.Response request(HttpConfig config) 用于发送rest请求 okhttp3.Response
TaskBasicRequestBody 参数 是否必选 参数类型 描述 task_name 是 String 任务名称,只能以字母、数字为开头,包含字母、数字和 . _ - 3~100个字符。 最小长度:3 最大长度:100 task_type 是 String 任务类型。 REALTIME (实时)
expire_logs_days为Binlog日志文件保留时间,超过保留时间的Binlog日志会被自动删除,应保留至少2天的日志文件。 “gtid_mode = on”和“enforce_gtid_consistency = on”仅当MySQL的版本大于等于5.6.5时才需要添加,否则删除这两行内容。 按“
AppCodeBaseInfo 参数 参数类型 描述 app_code String App Code值 支持英文,+_!@#$%+/=,且只能以英文和+、/开头。 最小长度:64 最大长度:180 id String 编号 app_id String 应用编号 create_time String
app_quota_id String 客户端配额编号 app_quota_name String 配额名称。支持汉字,英文,数字,下划线,且只能以英文和汉字开头,3-255字符 bound_time String 绑定时间 状态码: 400 表6 响应Body参数 参数 参数类型 描述 error_code
app_quota_id String 客户端配额编号 app_quota_name String 配额名称。支持汉字,英文,数字,下划线,且只能以英文和汉字开头,3-255字符 bound_time String 绑定时间 状态码: 400 表6 响应Body参数 参数 参数类型 描述 error_code
请求Body参数 参数 是否必选 参数类型 描述 acl_name 是 String ACL策略名称。支持汉字,英文,数字,下划线,且只能以英文和汉字开头,3 ~ 64字符。 说明: 中文字符必须为UTF-8或者unicode编码。 acl_type 是 String 类型 PERMIT
最大长度:36 error_msg String 错误描述。 最小长度:2 最大长度:512 请求示例 修改指定数据集成组合任务,操作类型修改为插入和更新,并同步已有数据 { "description" : "test" } 响应示例 状态码: 400 Bad Request { "error_code"
插件绑定编码。 plugin_id String 插件编码。 plugin_name String 插件名称。支持汉字,英文,数字,下划线,且只能以英文和汉字开头,3-255字符 说明: 中文字符必须为UTF-8或者unicode编码。 plugin_type String 插件类型 cors:跨域资源共享
插件绑定编码。 plugin_id String 插件编码。 plugin_name String 插件名称。支持汉字,英文,数字,下划线,且只能以英文和汉字开头,3-255字符 说明: 中文字符必须为UTF-8或者unicode编码。 plugin_type String 插件类型 cors:跨域资源共享
rabbitMqConfig) 构造一个RabbitMQ消息生产者。 参数:rabbitMqConfig表示RabbitMQ的配置信息。 方法列表 返回类型 方法和说明 void produceWithDirectExchange(String routingKey, String props, String
描述 plugin_id String 插件编码。 plugin_name String 插件名称。支持汉字,英文,数字,下划线,且只能以英文和汉字开头,3-255字符。 说明: 中文字符必须为UTF-8或者unicode编码。 plugin_type String 插件类型 cors:跨域资源共享
输入动作描述。 新增动作完成后,配置动作参数。 表4 动作参数说明 参数 说明 输入参数 配置输入参数,可配置“Query”、“Header”和“Path”三种类型的输入参数。 参数名:输入参数名。 参数展示名:输入参数展示名。 类型:选择参数类型,可选择“string”、“integer”、“number”。
描述 plugin_id String 插件编码。 plugin_name String 插件名称。支持汉字,英文,数字,下划线,且只能以英文和汉字开头,3-255字符。 说明: 中文字符必须为UTF-8或者unicode编码。 plugin_type String 插件类型 cors:跨域资源共享
描述 plugin_id String 插件编码。 plugin_name String 插件名称。支持汉字,英文,数字,下划线,且只能以英文和汉字开头,3-255字符。 说明: 中文字符必须为UTF-8或者unicode编码。 plugin_type String 插件类型 cors:跨域资源共享
流量限制值。输入的值不超过2147483647。正整数。 name String 流控策略名称。支持汉字,英文,数字,下划线,且只能以英文和汉字开头,3 ~ 64字符。 说明: 中文字符必须为UTF-8或者unicode编码。 time_unit String 流控的时间单位 remark