检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
数据库 MySQL Redis DB2 GaussDB DWS Milvus Oracle PostgreSQL Sql Server 父主题： 连接器
\"sourceDatasourceType\":\"MYSQL\",\"taskType\":2,\"sourceDatasource\":\"mysql\",\"targetDatasourceType\":\"MYSQL\",\"mappingSourceTextOrNot
Jira Software 定时器 ArtemisMQ RabbitMQ 事件网格 QQ邮箱 IBM MQ Kafka MySQL Oracle PostgreSQL Sql Server 父主题： 连接器
后端API配额 scripts String 脚本配额 datasource_used String 已使用的数据源数量 api_used String 已使用的后端API数量 状态码： 400 表4 响应Body参数 参数 参数类型 描述 error_code String 错误码 error_msg
config = new DataSourceConfig() config.setType("mysql") config.setUrl("jdbc:mysql://127.0.0.1:3306/db?allowPublicKeyRetrieval=true")
创建数据集成任务（组合任务） 配置Oracle CDC（LogMiner） 配置Oracle CDC（XStream） 配置MySQL CDC（Binlog） 配置SQL Server CDC 创建组合任务 父主题： 数据集成指导
0-SNAPSHOT.jar & 以MQS数据源作为源端，MySQL作为目标端为例创建实时任务。 参考创建数据集成任务（普通任务）接入源端MQS数据源和目标端MySQL数据源，并创建实时任务。完成后运行任务，可以将源端MQS数据源中的数据，迁移到MySQL数据源的表中。 父主题： 数据集成开发指导
KafkaConsumer(config) var records = consumer.consume(topic, 5000, 10); var res = [] var iter = records.iterator() while (iter.hasNext())
数据源为FTP配置。 batch_num 否 Integer 迁移数量。 是否解析(is_parse)如果选择了是，表示解析的数据行数，最大值为1500000。 是否解析(is_parse)如果选择了否，表示文件数量，最大值为20000 数据源为FTP配置。 skip_header
约束与限制 您能创建的ROMA Connect资源数量与配额有关系，具体请参见配额说明。 更详细的限制请参见具体API的说明。 父主题： 使用前必读
Name：数据视图名称，自定义。 Index pattern：使用通配符形式匹配多个日志索引，例如“site_access_log_*”，表示匹配以site_access_log_开头的所有日志索引文件。 日志索引的名称格式为site_access_log_{es_index_name}_{current_date
", "source_ds_type" : "MYSQL", "ext_info" : { "server_id" : 1665647763438 }, "target_ds_type" : "MYSQL", "total" : 1, "source_group"
接入FI Hive数据源 接入MySQL数据源 接入MongoDB数据源 接入MRS Hive数据源 接入MRS HBase数据源 接入FI HBase数据源 接入Oracle数据源 接入SQL Server数据源 接入DAMENG数据源 接入POSTGRESQL数据源 接入SFTP数据源
配额说明 配额限制 配额是指用户在ROMA Connect实例中可创建的资源数量限制，具体的资源配额限制如下表所示。 在高并发情况下会出现略超最大配额数限制的情况，不影响资源的正常使用。 表1 实例资源配额限制 组件 资源 最大配额（个） 是否支持修改配额 集成应用 集成应用 100
单次批量删除产品最大数量不能超过: {0} 减少单次批量删除产品的数量。 500 ROMA.00110013 The maximum number of devices to be deleted at a time cannot exceed {0}. 单次批量删除设备最大数量不能超过:
"enterprise_project_id" : "0", "source_datasource_type" : "MYSQL", "target_datasource_type" : "MYSQL", "source_instance_name" : "roma-z00617033-not-delete"
zrangebyscore/zrevrangebyscore zrange/zrevrange 键：有序集合的名称。 值：元素的成员值。 分数：元素的分数。 起始索引：分数最小值。 终止索引：分数最大值。 集合 srem sismember srandmember spop sadd 键：集合的名称。 值：元素的成员值。
消费者端 根据实际业务需求，合理增加消费者个数（消费并发度），建议消费者数量和分区数保持一致。 提高消费者的消费速度，通过优化消费者处理逻辑（减少复杂计算、第三方接口调用和读库操作），减少消费时间。 增加消费者每次拉取消息的数量：拉取数据/处理时间 >= 生产速度。 生产者端 生产消息
Unit，ROMA计算单元）数量和使用时长计费。具体内容如表2所示。 表2 新版ROMA Connect计费项 计费项 计费项说明 适用的计费模式 计费公式 RCU ROMA计量单元，根据购买的RCU数量和使用时长计费。 按需计费、套餐包计费 RCU数量*RCU单价*购买时长 RCU时套餐包单价*购买时长
var config = new DataSourceConfig() config.setType("mysql") config.setUrl("jdbc:mysql://127.0.0.1:3306/db?allowPublicKeyRetrieval=true")
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
