java代码调用python_java 直接调用python脚本,并传递参数代码实例|chu
最近陸續(xù)用python寫了很多文件處理腳本,雖然功能都比較簡單 ,但還是感覺到python對文件處理的簡潔高效 ,越發(fā)覺得java的語法相當?shù)姆爆崀
接到個需求處理ftp數(shù)據(jù)接口 。所以想把python腳本也用上。java代碼定時掃描ftp數(shù)據(jù)倉庫 ,調(diào)用python腳本入庫。
直接采用java執(zhí)行系統(tǒng)命令的方式
@Async public void readFileByPython(List filePaths) throws FileNotFoundException { URL localSrcUrl = AbstractReadFileLine.class.getResource(""); String localSrcPath = localSrcUrl.getPath(); localSrcPath = localSrcPath.substring(1, localSrcPath.length()); String pythonFile = localSrcPath + "PythonFileHandle.py"; int size = filePaths.size() + 2; String[] args = new String[size]; args[0] = "python"; args[1] = pythonFile; for(int i =0;i"); while((line = br.readLine())!=null){ System.out.println(line); System.out.println(""); int exitValue = proc.waitFor(); System.out.println("Process exitValue="+exitValue); } System.out.println("end"); } catch (Exception e){ e.printStackTrace(); } }
String[] args = new String[size];
args[0] = "python"; args[1] = pythonFile; args[0]表示要執(zhí)行的是python 腳本 ,args[1] 腳本文件的全路徑
該方法調(diào)用 AbstractReadFileLine.class 文件路徑下的 PythonFileHandle.py 腳本 ,并傳入String數(shù)組類型的參數(shù)(需要處理的文件全路徑)
PythonFileHandle腳本接受java傳入的文件路徑參數(shù)(數(shù)組),解析并入庫
PythonFileHandle.py 代碼
import pymssql,time,sys reload(sys) sys.setdefaultencoding("utf-8") class MSSQL: def __init__(self,host,user,pwd,db): self.host = host self.user = user self.pwd = pwd self.db = db def __GetConnect(self): if not self.db: raise(NameError,"") self.conn = pymssql.connect(host=self.host,user=self.user,password=self.pwd,database=self.db,charset="utf8") cur = self.conn.cursor() if not cur: raise(NameError,"") else: return cur def ExecQuery(self,sql): cur = self.__GetConnect() cur.execute(sql) resList = cur.fetchall() # self.conn.close() return resList def ExecNonQuery(self,sql): cur = self.__GetConnect() cur.execute(sql) self.conn.commit() self.conn.close() def insertToCloseList(data ,ms): sql = "insert into t_isee_closelist_infos (WORK_ORDER_ID,CRM_Cdsc_Id,APPRAISE_TYPE,CRM_Accept_Date,latn_code,theme_row_id,TASK_EXECUTE_ROW_ID,CRM_Accept_REASON,ASSET_INTEG_ID) values ( '" temp ="' , '" sqlStr = temp.join(data) sql = sql + sqlStr + "')" ms.ExecNonQuery(sql) ms = MSSQL(host="172.30.0.186",user="sa",pwd="",db="test") fengefu = '$%$' for i in range(1, len(sys.argv)): read = open(sys.argv[i] ,'r') for line in read: line=line.strip('n') data = line.split(fengefu) insertToCloseList(data,ms) read.close
sys.argv[0] 存儲的是py文件自身的路徑,故接受參數(shù)從sys.argv[1]開始。
以上所述是小編給大家介紹的java調(diào)用python腳本傳遞參數(shù)詳解整合,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復(fù)大家的。在此也非常感謝大家對華域聯(lián)盟網(wǎng)站的支持!
總結(jié)
以上是生活随笔為你收集整理的java代码调用python_java 直接调用python脚本,并传递参数代码实例|chu的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 无线网络禁用了怎么开启 如何开启无线网络
- 下一篇: 巴基斯坦飞行员成功试飞中guo歼10!