DataX配置案例
阿新 • • 發佈:2022-03-18
1.mysql 讀(querySql查詢方式)到mysql寫 執行命令是:
python datax/bin/datax.py datax/job/test.json
{ "job":{ "content":[ { "reader": { "name": "mysqlreader", "parameter": { "username": "root", "password": "root", "connection": [ {"querySql": [ "select * from wmj_owner where id = 2;" ], "jdbcUrl": [ "jdbc:mysql://127.0.0.1:3306/yyl_ry" ] } ] } }, "writer":{ "name":"mysqlwriter","parameter":{ "column":[ "user_name" ], "connection":[ { "jdbcUrl": "jdbc:mysql://127.0.0.1:3306/yyl_ry", "table":[ "wmj_orders" ] } ], "password":"root","username":"root" } } } ], "setting":{ "speed":{ "channel":"1" } } } }
2.mysql 讀(where動態方式查詢方式)到mysql寫 執行命令是:
python datax/bin/datax.py datax/job/test.json -p "-Did=3"
{ "job":{ "content":[ { "reader": { "name": "mysqlreader", "parameter": { "username": "root", "password": "root", "column": [ "name" ], "where": "id=${id}", "splitPk": "id", "connection": [ { "table": [ "wmj_owner" ], "jdbcUrl": [ "jdbc:mysql://127.0.0.1:3306/yyl_ry" ] } ] } }, "writer":{ "name":"mysqlwriter", "parameter":{ "column":[ "user_name" ], "connection":[ { "jdbcUrl": "jdbc:mysql://127.0.0.1:3306/yyl_ry", "table":[ "wmj_orders" ] } ], "password":"root", "username":"root" } } } ], "setting":{ "speed":{ "channel":"1" } } } }