遇到多线程问题同时连接到多个设备

Question

我用def get_info()定义了主要功能。此函数不接受参数。该程序使用argumentParser从命令行解析参数。提供的参数是带有--csv选项的CSV文件。这将从当前目录中获取csv文件并读取每个包含IP地址的行，以串行方式登录到设备并运行几个命令返回输出并附加到文本文件中。代码运行时，它会从目录中删除旧的文本文件，并在执行时创建一个新的输出文本文件。问题：我想使用线程模块实现这一点，这样它就需要并行5个设备并输出到文件中。我正在运行的问题是锁定问题，因为同一个进程同时使用同一个对象。这里是我编写的示例代码。线程概念对我来说很新，所以请理解。

import getpass import csv import time import os import netmiko import paramiko from argparse import ArgumentParser from multiprocessing import Process，Queue

def get_ip（device_ip，output_q）：

        try:
            ssh_session = netmiko.ConnectHandler(device_type='cisco_ios', ip=device_row['device_ip'],
                                                 username=ssh_username, password=ssh_password)
            time.sleep(2)
            ssh_session.clear_buffer()
        except (netmiko.ssh_exception.NetMikoTimeoutException,
                netmiko.ssh_exception.NetMikoAuthenticationException,
                paramiko.ssh_exception.SSHException) as s_error:
            print(s_error)

def main（）：

show_vlanfile = "pool.txt"
if os.path.isfile(show_vlanfile):
  try:
    os.remove(show_vlanfile)
  except OSError as e:
    print("Error: %s - %s." %(e.filename, e.strerror))

parser = ArgumentParser(description='Arguments for running oneLiner.py')
parser.add_argument('-c', '--csv', required=True, action='store', help='Location of CSV file')             
args = parser.parse_args()                                                                                 

ssh_username = input("SSH username: ")                                                                     
ssh_password = getpass.getpass('SSH Password: ')                                                           

with open(args.csv, "r") as file:                                                                          
    reader = csv.DictReader(file)                                                                          
    output_q = Queue(maxsize=5)                                                                            
    procs = []                                                                                             
    for device_row in reader:                                                                              
       # print("+++++ {0} +++++".format(device_row['device_ip']))                                          
         my_proc = Process(target=show_version_queue, args=(device_row, output_q))                         
         my_proc.start()                                                                                   
         procs.append(my_proc)                                                                             

# Make sure all processes have finished                                                                    
    for a_proc in procs:                                                                                   
        a_proc.join()                                                                                      

            commands = ["terminal length 0","terminal width 511","show run | inc hostname","show ip int brief | ex una","show

vlan brief“，”终端长度70“] 输出='' 对于命令中的cmd：输出+ =“\ n” 输出+ = ssh_session.send_command（cmd）输出+ =“\ n” 使用open（“pool.txt”，“a”）作为输出文件：而不是output_q.empty（）： output_queue = output_q.get（）对于output_queue中的x： outputfile.write（x）的

如果name ==“main”：主要（）