1。安装datax
2。安装python并配置环境变量
3。把mysql2odps.json文件放在datax安装目录的工作文件夹下
4。运行Test.java测试
<强> mysql2odps.json文件:
{
"工作":{
“内容”:(
{
“读者”:{
“名称”:“mysqlreader”,
“参数”:{
“用户名”:“用户名”美元,
“密码”:“密码”美元,
”,“:“optime>=皊tartDate可以开始时间美元”和optime
<强>测试程序(我的datax安装路径为F盘根目录):
进口java.io.BufferedReader;
进口java.io.InputStreamReader;
公共类测试{
公共静态void main (String [] args) {
尝试{
System.out.println(“开始”);
python字符串windowcmd=" cmd/c F:/datax/bin/datax。py - p \“-Dusername=根-Dpassword=1234 -DjdbcUrl=jdbc: mysql://192.168.1.122:3306/中心-Dwhere=左(optime 10)=CURDATE()印度生物技术部=20171214 -Dregion=北京\“F:/datax/工作/mysql2odps.json”;
System.out.println (windowcmd);
过程公关=Runtime.getRuntime () .exec (windowcmd);
BufferedReader=new BufferedReader(新InputStreamReader (pr.getInputStream ()));
字符串行;
在((=in.readLine行())!=null) {
System.out.println(线);
}
in.close ();
pr.waitFor ();
System.out.println(“结束”);
}捕捉(异常e) {
e.printStackTrace ();
}
}
}
以上这篇Java通过python命令执行DataX任务的实例就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。
