Java通过python命令执行DataX任务的实例

{  "job": {    "content": [      {        "reader": {          "name": "mysqlreader",          "parameter": {            "username": "$username",            "password": "$password",            "where": "optime>='$startDate $startTime' and optime<'$endDate $endTime'",            "column": ["id","xm"],            "connection": [              {                "table": [                  "test"                ],                "jdbcUrl": [                  "$jdbcUrl"                ]              }            ]          }        },        "writer": {          "name": "odpswriter",          "parameter": {            "accessId": "****************",            "accessKey": "******************************",            "column": ["id","xm"],            "odpsServer": "http://service.odps.xxx.com/api",            "partition": "bt=$bt,region=$region",            "project": "dst_project_name",            "table": "test"          }        }      }    ],    "setting": {      "speed": {        "channel": 10      }    }  }}

import java.io.BufferedReader;import java.io.InputStreamReader;public class Test {  public static void main(String[] args) {    try {      System.out.println("start");      String windowcmd = "cmd /c python F:/datax/bin/datax.py -p /" -Dusername=root -Dpassword=1234 -DjdbcUrl=jdbc:mysql://192.168.1.122:3306/center -Dwhere=left(optime,10)=CURDATE() -Dbt=20171214 -Dregion=beijing /" F:/datax/job/mysql2odps.json";      System.out.println(windowcmd);      Process pr = Runtime.getRuntime().exec(windowcmd);      BufferedReader in = new BufferedReader(new InputStreamReader(pr.getInputStream()));      String line;      while ((line = in.readLine()) != null) {        System.out.println(line);      }      in.close();      pr.waitFor();      System.out.println("end");    } catch (Exception e) {      e.printStackTrace();    }  }}