datax使记录

简介
https://github.com/alibaba/DataX
DataX 是阿里云 DataWorks数据集成 的开源版本,在阿里巴巴集团内被广泛使用的离线数据同步工具/平台。DataX 实现了包括 MySQL、Oracle、OceanBase、SqlServer、Postgre、HDFS、Hive、ADS、HBase、TableStore(OTS)、MaxCompute(ODPS)、Hologres、DRDS 等各种异构数据源之间高效的数据同步功能。

文章目录

  • 1、下载datax
  • 2、下载python2.7
  • 3、测试datax安装是否正确
  • 4、测试datax
    • (1) stream -> stream
    • (2) oracle->mysql
    • (3)测试oracle 和 mysql上不同时间格式能否正确导入
    • (4)测试数据导入速度,mysql导入oracle

1、下载datax

http://datax-opensource.oss-cn-hangzhou.aliyuncs.com/datax.tar.gz

2、下载python2.7

https://www.python.org/ftp/python/2.7/python-2.7.msi
安装之后设置环境变量




打开cmd窗口测试是否安装成功

3、测试datax安装是否正确

进到安装目录bin,执行以下命令

D:\softwares\datax\bin>python datax.py ../job/myTest.json

报如下错

经百度,找到了解决办法,https://blog.51cto.com/u_13372349/5319772

删除
D:\softwares\datax\plugin\reader
D:\softwares\datax\plugin\writer
下的隐藏文件解决了问题

4、测试datax

(1) stream -> stream

在D:\softwares\datax\job 文件夹下新建一个json文件
stream2stream.json,文件内容如下

{"job": {"content": [{"reader": {"name": "streamreader","parameter": {"sliceRecordCount": 10,"column": [{"type": "long","value": "10"},{"type": "string","value": "hello,DataX"}]}},"writer": {"name": "streamwriter","parameter": {"encoding": "UTF-8","print": true}}}],"setting": {"speed": {"channel": 1}}} }

控制台执行命令

D:\softwares\datax\bin>python datax.py ../job/stream2stream.json

执行日志如下

DataX (DATAX-OPENSOURCE-3.0), From Alibaba !
Copyright (C) 2010-2017, Alibaba Group. All Rights Reserved.2022-12-22 10:35:44.537 [main] INFO  VMInfo - VMInfo# operatingSystem class => sun.management.OperatingSystemImpl
2022-12-22 10:35:44.545 [main] INFO  Engine - the machine info  =>osInfo: Oracle Corporation 1.8 25.221-b11jvmInfo:        Windows 10 amd64 10.0cpu num:        6totalPhysicalMemory:    -0.00GfreePhysicalMemory:     -0.00GmaxFileDescriptorCount: -1currentOpenFileDescriptorCount: -1GC Names        [PS MarkSweep, PS Scavenge]MEMORY_NAME                    | allocation_size                | init_sizePS Eden Space                  | 256.00MB                       | 256.00MBCode Cache                     | 240.00MB                       | 2.44MBCompressed Class Space         | 1,024.00MB                     | 0.00MBPS Survivor Space              | 42.50MB                        | 42.50MBPS Old Gen                     | 683.00MB                       | 683.00MBMetaspace                      | -0.00MB                        | 0.00MB2022-12-22 10:35:44.562 [main] INFO  Engine -
{"content":[{"reader":{"name":"streamreader","parameter":{"column":[{"type":"long","value":"10"},{"type":"string","value":"hello,DataX"}],"sliceRecordCount":10}},"writer":{"name":"streamwriter","parameter":{"encoding":"UTF-8","print":true}}}],"setting":{"speed":{"channel":1}}
}2022-12-22 10:35:44.581 [main] WARN  Engine - prioriy set to 0, because NumberFormatException, the value is: null
2022-12-22 10:35:44.584 [main] INFO  PerfTrace - PerfTrace traceId=job_-1, isEnable=false, priority=0
2022-12-22 10:35:44.585 [main] INFO  JobContainer - DataX jobContainer starts job.
2022-12-22 10:35:44.586 [main] INFO  JobContainer - Set jobId = 0
2022-12-22 10:35:44.604 [job-0] INFO  JobContainer - jobContainer starts to do prepare ...
2022-12-22 10:35:44.605 [job-0] INFO  JobContainer - DataX Reader.Job [streamreader] do prepare work .
2022-12-22 10:35:44.605 [job-0] INFO  JobContainer - DataX Writer.Job [streamwriter] do prepare work .
2022-12-22 10:35:44.605 [job-0] INFO  JobContainer - jobContainer starts to do split ...
2022-12-22 10:35:44.606 [job-0] INFO  JobContainer - Job set Channel-Number to 1 channels.
2022-12-22 10:35:44.608 [job-0] INFO  JobContainer - DataX Reader.Job [streamreader] splits to [1] tasks.
2022-12-22 10:35:44.609 [job-0] INFO  JobContainer - DataX Writer.Job [streamwriter] splits to [1] tasks.
2022-12-22 10:35:44.626 [job-0] INFO  JobContainer - jobContainer starts to do schedule ...
2022-12-22 10:35:44.629 [job-0] INFO  JobContainer - Scheduler starts [1] taskGroups.
2022-12-22 10:35:44.631 [job-0] INFO  JobContainer - Running by standalone Mode.
2022-12-22 10:35:44.641 [taskGroup-0] INFO  TaskGroupContainer - taskGroupId=[0] start [1] channels for [1] tasks.
2022-12-22 10:35:44.645 [taskGroup-0] INFO  Channel - Channel set byte_speed_limit to -1, No bps activated.
2022-12-22 10:35:44.646 [taskGroup-0] INFO  Channel - Channel set record_speed_limit to -1, No tps activated.
2022-12-22 10:35:44.659 [taskGroup-0] INFO  TaskGroupContainer - taskGroup[0] taskId[0] attemptCount[1] is started
10      hello,DataX
10      hello,DataX
10      hello,DataX
10      hello,DataX
10      hello,DataX
10      hello,DataX
10      hello,DataX
10      hello,DataX
10      hello,DataX
10      hello,DataX
2022-12-22 10:35:44.762 [taskGroup-0] INFO  TaskGroupContainer - taskGroup[0] taskId[0] is successed, used[104]ms
2022-12-22 10:35:44.763 [taskGroup-0] INFO  TaskGroupContainer - taskGroup[0] completed it's tasks.
2022-12-22 10:35:54.658 [job-0] INFO  StandAloneJobContainerCommunicator - Total 10 records, 130 bytes | Speed 13B/s, 1 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 0.000s |  All Task WaitReaderTime 0.000s | Percentage 100.00%
2022-12-22 10:35:54.658 [job-0] INFO  AbstractScheduler - Scheduler accomplished all tasks.
2022-12-22 10:35:54.659 [job-0] INFO  JobContainer - DataX Writer.Job [streamwriter] do post work.
2022-12-22 10:35:54.659 [job-0] INFO  JobContainer - DataX Reader.Job [streamreader] do post work.
2022-12-22 10:35:54.660 [job-0] INFO  JobContainer - DataX jobId [0] completed successfully.
2022-12-22 10:35:54.661 [job-0] INFO  HookInvoker - No hook invoked, because base dir not exists or is a file: D:\softwares\datax\hook
2022-12-22 10:35:54.662 [job-0] INFO  JobContainer -[total cpu info] =>averageCpu                     | maxDeltaCpu                    | minDeltaCpu-1.00%                         | -1.00%                         | -1.00%[total gc info] =>NAME                 | totalGCCount       | maxDeltaGCCount    | minDeltaGCCount    | totalGCTime        | maxDeltaGCTime     | minDeltaGCTimePS MarkSweep         | 0                  | 0                  | 0                  | 0.000s             | 0.000s             | 0.000sPS Scavenge          | 0                  | 0                  | 0                  | 0.000s             | 0.000s             | 0.000s2022-12-22 10:35:54.662 [job-0] INFO  JobContainer - PerfTrace not enable!
2022-12-22 10:35:54.662 [job-0] INFO  StandAloneJobContainerCommunicator - Total 10 records, 130 bytes | Speed 13B/s, 1 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 0.000s |  All Task WaitReaderTime 0.000s | Percentage 100.00%
2022-12-22 10:35:54.663 [job-0] INFO  JobContainer -
任务启动时刻                    : 2022-12-22 10:35:44
任务结束时刻                    : 2022-12-22 10:35:54
任务总计耗时                    :                 10s
任务平均流量                    :               13B/s
记录写入速度                    :              1rec/s
读出记录总数                    :                  10
读写失败总数                    :                   0

(2) oracle->mysql

在D:\softwares\datax\job 文件夹下新建一个json文件
orcl2mysql.json,文件内容如下


{"job": {"content": [{"reader": {"name": "oraclereader","parameter": {"column": ["*"],"connection": [{"jdbcUrl": ["jdbc:oracle:thin:@localhost:1521:orcl"],"table": ["zx_mobile_temp"]}],"password": "xxx","username": "GL"}},"writer": {"name": "mysqlwriter","parameter": {"column": ["*"],"connection": [{"jdbcUrl": "jdbc:mysql://localhost:3306/test","table": ["zx_mobile_temp"]}],"password": "xxx","username": "root","writeMode": "insert"}}}],"setting": {"speed": {"channel": "1"}}}
}

控制台执行如下命令

D:\softwares\datax\bin>python datax.py ../job/orcl2mysql.json

执行日志如下

DataX (DATAX-OPENSOURCE-3.0), From Alibaba !
Copyright (C) 2010-2017, Alibaba Group. All Rights Reserved.2022-12-22 10:50:59.340 [main] INFO  VMInfo - VMInfo# operatingSystem class => sun.management.OperatingSystemImpl
2022-12-22 10:50:59.348 [main] INFO  Engine - the machine info  =>osInfo: Oracle Corporation 1.8 25.221-b11jvmInfo:        Windows 10 amd64 10.0cpu num:        6totalPhysicalMemory:    -0.00GfreePhysicalMemory:     -0.00GmaxFileDescriptorCount: -1currentOpenFileDescriptorCount: -1GC Names        [PS MarkSweep, PS Scavenge]MEMORY_NAME                    | allocation_size                | init_size              PS Eden Space                  | 256.00MB                       | 256.00MB               Code Cache                     | 240.00MB                       | 2.44MB                 Compressed Class Space         | 1,024.00MB                     | 0.00MB                 PS Survivor Space              | 42.50MB                        | 42.50MB                PS Old Gen                     | 683.00MB                       | 683.00MB               Metaspace                      | -0.00MB                        | 0.00MB                 2022-12-22 10:50:59.365 [main] INFO  Engine -
{"content":[{"reader":{"name":"oraclereader","parameter":{"column":["*"],"connection":[{"jdbcUrl":["jdbc:oracle:thin:@localhost:1521:orcl"],"table":["zx_mobile_temp"]}],"password":"******","username":"GL"}},"writer":{"name":"mysqlwriter","parameter":{"column":["*"],"connection":[{"jdbcUrl":"jdbc:mysql://localhost:3306/test","table":["zx_mobile_temp"]}],"password":"******","username":"root","writeMode":"insert"}}}],"setting":{"speed":{"channel":"1"}}
}2022-12-22 10:50:59.383 [main] WARN  Engine - prioriy set to 0, because NumberFormatException, the value is: null
2022-12-22 10:50:59.385 [main] INFO  PerfTrace - PerfTrace traceId=job_-1, isEnable=false, priority=0
2022-12-22 10:50:59.385 [main] INFO  JobContainer - DataX jobContainer starts job.
2022-12-22 10:50:59.386 [main] INFO  JobContainer - Set jobId = 0
2022-12-22 10:51:04.642 [job-0] INFO  OriginalConfPretreatmentUtil - Available jdbcUrl:jdbc:oracle:thin:@localhost:1521:orcl.
2022-12-22 10:51:04.644 [job-0] WARN  OriginalConfPretreatmentUtil - 您的配置文件中的列配置存在一定的风险. 因为您未配置读取数据库表的列,当您的表字段个数、类型有变动时,可能影响任务正确性甚至会 运行出错。请检查您的配置并作出修改.
2022-12-22 10:51:04.856 [job-0] INFO  OriginalConfPretreatmentUtil - table:[zx_mobile_temp] all columns:[
mobile
].
2022-12-22 10:51:04.856 [job-0] WARN  OriginalConfPretreatmentUtil - 您的配置文件中的列配置信息存在风险. 因为您配置的写入数据库表的列为*,当您的表字段个数、类型有变动时,可能影响任务正确性甚至会运行出错。请检查您的配置并作出修改.
2022-12-22 10:51:04.860 [job-0] INFO  OriginalConfPretreatmentUtil - Write data [
insert INTO %s (mobile) VALUES(?)
], which jdbcUrl like:[jdbc:mysql://localhost:3306/test?yearIsDateType=false&zeroDateTimeBehavior=convertToNull&tinyInt1isBit=false&rewriteBatchedStatements=true]
2022-12-22 10:51:04.861 [job-0] INFO  JobContainer - jobContainer starts to do prepare ...
2022-12-22 10:51:04.861 [job-0] INFO  JobContainer - DataX Reader.Job [oraclereader] do prepare work .
2022-12-22 10:51:04.861 [job-0] INFO  JobContainer - DataX Writer.Job [mysqlwriter] do prepare work .
2022-12-22 10:51:04.862 [job-0] INFO  JobContainer - jobContainer starts to do split ...
2022-12-22 10:51:04.862 [job-0] INFO  JobContainer - Job set Channel-Number to 1 channels.
2022-12-22 10:51:04.866 [job-0] INFO  JobContainer - DataX Reader.Job [oraclereader] splits to [1] tasks.
2022-12-22 10:51:04.866 [job-0] INFO  JobContainer - DataX Writer.Job [mysqlwriter] splits to [1] tasks.
2022-12-22 10:51:04.879 [job-0] INFO  JobContainer - jobContainer starts to do schedule ...
2022-12-22 10:51:04.882 [job-0] INFO  JobContainer - Scheduler starts [1] taskGroups.
2022-12-22 10:51:04.884 [job-0] INFO  JobContainer - Running by standalone Mode.
2022-12-22 10:51:04.891 [taskGroup-0] INFO  TaskGroupContainer - taskGroupId=[0] start [1] channels for [1] tasks.
2022-12-22 10:51:04.895 [taskGroup-0] INFO  Channel - Channel set byte_speed_limit to -1, No bps activated.
2022-12-22 10:51:04.895 [taskGroup-0] INFO  Channel - Channel set record_speed_limit to -1, No tps activated.
2022-12-22 10:51:04.906 [taskGroup-0] INFO  TaskGroupContainer - taskGroup[0] taskId[0] attemptCount[1] is started
2022-12-22 10:51:04.911 [0-0-0-reader] INFO  CommonRdbmsReader$Task - Begin to read record by Sql: [select * from zx_mobile_temp
] jdbcUrl:[jdbc:oracle:thin:@localhost:1521:orcl].
2022-12-22 10:51:04.971 [0-0-0-reader] INFO  CommonRdbmsReader$Task - Finished read record by Sql: [select * from zx_mobile_temp
] jdbcUrl:[jdbc:oracle:thin:@localhost:1521:orcl].
2022-12-22 10:51:05.227 [taskGroup-0] INFO  TaskGroupContainer - taskGroup[0] taskId[0] is successed, used[322]ms
2022-12-22 10:51:05.228 [taskGroup-0] INFO  TaskGroupContainer - taskGroup[0] completed it's tasks.
2022-12-22 10:51:14.904 [job-0] INFO  StandAloneJobContainerCommunicator - Total 6 records, 66 bytes | Speed 6B/s, 0 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 0.000s |  All Task WaitReaderTime 0.044s | Percentage 100.00%
2022-12-22 10:51:14.905 [job-0] INFO  AbstractScheduler - Scheduler accomplished all tasks.
2022-12-22 10:51:14.905 [job-0] INFO  JobContainer - DataX Writer.Job [mysqlwriter] do post work.
2022-12-22 10:51:14.905 [job-0] INFO  JobContainer - DataX Reader.Job [oraclereader] do post work.
2022-12-22 10:51:14.905 [job-0] INFO  JobContainer - DataX jobId [0] completed successfully.
2022-12-22 10:51:14.906 [job-0] INFO  HookInvoker - No hook invoked, because base dir not exists or is a file: D:\softwares\datax\hook
2022-12-22 10:51:14.907 [job-0] INFO  JobContainer -[total cpu info] =>averageCpu                     | maxDeltaCpu                    | minDeltaCpu    -1.00%                         | -1.00%                         | -1.00%[total gc info] =>NAME                 | totalGCCount       | maxDeltaGCCount    | minDeltaGCCount    | totalGCTime        | maxDeltaGCTime     | minDeltaGCTimePS MarkSweep         | 0                  | 0                  | 0                  | 0.000s             | 0.000s             | 0.000sPS Scavenge          | 0                  | 0                  | 0                  | 0.000s             | 0.000s             | 0.000s2022-12-22 10:51:14.907 [job-0] INFO  JobContainer - PerfTrace not enable!
2022-12-22 10:51:14.908 [job-0] INFO  StandAloneJobContainerCommunicator - Total 6 records, 66 bytes | Speed 6B/s, 0 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 0.000s |  All Task WaitReaderTime 0.044s | Percentage 100.00%
2022-12-22 10:51:14.909 [job-0] INFO  JobContainer -
任务启动时刻                    : 2022-12-22 10:50:59
任务结束时刻                    : 2022-12-22 10:51:14
任务总计耗时                    :                 15s
任务平均流量                    :                6B/s
记录写入速度                    :              0rec/s
读出记录总数                    :                   6
读写失败总数                    :                   0

(3)测试oracle 和 mysql上不同时间格式能否正确导入

oracle数据库建表

create table date_test(time1 date,time2 timestamp
);

并插入数据

mysql数据库建表

create table date_test1(time1 datetime,time2 timestamp
);create table date_test2(time1 timestamp,time2 datetime
);

先让oracle date_test同步到 mysql date_test1
执行完毕后mysql date_test1表数据如下

因此
1、date->datetime √
2、timestamp->timestamp √

然后让oracle date_test同步到 mysql date_test2
执行完毕后mysql date_test1表数据如下

因此
1、date->timestamp √
2、timestamp->datetime√

(4)测试数据导入速度,mysql导入oracle

数据准备

create table student
(s_id    int  not nullprimary key auto_increment,s_name  varchar(16)  null,s_birth varchar(16)  null,s_age   varchar(2)   null,s_sex   char         null,s_img   varchar(128) null,create_time timestamp not null default now()
);create function createName()RETURNS varchar(3)
BEGINDECLARE LN VARCHAR(4000);DECLARE MN VARCHAR(4000);DECLARE FN VARCHAR(4000);DECLARE LN_N INT;DECLARE MN_N INT;DECLARE FN_N INT;SET LN = '赵钱孙李周吴郑王冯陈褚卫蒋沈韩杨朱秦尤许吕施张孔曹严华金魏陶姜戚谢邹喻柏水窦章云苏潘葛奚范彭郎鲁韦昌马苗凤花方俞任袁柳酆鲍史唐费廉岑薛雷贺倪汤滕殷罗毕郝邬安常乐于时傅皮卞齐康伍余元卜顾孟平黄和穆萧尹段';SET MN = '的一是在不了有和人这中大为上个国我以要他时来用们生到作地于出就分对成会可主发年动同工也能下过子说产种面而方后多定行学法所民得经十三之进着等部度家电力里如水化高自二理起小物现实加量都两体制机当使点从业本去把性好应开它合还因由其些然前外天政四日那社义事平形相全表间样与关各重新线内数正心反你明看原又么利比或但质气第向道命此变条只没结解问意建月公无系军很情者最立代想已通并提直题党程展五果料象员革位入常文总次品式活设及管特件长求老头基资边流路级少图山统接知较长将组见计别她手角期根论运农指几九区强放决西被干做必战先回则任取据处队南给色光门即保治北造百规热领七海地口东导器压志世金增争济阶油思术极交受联什认六共权收证改清已美再采转更单风切打白教速花带安场身车例真务具万每目至达走积示议声报斗完类八离华名确才科张信马节话米整空元况今集温传土许步群广石记需段研界拉林律叫且究观越织装影算低持音众书布复容儿须际商非验连断深难近矿千周委素技备半办青省列习响约支般史感劳便团往酸历市克何除消构府称太准精值号率族维划选标写存候毛亲快效斯院查江型眼王按格养易置派层片始却专状育厂京识适属圆包火住调满县局照参红细引听该铁价严首底液官德调随病苏失尔死讲配女黄推显谈罪神艺呢席含企望密批营项防举球英氧势告李台落木帮轮破亚师围注远字材排供河态封另施减树溶怎止案言士均武固叶鱼波视仅费紧爱左章早朝害续轻服试食充兵源判护司足某练差致板田降黑犯负击范继兴似余坚曲输修的故城夫够送笔船占右财吃富春职觉汉画功巴跟虽杂飞检吸助升阳互初创抗考投坏策古径换未跑留钢曾端责站简述钱副尽帝射草冲承独令限阿宣环双请超微让控州良轴找否纪益依优顶础载倒房突坐粉敌略客袁冷胜绝析块剂测丝协重诉念陈仍罗盐友洋错苦夜刑移频逐靠混母短皮终聚汽村云哪既距卫停烈央察烧行迅境若印洲刻括激孔搞甚室待核校散侵吧甲游久菜味旧模湖货损预阻毫普稳乙妈植息扩银语挥酒守拿序纸医缺雨吗针刘啊急唱误训愿审附获茶鲜粮斤孩脱硫肥善龙演父渐血欢械掌歌沙著刚攻谓盾讨晚粒乱燃矛乎杀药宁鲁贵钟煤读班伯香介迫句丰培握兰担弦蛋沉假穿执答乐谁顺烟缩征脸喜松脚困异免背星福买染井概慢怕磁倍祖皇促静补评翻肉践尼衣宽扬棉希伤操垂秋宜氢套笔督振架亮末宪庆编牛触映雷销诗座居抓裂胞呼娘景威绿晶厚盟衡鸡孙延危胶还屋乡临陆顾掉呀灯岁措束耐剧玉赵跳哥季课凯胡额款绍卷齐伟蒸殖永宗苗川炉岩弱零杨奏沿露杆探滑镇饭浓航怀赶库夺伊灵税了途灭赛归召鼓播盘裁险康唯录菌纯借糖盖横符私努堂域枪润幅哈竟熟虫泽脑壤碳欧遍侧寨敢彻虑斜薄庭都纳弹饲伸折麦湿暗荷瓦塞床筑恶户访塔奇透梁刀旋迹卡氯遇份毒泥退洗摆灰彩卖耗夏择忙铜献硬予繁圈雪函亦抽篇阵阴丁尺追堆雄迎泛爸楼避谋吨野猪旗累偏典馆索秦脂潮爷豆忽托惊塑遗愈朱替纤粗倾尚痛楚谢奋购磨君池旁碎骨监捕弟暴割贯殊释词亡壁顿宝午尘闻揭炮残冬桥妇警综招吴付浮遭徐您摇谷赞箱隔订男吹乐园纷唐败宋玻巨耕坦荣闭湾键凡驻锅救恩剥凝碱齿截炼麻纺禁废盛版缓净睛昌婚涉筒嘴插岸朗庄街藏姑贸腐奴啦惯乘伙恢匀纱扎辩耳彪臣亿璃抵脉秀萨俄网舞店喷纵寸汗挂洪着贺闪柬爆烯津稻墙软勇像滚厘蒙芳肯坡柱荡腿仪旅尾轧冰贡登黎削钻勒逃障氨郭峰币港伏轨亩毕擦莫刺浪秘援株健售股岛甘泡睡童铸汤阀休汇舍牧绕炸哲磷绩朋淡尖启陷柴呈徒颜泪稍忘泵蓝拖洞授镜辛壮锋贫虚弯摩泰幼廷尊窗纲弄隶疑氏宫姐震瑞怪尤琴循描膜违夹腰缘珠穷森枝竹沟催绳忆邦剩幸浆栏拥牙贮礼滤钠纹弹罢拍咱喊袖埃勤罚焦潜伍墨欲缝姓刊饱仿奖铝鬼丽跨默挖链扫喝袋炭污幕诸弧励梅奶洁灾舟鉴苯讼抱毁率懂寒智埔寄届跃渡挑丹艰贝碰拔爹戴码梦芽熔赤渔哭敬颗奔藏铅熟仲虎稀妹乏珍申桌遵允隆螺仓魏锐晓氮兼隐碍赫拨忠肃缸牵抢博巧壳兄杜讯诚碧祥柯页巡矩悲灌龄伦票寻桂铺圣恐恰郑趣抬荒腾贴柔滴猛阔辆妻填撤储签闹扰紫砂递戏吊陶伐喂疗瓶婆抚臂摸忍虾蜡邻胸巩挤偶弃槽劲乳邓吉仁烂砖租乌舰伴瓜浅丙暂燥橡柳迷暖牌纤秧胆详簧踏瓷谱呆宾糊洛辉愤竞隙怒粘乃绪肩籍敏涂熙皆侦悬掘享纠醒狂锁淀恨牲霸爬赏逆玩陵祝秒浙貌役彼悉鸭着趋凤晨畜辈秩卵署梯炎滩棋驱筛峡冒啥寿译浸泉帽迟硅疆贷漏稿冠嫩胁芯牢叛蚀奥鸣岭羊凭串塘绘酵融盆锡庙筹冻辅摄袭筋拒僚旱钾鸟漆沈眉疏添棒穗硝韩逼扭侨凉挺碗栽炒杯患馏劝豪辽勃鸿旦吏拜狗埋辊掩饮搬骂辞勾扣估蒋绒雾丈朵姆拟宇辑陕雕偿蓄崇剪倡厅咬驶薯刷斥番赋奉佛浇漫曼扇钙桃扶仔返俗亏腔鞋棱覆框悄叔撞骗勘旺沸孤粘吐孟渠屈疾妙惜仰狠胀谐抛霉桑岗嘛衰盗渗脏赖涌甜曹阅肌哩厉烃纬毅昨伪症煮叹钉搭茎笼酷偷弓锥恒杰坑鼻翼纶叙狱逮罐络棚抑膨蔬寺骤穆冶枯册尸凸绅坯牺焰轰欣晋瘦御锭锦丧旬锻垄搜佛扑邀亭酯迈舒脆酶闲忧酚顽羽涨卸仗陪薄辟惩杭姚肚捉飘漂昆欺吾郎烷汁呵饰萧雅邮迁燕撒姻赴宴烦削债帐斑铃旨醇董饼雏姿拌傅腹妥揉贤拆歪葡胺丢浩徽昂垫挡览贪慰缴汪慌冯诺姜谊凶劣诬耀昏躺盈骑乔溪丛卢抹易闷咨刮驾缆悟摘铒掷颇幻柄惠惨佳仇腊窝涤剑瞧堡泼葱罩霍捞胎苍滨俩捅湘砍霞邵萄疯淮遂熊粪烘宿档戈驳嫂裕徙箭捐肠撑晒辨殿莲摊搅酱屏疫哀蔡堵沫皱畅叠阁莱敲辖钩痕坝巷饿祸丘玄溜曰逻彭尝卿妨艇吞韦怨矮歇郊禄捻漠粹颠宏冤肪饥呵仙押挨醛娃拾没佩勿吓讹侯恋夕锌篡戚淋蓬岂釉兆泊魂拘亡杠摧氟颂浑凌铀诱犁谴颁舶扯嘉萌犹滋焊舌匹媳肺掠酿烹疲驰鸦窄辱狭朴遣菲奸韧辣拳秆卧醉竭茅墓矣哎艳敦舆缔雇尿葬履契禽渣衬躲赔咸溉贼醋堤抖妃裤廉晴挽掀茫丑亥拦悠阐慧佐奇竖孝柜麟绣遥逝愁肖昭芬逢窑捷圜盲闸宙辐披账狼幽绸蜂慎餐酬誓惟叉弥址帜芝砌唉仆涛臭翠盒劫慨炳阖寂椒倘拓畏喉巾颈垦拚兽蔽芦乾爽窃谭挣崩模褐传翅儒伞晃谬胚剖凑眠浊霜礁蔑抄闯洒碑蓉耶猜蹲壶唤澳锯郡玲绵纽梳掏吁锤鼠穴椅殷遮吵萍厌畜俱夸吕囊捧雌闽饶瞬郁哨凿朝俺浒茂肝勋盯籽耻菊滥稼戒奈帅鞭蚕镁询跌烤坛宅笛鄂蛮颤棍睁鼎岌降侍藩嚷匪岳糟缠迪泄卑氛堪萝盛碘缚悦澄甫攀屠溢拱晰携朽吟菱谦凹俊芒盼婶艘酰趁唇挫羞浴疼萎肴愚肿刨绞枢嫁慕舱铲苹豫谕迭潘顷翁榜匠欠茬畴胃沾踪弊哼鹏歧桐沃悼惑溃蔗荐潭孢露诊庸聪嫌厨庞祁钳肆梭赠崖篮颖甸藻捣且撕诏贞赐慈炕胖兹差琼锈汛卓棵馈挠灶婴蒂肤衫沥仑勉沪逸蜜浦嗓晕膏祭赢艾扮鹅怜蒲兔孕呖蘖挪淑谣惧廊缅俘骄膀陡宰诞峻恼腺猎涡夷愉魔铵葛贾似荫哟脊钞苛锰椭镶杏溴倚滞会氓捏斩傲匆僵卤烫衍榨拢裸屑咽坊舅渴翔邪拄窖猫砌钦媒脾勺柏栅噪昼耿扁辰秤得贩糕梁昙衷宦扔哇诈嘱藤卜冈悔廓皂拐氰杉玛矢寓瓣罕垮笋淘衔称恭喇帕桉秉帘铭蛇摔斋叭帆裸俭瘤篷砸肢辟脖瞪暑卜竿歼笙酮蕴哗瞎喀刃楔喘枚嵌挝厢粤甩拴膝恳腕娓熄锚忌愧哦荆圃骚丸蒜毯弗俯鹿梢屯衙轿贱垒谅踢哑滔渥饷泳棕熬搁腈梨吻樱奠捆姨柏聘惕郓绑冀裹酥寡彦稠啡钝汝擅汰鳙埔敞嘿逊栋谨咖鲤雀佣庵葫贿鳞拼搏谎塌忉腻戊怖坟禾刹嘻桔坎拇煽狮痒曾梗寇鹰烛哄莽雯胳龟亟糠泌坪傻什喻渊蚌跪巷涅钊譬蕊膛侮奕枕辫况扼郝寥凄厦腥钧耦蹄戥屁诵匈桩钓涵倦袍抒屿蹈忿敷虹聊嗣尉灿糙蹬嗯姬狡笨辜僧茨讽翰枉岐枣崭焚咕猴揽涝耍趟汹咋傍镀给爵虏劈璋踩瞅迄昔汞呱诡魄祺嘲惶赃癌咐歉扳鄙庐聂便芡躯贬煌拧隋襄淤宠炊滇謇懒栓佑憾骆裙猖兜孵痼盥曝泣絮韵眷旷噢参栖盏鳌溅煎校榴暮琪淆陛巢哒吼槐唧其沛乞蜀蜇赚捍铰幂尧咒耽叮褂焕煞雹搓釜铬拣募淹瑰鲢茄灼邹躬觉娇焉彰鹤琳沦畔惹庶毙皖邢禹渍绷窜翘淫箪陌膊鞑咳玫巫拂蕉澜赎绥锄囱赌颊缕寅躁稚庚苟氦魁珊蜕蛭酌逗闺蔓撇豌朕缉襟镍桅荧侄卒佃瞿娶饪耸乍靶痴靖扛筐韶嚣崔蓿岔氘娥剿霖喃搪雍裳撰豹骏慷';SET FN = '的一是在不了有和人这中大为上个国我以要他时来用们生到作地于出就分对成会可主发年动同工也能下过子说产种面而方后多定行学法所民得经十三之进着等部度家电力里如水化高自二理起小物现实加量都两体制机当使点从业本去把性好应开它合还因由其些然前外天政四日那社义事平形相全表间样与关各重新线内数正心反你明看原又么利比或但质气第向道命此变条只没结解问意建月公无系军很情者最立代想已通并提直题党程展五果料象员革位入常文总次品式活设及管特件长求老头基资边流路级少图山统接知较长将组见计别她手角期根论运农指几九区强放决西被干做必战先回则任取据处队南给色光门即保治北造百规热领七海地口东导器压志世金增争济阶油思术极交受联什认六共权收证改清已美再采转更单风切打白教速花带安场身车例真务具万每目至达走积示议声报斗完类八离华名确才科张信马节话米整空元况今集温传土许步群广石记需段研界拉林律叫且究观越织装影算低持音众书布复容儿须际商非验连断深难近矿千周委素技备半办青省列习响约支般史感劳便团往酸历市克何除消构府称太准精值号率族维划选标写存候毛亲快效斯院查江型眼王按格养易置派层片始却专状育厂京识适属圆包火住调满县局照参红细引听该铁价严首底液官德调随病苏失尔死讲配女黄推显谈罪神艺呢席含企望密批营项防举球英氧势告李台落木帮轮破亚师围注远字材排供河态封另施减树溶怎止案言士均武固叶鱼波视仅费紧爱左章早朝害续轻服试食充兵源判护司足某练差致板田降黑犯负击范继兴似余坚曲输修的故城夫够送笔船占右财吃富春职觉汉画功巴跟虽杂飞检吸助升阳互初创抗考投坏策古径换未跑留钢曾端责站简述钱副尽帝射草冲承独令限阿宣环双请超微让控州良轴找否纪益依优顶础载倒房突坐粉敌略客袁冷胜绝析块剂测丝协重诉念陈仍罗盐友洋错苦夜刑移频逐靠混母短皮终聚汽村云哪既距卫停烈央察烧行迅境若印洲刻括激孔搞甚室待核校散侵吧甲游久菜味旧模湖货损预阻毫普稳乙妈植息扩银语挥酒守拿序纸医缺雨吗针刘啊急唱误训愿审附获茶鲜粮斤孩脱硫肥善龙演父渐血欢械掌歌沙著刚攻谓盾讨晚粒乱燃矛乎杀药宁鲁贵钟煤读班伯香介迫句丰培握兰担弦蛋沉假穿执答乐谁顺烟缩征脸喜松脚困异免背星福买染井概慢怕磁倍祖皇促静补评翻肉践尼衣宽扬棉希伤操垂秋宜氢套笔督振架亮末宪庆编牛触映雷销诗座居抓裂胞呼娘景威绿晶厚盟衡鸡孙延危胶还屋乡临陆顾掉呀灯岁措束耐剧玉赵跳哥季课凯胡额款绍卷齐伟蒸殖永宗苗川炉岩弱零杨奏沿露杆探滑镇饭浓航怀赶库夺伊灵税了途灭赛归召鼓播盘裁险康唯录菌纯借糖盖横符私努堂域枪润幅哈竟熟虫泽脑壤碳欧遍侧寨敢彻虑斜薄庭都纳弹饲伸折麦湿暗荷瓦塞床筑恶户访塔奇透梁刀旋迹卡氯遇份毒泥退洗摆灰彩卖耗夏择忙铜献硬予繁圈雪函亦抽篇阵阴丁尺追堆雄迎泛爸楼避谋吨野猪旗累偏典馆索秦脂潮爷豆忽托惊塑遗愈朱替纤粗倾尚痛楚谢奋购磨君池旁碎骨监捕弟暴割贯殊释词亡壁顿宝午尘闻揭炮残冬桥妇警综招吴付浮遭徐您摇谷赞箱隔订男吹乐园纷唐败宋玻巨耕坦荣闭湾键凡驻锅救恩剥凝碱齿截炼麻纺禁废盛版缓净睛昌婚涉筒嘴插岸朗庄街藏姑贸腐奴啦惯乘伙恢匀纱扎辩耳彪臣亿璃抵脉秀萨俄网舞店喷纵寸汗挂洪着贺闪柬爆烯津稻墙软勇像滚厘蒙芳肯坡柱荡腿仪旅尾轧冰贡登黎削钻勒逃障氨郭峰币港伏轨亩毕擦莫刺浪秘援株健售股岛甘泡睡童铸汤阀休汇舍牧绕炸哲磷绩朋淡尖启陷柴呈徒颜泪稍忘泵蓝拖洞授镜辛壮锋贫虚弯摩泰幼廷尊窗纲弄隶疑氏宫姐震瑞怪尤琴循描膜违夹腰缘珠穷森枝竹沟催绳忆邦剩幸浆栏拥牙贮礼滤钠纹弹罢拍咱喊袖埃勤罚焦潜伍墨欲缝姓刊饱仿奖铝鬼丽跨默挖链扫喝袋炭污幕诸弧励梅奶洁灾舟鉴苯讼抱毁率懂寒智埔寄届跃渡挑丹艰贝碰拔爹戴码梦芽熔赤渔哭敬颗奔藏铅熟仲虎稀妹乏珍申桌遵允隆螺仓魏锐晓氮兼隐碍赫拨忠肃缸牵抢博巧壳兄杜讯诚碧祥柯页巡矩悲灌龄伦票寻桂铺圣恐恰郑趣抬荒腾贴柔滴猛阔辆妻填撤储签闹扰紫砂递戏吊陶伐喂疗瓶婆抚臂摸忍虾蜡邻胸巩挤偶弃槽劲乳邓吉仁烂砖租乌舰伴瓜浅丙暂燥橡柳迷暖牌纤秧胆详簧踏瓷谱呆宾糊洛辉愤竞隙怒粘乃绪肩籍敏涂熙皆侦悬掘享纠醒狂锁淀恨牲霸爬赏逆玩陵祝秒浙貌役彼悉鸭着趋凤晨畜辈秩卵署梯炎滩棋驱筛峡冒啥寿译浸泉帽迟硅疆贷漏稿冠嫩胁芯牢叛蚀奥鸣岭羊凭串塘绘酵融盆锡庙筹冻辅摄袭筋拒僚旱钾鸟漆沈眉疏添棒穗硝韩逼扭侨凉挺碗栽炒杯患馏劝豪辽勃鸿旦吏拜狗埋辊掩饮搬骂辞勾扣估蒋绒雾丈朵姆拟宇辑陕雕偿蓄崇剪倡厅咬驶薯刷斥番赋奉佛浇漫曼扇钙桃扶仔返俗亏腔鞋棱覆框悄叔撞骗勘旺沸孤粘吐孟渠屈疾妙惜仰狠胀谐抛霉桑岗嘛衰盗渗脏赖涌甜曹阅肌哩厉烃纬毅昨伪症煮叹钉搭茎笼酷偷弓锥恒杰坑鼻翼纶叙狱逮罐络棚抑膨蔬寺骤穆冶枯册尸凸绅坯牺焰轰欣晋瘦御锭锦丧旬锻垄搜佛扑邀亭酯迈舒脆酶闲忧酚顽羽涨卸仗陪薄辟惩杭姚肚捉飘漂昆欺吾郎烷汁呵饰萧雅邮迁燕撒姻赴宴烦削债帐斑铃旨醇董饼雏姿拌傅腹妥揉贤拆歪葡胺丢浩徽昂垫挡览贪慰缴汪慌冯诺姜谊凶劣诬耀昏躺盈骑乔溪丛卢抹易闷咨刮驾缆悟摘铒掷颇幻柄惠惨佳仇腊窝涤剑瞧堡泼葱罩霍捞胎苍滨俩捅湘砍霞邵萄疯淮遂熊粪烘宿档戈驳嫂裕徙箭捐肠撑晒辨殿莲摊搅酱屏疫哀蔡堵沫皱畅叠阁莱敲辖钩痕坝巷饿祸丘玄溜曰逻彭尝卿妨艇吞韦怨矮歇郊禄捻漠粹颠宏冤肪饥呵仙押挨醛娃拾没佩勿吓讹侯恋夕锌篡戚淋蓬岂釉兆泊魂拘亡杠摧氟颂浑凌铀诱犁谴颁舶扯嘉萌犹滋焊舌匹媳肺掠酿烹疲驰鸦窄辱狭朴遣菲奸韧辣拳秆卧醉竭茅墓矣哎艳敦舆缔雇尿葬履契禽渣衬躲赔咸溉贼醋堤抖妃裤廉晴挽掀茫丑亥拦悠阐慧佐奇竖孝柜麟绣遥逝愁肖昭芬逢窑捷圜盲闸宙辐披账狼幽绸蜂慎餐酬誓惟叉弥址帜芝砌唉仆涛臭翠盒劫慨炳阖寂椒倘拓畏喉巾颈垦拚兽蔽芦乾爽窃谭挣崩模褐传翅儒伞晃谬胚剖凑眠浊霜礁蔑抄闯洒碑蓉耶猜蹲壶唤澳锯郡玲绵纽梳掏吁锤鼠穴椅殷遮吵萍厌畜俱夸吕囊捧雌闽饶瞬郁哨凿朝俺浒茂肝勋盯籽耻菊滥稼戒奈帅鞭蚕镁询跌烤坛宅笛鄂蛮颤棍睁鼎岌降侍藩嚷匪岳糟缠迪泄卑氛堪萝盛碘缚悦澄甫攀屠溢拱晰携朽吟菱谦凹俊芒盼婶艘酰趁唇挫羞浴疼萎肴愚肿刨绞枢嫁慕舱铲苹豫谕迭潘顷翁榜匠欠茬畴胃沾踪弊哼鹏歧桐沃悼惑溃蔗荐潭孢露诊庸聪嫌厨庞祁钳肆梭赠崖篮颖甸藻捣且撕诏贞赐慈炕胖兹差琼锈汛卓棵馈挠灶婴蒂肤衫沥仑勉沪逸蜜浦嗓晕膏祭赢艾扮鹅怜蒲兔孕呖蘖挪淑谣惧廊缅俘骄膀陡宰诞峻恼腺猎涡夷愉魔铵葛贾似荫哟脊钞苛锰椭镶杏溴倚滞会氓捏斩傲匆僵卤烫衍榨拢裸屑咽坊舅渴翔邪拄窖猫砌钦媒脾勺柏栅噪昼耿扁辰秤得贩糕梁昙衷宦扔哇诈嘱藤卜冈悔廓皂拐氰杉玛矢寓瓣罕垮笋淘衔称恭喇帕桉秉帘铭蛇摔斋叭帆裸俭瘤篷砸肢辟脖瞪暑卜竿歼笙酮蕴哗瞎喀刃楔喘枚嵌挝厢粤甩拴膝恳腕娓熄锚忌愧哦荆圃骚丸蒜毯弗俯鹿梢屯衙轿贱垒谅踢哑滔渥饷泳棕熬搁腈梨吻樱奠捆姨柏聘惕郓绑冀裹酥寡彦稠啡钝汝擅汰鳙埔敞嘿逊栋谨咖鲤雀佣庵葫贿鳞拼搏谎塌忉腻戊怖坟禾刹嘻桔坎拇煽狮痒曾梗寇鹰烛哄莽雯胳龟亟糠泌坪傻什喻渊蚌跪巷涅钊譬蕊膛侮奕枕辫况扼郝寥凄厦腥钧耦蹄戥屁诵匈桩钓涵倦袍抒屿蹈忿敷虹聊嗣尉灿糙蹬嗯姬狡笨辜僧茨讽翰枉岐枣崭焚咕猴揽涝耍趟汹咋傍镀给爵虏劈璋踩瞅迄昔汞呱诡魄祺嘲惶赃癌咐歉扳鄙庐聂便芡躯贬煌拧隋襄淤宠炊滇謇懒栓佑憾骆裙猖兜孵痼盥曝泣絮韵眷旷噢参栖盏鳌溅煎校榴暮琪淆陛巢哒吼槐唧其沛乞蜀蜇赚捍铰幂尧咒耽叮褂焕煞雹搓釜铬拣募淹瑰鲢茄灼邹躬觉娇焉彰鹤琳沦畔惹庶毙皖邢禹渍绷窜翘淫箪陌膊鞑咳玫巫拂蕉澜赎绥锄囱赌颊缕寅躁稚庚苟氦魁珊蜕蛭酌逗闺蔓撇豌朕缉襟镍桅荧侄卒佃瞿娶饪耸乍靶痴靖扛筐韶嚣崔蓿岔氘娥剿霖喃搪雍裳撰豹骏慷';SET LN_N = CHAR_LENGTH(LN);SET MN_N = CHAR_LENGTH(MN);SET FN_N = CHAR_LENGTH(FN);RETURN CONCAT(substring(LN,CEIL(RAND()*LN_N),1),substring(MN,CEIL(RAND()*LN_N),1),substring(FN,CEIL(RAND()*FN_N),1));END;create procedure insertStudent(in sn int)
begindeclare i int;set i = 1;while i <= sn DOinsert intostudent(s_name, s_birth, s_sex,s_age,s_img)values(createName(),concat('199',convert(ceil(rand()*9),char(1)),'-',LPAD(convert(ceil(rand()*12),char(2)),2,'0'),'-',LPAD(convert(ceil(rand()*28),char(2)),2,'0')),if(rand()*2>1,'男','女'),ceil(rand()*28)+10,'https://plc.jj20.com/up/allimg/1114/040221103339/210402103339-7.jpg');set i=i+1;end while;
end;call insertStudent(10000000);

插入1000万条数据,耗时2 h 3 m 48 s 446 ms

oralce建表

create table student
(s_id        numberprimary key,s_name      varchar2(16)                         null,s_birth     varchar2(16)                         null,s_age       varchar2(2)                          null,s_sex       char(2)                              null,s_img       varchar2(128)                        null,create_time timestamp default sysdate not null
);

改脚本,同步数据

D:\softwares\datax\bin>python datax.py ../job/mysql2orcl.json

数据同步日志

DataX (DATAX-OPENSOURCE-3.0), From Alibaba !
Copyright (C) 2010-2017, Alibaba Group. All Rights Reserved.2022-12-22 14:21:23.243 [main] INFO  VMInfo - VMInfo# operatingSystem class => sun.management.OperatingSystemImpl
2022-12-22 14:21:23.259 [main] INFO  Engine - the machine info  =>osInfo: Oracle Corporation 1.8 25.221-b11jvmInfo:        Windows 10 amd64 10.0cpu num:        6totalPhysicalMemory:    -0.00GfreePhysicalMemory:     -0.00GmaxFileDescriptorCount: -1currentOpenFileDescriptorCount: -1GC Names        [PS MarkSweep, PS Scavenge]MEMORY_NAME                    | allocation_size                | init_size              PS Eden Space                  | 256.00MB                       | 256.00MB               Code Cache                     | 240.00MB                       | 2.44MB                 Compressed Class Space         | 1,024.00MB                     | 0.00MB                 PS Survivor Space              | 42.50MB                        | 42.50MB                PS Old Gen                     | 683.00MB                       | 683.00MB               Metaspace                      | -0.00MB                        | 0.00MB                 2022-12-22 14:21:23.274 [main] INFO  Engine -
{"content":[{"reader":{"name":"mysqlreader","parameter":{"column":["*"],"connection":[{"jdbcUrl":["jdbc:mysql://localhost:3306/test"],"table":["student"]}],"password":"******","username":"root"}},"writer":{"name":"oraclewriter","parameter":{"column":["*"],"connection":[{"jdbcUrl":"jdbc:oracle:thin:@localhost:1521:orcl","table":["student"]}],"password":"******","username":"GL"}}}],"setting":{"speed":{"channel":"1"}}
}2022-12-22 14:21:23.274 [main] WARN  Engine - prioriy set to 0, because NumberFormatException, the value is: null
2022-12-22 14:21:23.274 [main] INFO  PerfTrace - PerfTrace traceId=job_-1, isEnable=false, priority=0
2022-12-22 14:21:23.290 [main] INFO  JobContainer - DataX jobContainer starts job.
2022-12-22 14:21:23.290 [main] INFO  JobContainer - Set jobId = 0
2022-12-22 14:21:23.524 [job-0] INFO  OriginalConfPretreatmentUtil - Available jdbcUrl:jdbc:mysql://localhost:3306/test?yearIsDateType=false&zeroDateTimeBehavior=convertToNull&tinyInt1isBit=false&rewriteBatchedStatements=true.
2022-12-22 14:21:23.524 [job-0] WARN  OriginalConfPretreatmentUtil - 您的配置文件中的列配置存在一定的风险. 因为您未配置读取数据库表的列,当您的表字段个数、类型有变动时,可能影响任务正确性甚至会 运行出错。请检查您的配置并作出修改.
2022-12-22 14:21:28.742 [job-0] INFO  OriginalConfPretreatmentUtil - table:[student] all columns:[
S_ID,S_NAME,S_BIRTH,S_AGE,S_SEX,S_IMG,CREATE_TIME
].
2022-12-22 14:21:28.742 [job-0] WARN  OriginalConfPretreatmentUtil - 您的配置文件中的列配置信息存在风险. 因为您配置的写入数据库表的列为*,当您的表字段个数、类型有变动时,可能影响任务正确性甚至会运行出错。请检查您的配置并作出修改.
2022-12-22 14:21:28.742 [job-0] INFO  OriginalConfPretreatmentUtil - Write data [
INSERT INTO %s (S_ID,S_NAME,S_BIRTH,S_AGE,S_SEX,S_IMG,CREATE_TIME) VALUES(?,?,?,?,?,?,?)
], which jdbcUrl like:[jdbc:oracle:thin:@localhost:1521:orcl]
2022-12-22 14:21:28.742 [job-0] INFO  JobContainer - jobContainer starts to do prepare ...
2022-12-22 14:21:28.742 [job-0] INFO  JobContainer - DataX Reader.Job [mysqlreader] do prepare work .
2022-12-22 14:21:28.742 [job-0] INFO  JobContainer - DataX Writer.Job [oraclewriter] do prepare work .
2022-12-22 14:21:28.742 [job-0] INFO  JobContainer - jobContainer starts to do split ...
2022-12-22 14:21:28.742 [job-0] INFO  JobContainer - Job set Channel-Number to 1 channels.
2022-12-22 14:21:28.742 [job-0] INFO  JobContainer - DataX Reader.Job [mysqlreader] splits to [1] tasks.
2022-12-22 14:21:28.742 [job-0] INFO  JobContainer - DataX Writer.Job [oraclewriter] splits to [1] tasks.
2022-12-22 14:21:28.757 [job-0] INFO  JobContainer - jobContainer starts to do schedule ...
2022-12-22 14:21:28.757 [job-0] INFO  JobContainer - Scheduler starts [1] taskGroups.
2022-12-22 14:21:28.757 [job-0] INFO  JobContainer - Running by standalone Mode.
2022-12-22 14:21:28.773 [taskGroup-0] INFO  TaskGroupContainer - taskGroupId=[0] start [1] channels for [1] tasks.
2022-12-22 14:21:28.773 [taskGroup-0] INFO  Channel - Channel set byte_speed_limit to -1, No bps activated.
2022-12-22 14:21:28.773 [taskGroup-0] INFO  Channel - Channel set record_speed_limit to -1, No tps activated.
2022-12-22 14:21:28.773 [taskGroup-0] INFO  TaskGroupContainer - taskGroup[0] taskId[0] attemptCount[1] is started
2022-12-22 14:21:28.773 [0-0-0-reader] INFO  CommonRdbmsReader$Task - Begin to read record by Sql: [select * from student
] jdbcUrl:[jdbc:mysql://localhost:3306/test?yearIsDateType=false&zeroDateTimeBehavior=convertToNull&tinyInt1isBit=false&rewriteBatchedStatements=true].
2022-12-22 14:21:38.786 [job-0] INFO  StandAloneJobContainerCommunicator - Total 0 records, 0 bytes | Speed 0B/s, 0 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 0.000s |  All Task WaitReaderTime 0.000s | Percentage 0.00%
2022-12-22 14:21:58.800 [job-0] INFO  StandAloneJobContainerCommunicator - Total 1665728 records, 162130240 bytes | Speed 7.73MB/s, 83286 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 17.603s |  All Task WaitReaderTime 1.831s | Percentage 0.00%
2022-12-22 14:22:08.813 [job-0] INFO  StandAloneJobContainerCommunicator - Total 2433536 records, 237375424 bytes | Speed 7.18MB/s, 76780 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 26.292s |  All Task WaitReaderTime 2.600s | Percentage 0.00%
2022-12-22 14:22:18.826 [job-0] INFO  StandAloneJobContainerCommunicator - Total 3090944 records, 301801408 bytes | Speed 6.14MB/s, 65740 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 34.475s |  All Task WaitReaderTime 3.254s | Percentage 0.00%
2022-12-22 14:22:28.840 [job-0] INFO  StandAloneJobContainerCommunicator - Total 3840512 records, 375259072 bytes | Speed 7.01MB/s, 74956 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 44.850s |  All Task WaitReaderTime 3.988s | Percentage 0.00%
2022-12-22 14:22:38.852 [job-0] INFO  StandAloneJobContainerCommunicator - Total 4403712 records, 430452672 bytes | Speed 5.26MB/s, 56320 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 50.816s |  All Task WaitReaderTime 4.573s | Percentage 0.00%
2022-12-22 14:22:48.857 [job-0] INFO  StandAloneJobContainerCommunicator - Total 4708864 records, 460357568 bytes | Speed 2.85MB/s, 30515 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 63.728s |  All Task WaitReaderTime 4.890s | Percentage 0.00%
2022-12-22 14:22:58.859 [job-0] INFO  StandAloneJobContainerCommunicator - Total 5302784 records, 518561728 bytes | Speed 5.55MB/s, 59392 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 72.980s |  All Task WaitReaderTime 5.471s | Percentage 0.00%
2022-12-22 14:23:08.874 [job-0] INFO  StandAloneJobContainerCommunicator - Total 6167040 records, 603258816 bytes | Speed 8.08MB/s, 86425 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 81.839s |  All Task WaitReaderTime 6.311s | Percentage 0.00%
2022-12-22 14:23:18.878 [job-0] INFO  StandAloneJobContainerCommunicator - Total 6824448 records, 667684800 bytes | Speed 6.14MB/s, 65740 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 90.040s |  All Task WaitReaderTime 6.980s | Percentage 0.00%
2022-12-22 14:23:28.883 [job-0] INFO  StandAloneJobContainerCommunicator - Total 7387648 records, 722878400 bytes | Speed 5.26MB/s, 56320 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 100.412s |  All Task WaitReaderTime 7.514s | Percentage 0.00%
2022-12-22 14:23:38.887 [job-0] INFO  StandAloneJobContainerCommunicator - Total 8137216 records, 796336064 bytes | Speed 7.01MB/s, 74956 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 109.425s |  All Task WaitReaderTime 8.224s | Percentage 0.00%
2022-12-22 14:23:48.892 [job-0] INFO  StandAloneJobContainerCommunicator - Total 8794624 records, 860762048 bytes | Speed 6.14MB/s, 65740 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 117.580s |  All Task WaitReaderTime 8.848s | Percentage 0.00%
2022-12-22 14:23:55.985 [0-0-0-reader] INFO  CommonRdbmsReader$Task - Finished read record by Sql: [select * from student
] jdbcUrl:[jdbc:mysql://localhost:3306/test?yearIsDateType=false&zeroDateTimeBehavior=convertToNull&tinyInt1isBit=false&rewriteBatchedStatements=true].
2022-12-22 14:23:56.251 [taskGroup-0] INFO  TaskGroupContainer - taskGroup[0] taskId[0] is successed, used[147478]ms
2022-12-22 14:23:56.251 [taskGroup-0] INFO  TaskGroupContainer - taskGroup[0] completed it's tasks.
2022-12-22 14:23:58.906 [job-0] INFO  StandAloneJobContainerCommunicator - Total 10000000 records, 978888897 bytes | Speed 11.27MB/s, 120537 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 133.558s |  All Task WaitReaderTime 10.032s | Percentage 100.00%
2022-12-22 14:23:58.906 [job-0] INFO  AbstractScheduler - Scheduler accomplished all tasks.
2022-12-22 14:23:58.906 [job-0] INFO  JobContainer - DataX Writer.Job [oraclewriter] do post work.
2022-12-22 14:23:58.906 [job-0] INFO  JobContainer - DataX Reader.Job [mysqlreader] do post work.
2022-12-22 14:23:58.906 [job-0] INFO  JobContainer - DataX jobId [0] completed successfully.
2022-12-22 14:23:58.906 [job-0] INFO  HookInvoker - No hook invoked, because base dir not exists or is a file: D:\softwares\datax\hook
2022-12-22 14:23:58.906 [job-0] INFO  JobContainer -[total cpu info] =>averageCpu                     | maxDeltaCpu                    | minDeltaCpu    -1.00%                         | -1.00%                         | -1.00%[total gc info] =>NAME                 | totalGCCount       | maxDeltaGCCount    | minDeltaGCCount    | totalGCTime        | maxDeltaGCTime     | minDeltaGCTimePS MarkSweep         | 1                  | 1                  | 1                  | 0.022s             | 0.022s             | 0.022sPS Scavenge          | 80                 | 80                 | 80                 | 0.153s             | 0.153s             | 0.153s2022-12-22 14:23:58.906 [job-0] INFO  JobContainer - PerfTrace not enable!
2022-12-22 14:23:58.906 [job-0] INFO  StandAloneJobContainerCommunicator - Total 10000000 records, 978888897 bytes | Speed 6.22MB/s, 66666 records/s | Error 0 records, 0 bytes |  All Task WaitWriterTime 133.558s |  All Task WaitReaderTime 10.032s | Percentage 100.00%
2022-12-22 14:23:58.906 [job-0] INFO  JobContainer -
任务启动时刻                    : 2022-12-22 14:21:23
任务结束时刻                    : 2022-12-22 14:23:58
任务总计耗时                    :                155s
任务平均流量                    :            6.22MB/s
记录写入速度                    :          66666rec/s
读出记录总数                    :            10000000
读写失败总数                    :                   0

1000万条数据总共用时 155s,真的快

参考https://blog.csdn.net/prefect_start/article/details/126335662

windows上datax的使用记录相关推荐

  1. 用简单命令查看Windows上USB盘使用记录

    已经有很多文章描述如何查找注册表里边的USB盘使用记录,但用regedit 查找有所不便,下载相关程序又担心中病毒.本人写了一个简单的命令来做这个查询: 只需要打开命令行窗口(Win + R,输入 c ...

  2. windows上的LLVM pass瞎折腾记录

    windows上的LLVM pass瞎折腾记录 想了解下LLVM的代码风格和优化过程,就从写LLVM pass入手吧,做个踩坑记录- 文章最后有逐步骤的操作记录,Tips内记录关键点和思路 Tips: ...

  3. WSL安装Oracle,折腾记录:WSL(Windows Subsystem for Linux,Windows上的Linux子系统)安装后的环境配置-Go语言中文社区...

    WSL(Windows Subsystem for Linux,Windows上的Linux子系统)的安装比较简单,教程网上较多,此处略过.安装后须要进行一系列配置(如软件源配置.中文配置.图形化配置 ...

  4. Jenkins简介及在Windows上的简单使用示例

    Jenkins是一款开源CI(Continuous Integration,持续集成)&CD(Continuous Delivery,持续交付)软件,用于自动化各种任务,包括构建.测试和部署软 ...

  5. 御用导航官方网站提醒提示页_电脑上使用便签记录工作计划如何设置闹钟定时提醒?...

    平常工作日程事务比较多时,就很容易忘掉一些工作,这个时候很多工作族会选择经常使用的电脑工具来记录每日的工作计划,电脑如何设置闹钟定时提醒工作计划呢? 电脑便签可以用来记录工作计划闹钟定时提醒的软件,建 ...

  6. windows mysql 主从_mysql读写分离实战二-windows 上mysql主从数据库搭建及问题总结

    根据前篇web项目的搭建后,需要搭建主从数据库,这里在windows服务器上搭建了主从结构的mysql,这里在记录下在本机模拟搭建过程 在windows上安装和linux还是有些不同,不注意就会耽误不 ...

  7. PHP 1:在Windows上安装和配置PHP,Apache和My SQL

    PHP 1:在Windows上安装和配置PHP,Apache和My SQL 原文:PHP 1:在Windows上安装和配置PHP,Apache和My SQL 如果你Google一把类似的主题,你会发现 ...

  8. java 中window_教你如何在windows上安装Java

    最近够倒霉的,电脑硬盘坏了,重新做了个系统,各种环境全都没了,/(ㄒoㄒ)/~~ 然后我发现自己在重新安装各种环境的时候,有些东西竟然还需要去查,所以决定把这些环境的配置都写成博客记录下来. 今天就教 ...

  9. Windows上安装JDK

    Windows上安装JDK Windows上安装JDK 题外话 什么是JDK JRE 和 JDK 的区别是什么? 下载JDK并安装 设置环境变量 新建 JAVA_HOME 新建 CLASSPATH 编 ...

最新文章

  1. XML和实体类之间相互转换(序列化和反序列化)
  2. 【机器学习】PyCaret!又一个神仙的自动机器学习库!
  3. 内存不足而没有OutOfMemoryError
  4. [Python2.x] 标准库 urllib2 的使用细节
  5. qstring去掉特定字符_如何花式、批量且操作简单地处理字符?
  6. LeetCode 665. 非递减数列(双指针)
  7. activemq消息丢失_面试必问之消息中间件
  8. signature=12e3283d637b587235bcb4cbbfa1a5b3,A pathogen-inducible endogenous siRNA in plant immunity
  9. Win10家庭版安装docker(WSL与WSL2两种安装方式)
  10. Apache Iceberg Research
  11. P1359 租用游艇 dfs/dp/floyd/dijk/spfa DAG(有向无环图)
  12. java8 lambda 处理分类和子分类的技巧
  13. android 侧滑删除方法,Android 基于RecyclerView的Item侧滑删除
  14. JVM(3)-垃圾收集机制
  15. NPR——卡通渲染(二)
  16. jvm 面试之参数实战
  17. 淘宝拍立淘以图搜图接口:使用方法和指南
  18. druid监控页面授权
  19. php 微盟,微盟开放授权并获取ACCESS_TOKEN方法(新版)
  20. 【GamePlay】泡泡龙核心算法

热门文章

  1. linux下u盘怎么找,redhat怎么找到u盘呢 ?
  2. Matlab 添加工具包的操作
  3. 弧焊机器人断弧_qlh 2焊接机断弧如何修理
  4. 致远SPM解决方案之资产管理
  5. JavaScript正则表达式给html字符串的img标签增加style样式
  6. Unity技术手册 - 粒子基础主模块属性-中
  7. 计算机音乐怎么去掉,怎么取消电脑的开机音乐
  8. 第三章 栈与队列(二)
  9. 生鲜配送企业要如何突破局限性?存在哪些弊端?
  10. 斐波那契数(Java)