当我运行我的Python脚本时，我在paramiko 库上遇到错误......
但是脚本的结果不理解。任何人都可以帮助解决这个问题..！？
这是错误：
**Traceback (most recent call last):
File "/usr/local/lib/python3.5/dist-packages/paramiko/transport.py", line 2044, in _check_banner
buf = self.packetizer.readline(timeout)
File "/usr/local/lib/python3.5/dist-packages/paramiko/packet.py", line 353, in readline
buf += self._read_timeout(timeout)
File "/usr/local/lib/python3.5/dist-packages/paramiko/packet.py", line 540, in _read_timeout
x = self.__socket.recv(128)
ConnectionResetError: [Errno 104] Connection reset by peer
在处理上述异常的过程中，我遇到了另一个异常
这是新的异常：
Traceback (most recent call last):
File "/usr/local/lib/python3.5/dist-packages/paramiko/transport.py", line 1893, in run
self._check_banner()
File "/usr/local/lib/python3.5/dist-packages/paramiko/transport.py", line 2049, in _check_banner
'Error reading SSH protocol banner' + str(e)
paramiko.ssh_exception.SSHException: Error reading SSH protocol banner[Errno 104] Connection reset by peer
Script run time = 00:02:34**
这是脚本：
#!/usr/bin/python3.6
#import ipaddress
import csv
import os
from os import listdir
from os.path import isfile,join,expanduser
import getpass
import threading
import logging
import re
import time
from netmiko import ConnectHandler
from netmiko.ssh_exception import NetMikoTimeoutException
from netmiko.ssh_exception import NetMikoAuthenticationException
#-----------------------------------------------------------
def get_wd():
wd = os.path.expanduser('temp/')
if not os.path.exists(wd):
os.makedirs(wd)
return wd
#-----------------------------------------------------------
def del_temp_files():
list_temp_dir = os.listdir(wd)
ext = (".json",".csv",".txt",".log")
for item in list_temp_dir:
if item.endswith(ext):
os.remove(os.path.join(wd, item))
#----------------------------------------------------------------------
def ssh_connection(ip, ref, username, password):
try:
return ConnectHandler(device_type='cisco_ios',ip=ip,username=username,password=password)
except Exception as error:
logger.error('. %&%&%&%&%& {} {} \t {}'.format(ref, ip, error))
with open ("{}conn_error.txt".format(wd), "a") as efile:
efile.write('{} {} \n'.format(ref, ip))
#--------------------envoie de commande et stocker le resultat dans un fichier----------------------------------------------------
def get_worker(ip, ref, device):
try:
result = device.send_command("show run | inc username")
if "cisco" in result:
usert="yes"
else:
usert="no"
with open ("{}result.csv".format(wd), "a") as file1:
file1.write('{} {}\n'.format(ref,usert))
except Exception as error:
logger.error(". Get Error {} {} \t {}".format(ref, ip, error))
#-----------------------connection aux équipements--------------------------------------------------------
def main(ip, ref, username, password):
device = ssh_connection(ip, ref, username, password)
if device == None:
sema.release()
return
output = get_worker(ip, ref, device)
device.disconnect()
sema.release()
if __name__ == '__main__':
wd = get_wd()
del_temp_files()
threads = []
max_threads = 20
sema = threading.BoundedSemaphore(value=max_threads)
user = "cisco"
passwd = "cisco"
start_time = time.time()
logger = logging.getLogger("LOG")
handler = logging.FileHandler("{}main.log".format(wd))
logger.setLevel(logging.DEBUG)
logger.addHandler(handler)
#--------------------------------------------------------------------
with open("/home/net/inventaire_routes/cisco.csv.save") as fh:
devices = csv.reader(fh,delimiter=';')
for host in devices:
sema.acquire()
ip = host[1]
ref = host[0]
thread = threading.Thread(target=main, args=(ip, ref, user, passwd))
threads.append(thread)
thread.start()
elapsed_time = time.time() - start_time
print("Script run time = " + time.strftime("%H:%M:%S", time.gmtime(elapsed_time)))
#----------------------------------------------------------------------------------
我该如何解决这个问题..！？？