用子流程導出多個文件

Question

我想用子流程導出多個txt文件。

ip_address = ['172.16.{}.{}'.format(rack_number, box_number) for box_number in stb_list] 

    ip_address = ['10.10.8.89'] # Testing for single ip 

    # def planner_events_info(): 


    #Connect to Boxes 

    if len(ip_address) > 0: 



     for ip in ip_address: 


      action = 'FullExport' 
      menu_action = 'all' 
      arg_list = [('C:\\Users\\yke01\\Documents\\StormTest\\Scripts\\Completed' 
          '\\Utils\\UPNP_Client_Cmd_Line.py')] 
      arg_list.append(' --action=') 
      arg_list.append(action) 
      arg_list.append(' --ip=') 
      arg_list.append(ip) 
      arg_list.append(' --menu=') 
      arg_list.append(menu_action) 

      x = subprocess.Popen(arg_list, shell=True) 

      # print arg_list 

      with open("output.txt", "w+") as output: 
       subprocess.call(["python", arg_list], stdout=output) 

使用單個IP地址我可以導出output.txt。我正在爲最多16個不同的ips寫腳本。

ip_address = ['172.16.1.1, 172.16.1.2, 172.16.1.3, 172.16.1.4, ] 

例如，對於上述ip地址，我想導出4個txt文件。任何幫助將不勝感激。！

Answer 1

1.一個接一個 - 串行管道

for i,ip in enumerate(ip_address): 
    filename = "output_"+str(i)+".txt" 
    #... 
    with open(filename, "w+") as output: 
     subprocess.call(["python", arg_list], stdout=output) 

2.並行流水線

異步運行與apply_async從multiprocessing.Pool

這是一個完整的運行示例

import multiprocessing 

ip_address = ['172.16.1.1', '172.16.1.2', '172.16.1.3', '172.16.1.4', ] 

def runProcess(arg_list,output_file): 
    print('Will run:\n %s\nand save to \n %s\n'%(arg_list, output_file)) 
    x = subprocess.Popen(arg_list, shell=True) 

    with open(output_file, "w+") as output: 
     subprocess.call(["python", arg_list], stdout=output) 

tasks=[] 
#prepare list of tasks 
for i,ip in enumerate(ip_address): 
    filename = "output_"+str(i)+".txt" 
    action = 'FullExport' 
    menu_action = 'all' 
    arg_list = [('C:\\Users\\yke01\\Documents\\StormTest\\Scripts\\Completed' 
        '\\Utils\\UPNP_Client_Cmd_Line.py')] 
    arg_list.append(' --action=') 
    arg_list.append(action) 
    arg_list.append(' --ip=') 
    arg_list.append(ip) 
    arg_list.append(' --menu=') 
    arg_list.append(menu_action) 

    tasks.append((arg_list,filename)) #pairs: (arg_list,output_file) 

#run tasks 
numthreads = multiprocessing.cpu_count() 
pool = multiprocessing.Pool(numthreads) 
results = [pool.apply_async(runProcess, t) for t in tasks] 
pool.close() 
pool.join()