java 直接调用python脚本，并传递参数代码实例

2019-11-26 09:08:18

字体：大中小

来源：转载

供稿：网友

最近陆续用python写了很多文件处理脚本，虽然功能都比较简单，但还是感觉到python对文件处理的简洁高效，越发觉得java的语法相当的繁琐~

接到个需求处理ftp数据接口。所以想把python脚本也用上。java代码定时扫描ftp数据仓库，调用python脚本入库。

直接采用java执行系统命令的方式

@Async	public void readFileByPython(List<String> 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<filePaths.size() ;i++){			int index = i+2;			args[index] = filePaths.get(i);		}		try {				      System.out.println("start"); 	      Process proc = Runtime.getRuntime().exec(args);	      InputStream is = proc.getErrorStream(); 	      InputStreamReader isr = new InputStreamReader(is); 	      BufferedReader br = new BufferedReader(isr); 	      String line = null; 	      System.out.println("<ERROR>"); 	      while((line = br.readLine())!=null){ 	          System.out.println(line); 	          System.out.println("</ERROR>"); 	          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]表示要执行的是python 脚本，args[1] 脚本文件的全路径

该方法调用 AbstractReadFileLine.class 文件路径下的 PythonFileHandle.py 脚本，并传入String数组类型的参数（需要处理的文件全路径）

PythonFileHandle脚本接受java传入的文件路径参数（数组），解析并入库

PythonFileHandle.py 代码

import pymssql,time,sysreload(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文件自身的路径，故接受参数从sys.argv[1]开始。

以上所述是小编给大家介绍的java调用python脚本传递参数详解整合，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对武林网网站的支持！

上一篇：JAVA数据结构之汉诺塔代码实例

下一篇：SpringBoot通过yml和xml文件配置日志输出方法