欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java通過python命令執(zhí)行DataX任務的實例

 更新時間:2019年08月22日 14:12:54   作者:王紹樺  
今天小編就為大家分享一篇Java通過python命令執(zhí)行DataX任務的實例,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧

1.安裝datax

2.安裝python并配置環(huán)境變量

3.把mysql2odps.json文件放在datax安裝目錄的job文件夾下

4.運行Test.java測試

mysql2odps.json文件:

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

測試程序(我的datax安裝路徑為F盤根目錄):

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();
    }
  }

}

以上這篇Java通過python命令執(zhí)行DataX任務的實例就是小編分享給大家的全部內(nèi)容了,希望能給大家一個參考,也希望大家多多支持腳本之家。

相關(guān)文章

  • 淺談java中字符串數(shù)組、字符串、整形之間的轉(zhuǎn)換

    淺談java中字符串數(shù)組、字符串、整形之間的轉(zhuǎn)換

    這篇文章主要介紹了淺談java中字符串數(shù)組、字符串、整形之間的轉(zhuǎn)換,具有一定參考價值,需要的朋友可以了解下。
    2017-11-11
  • java并發(fā)學習-CountDownLatch實現(xiàn)原理全面講解

    java并發(fā)學習-CountDownLatch實現(xiàn)原理全面講解

    這篇文章主要介紹了java并發(fā)學習-CountDownLatch實現(xiàn)原理全面講解,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2021-02-02
  • java 解析user-agent 信息

    java 解析user-agent 信息

    這篇文章主要介紹了java 解析http user-agent的信息的相關(guān)資料,需要的朋友可以參考下
    2016-07-07
  • 詳解Java實現(xiàn)緩存(LRU,FIFO)

    詳解Java實現(xiàn)緩存(LRU,FIFO)

    本篇文章主要介紹了詳解Java實現(xiàn)緩存(LRU,FIFO) ,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-04-04
  • IDEA .iml文件及.idea文件夾超詳細講解

    IDEA .iml文件及.idea文件夾超詳細講解

    iml文件是IntelliJ IDEA自己創(chuàng)建的模塊文件,用于java應用開發(fā),存儲一些模塊相關(guān)的信息,比如一個Java組建,插件組建,Maven組建等,這篇文章主要介紹了IDEA .iml文件及.idea文件夾,需要的朋友可以參考下
    2023-09-09
  • Java程序測試上傳Maven工程代碼示例解析

    Java程序測試上傳Maven工程代碼示例解析

    這篇文章主要介紹了Java程序測試上傳Maven工程代碼示例解析,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2020-08-08
  • JAVA關(guān)鍵字及作用詳解

    JAVA關(guān)鍵字及作用詳解

    本文主要介紹了Java關(guān)鍵字及作用,具有很好的參考價值,下面跟著小編一起來看下吧
    2017-02-02
  • java的package和import機制原理解析

    java的package和import機制原理解析

    這篇文章主要介紹了java的package和import機制原理解析,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2020-01-01
  • Maven工程引入依賴失敗Dependencies全部飄紅問題

    Maven工程引入依賴失敗Dependencies全部飄紅問題

    這篇文章主要介紹了Maven工程引入依賴失敗Dependencies全部飄紅問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2024-08-08
  • 與眾不同的 Java 日期格式化大全

    與眾不同的 Java 日期格式化大全

    這篇文章主要介紹了與眾不同的 Java 日期格式化大全,在 Java 中,經(jīng)常要將時間字符串轉(zhuǎn)換為日期,或者要將日期轉(zhuǎn)換為時間字符串。,需要的朋友可以參考下
    2019-06-06

最新評論