java 直接調(diào)用python腳本，并傳遞參數(shù)代碼實例

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

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