代码拉取完成,页面将自动刷新
# 来源数据源配置
source:
# 来源url
url: jdbc:mysql://101.37.152.195:3306/data_warehouse?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai&useSSL=false
# 账号
username: root
# 密码
password: lzq199528
# 数据库(mongo)
dbName: data_warehouse
# 数据库类型 mongo mysql sqlServer
dbType: mysql
# 表
table:
- user
field:
- pid
# 目标表
target:
# 目标url(只能是postgresql)
url: jdbc:postgresql://101.37.152.195:5432/data_warehouse
# 账号
username: sonar
# 密码
password: sonar
# 目标表
table: user_2
# 目标表主键
pkNames: id
field:
- id
# datax配置
datax:
# 写JOB前置sql
preSql:
- SELECT 1
# 写JOB后置sql
postSql:
- SELECT 2
- SELECT 3
# 写JOB销毁时sql
destroySql:
- DROP TABLE IF EXISTS tmp_user_2
# 设置异常条数 按数量
errorRecord: 5000
# 设置异常条数 按比例
errorPercentage: 0
# flink配置
flink:
# kafka TOPIC 前缀
kafkaPrefix: lx@
# 删除的表
delTable: DEL_USER_2
# 设置异常条数 按数量
errorRecord: 1
# 设置异常条数 按比例
errorPercentage: 0
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。