1. 程式人生 > 其它 >DataX配置案例

DataX配置案例

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"
      }
    }
  }
}