日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

說(shuō)明

創(chuàng)新互聯(lián)憑借在網(wǎng)站建設(shè)、網(wǎng)站推廣領(lǐng)域領(lǐng)先的技術(shù)能力和多年的行業(yè)經(jīng)驗(yàn)，為客戶(hù)提供超值的營(yíng)銷(xiāo)型網(wǎng)站建設(shè)服務(wù)，我們始終認(rèn)為：好的營(yíng)銷(xiāo)型網(wǎng)站就是好的業(yè)務(wù)員。我們已成功為企業(yè)單位、個(gè)人等客戶(hù)提供了網(wǎng)站設(shè)計(jì)制作、做網(wǎng)站服務(wù)，以良好的商業(yè)信譽(yù)，完善的服務(wù)及深厚的技術(shù)力量處于同行領(lǐng)先地位。

1、將所有設(shè)備信息寫(xiě)入文本文檔。

簡(jiǎn)單地使用txt，將登錄信息構(gòu)建成字典。

2、初始化SSH連接和執(zhí)行命令。

3、分析此需求指定的命令和輸出結(jié)果。

將結(jié)果存儲(chǔ)在文件中。

4、增加多線(xiàn)程執(zhí)行。

提高效率。

5、添加Linux的crontab。

每小時(shí)收集一次信息(服務(wù)器配置)

實(shí)例

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import re
import time
from concurrent.futures import ThreadPoolExecutor
import Paramiko
 
 
def get_device_list(filename):
    """從文本文件讀取設(shè)備列表，返回由字典組成的列表。
    文本內(nèi)容格式為：ip，用戶(hù)名，密碼，別名，例如：
    1.1.1.1 admin admin sw1
    1.1.1.2 admin admin sw2
    ......
    
    Args:
        filename ([str]): 文件名稱(chēng)
    """
    with open(filename, 'r') as f:
        device_list = []
        for line in f.readlines():
            ip, username, password, name = line.strip().split()
            device_list.append(
                {
                    "ip": ip,
                    "username": username,
                    "password": password,
                    "name": name,
                }
            )
    return device_list
 
class NetworkDevice(object):
    def __init__(self, ip="", username="", password="'", name="", port=22,):
        self.conn = None
        if ip:
            self.ip = ip.strip()
        elif name:
            self.name = name.strip()
        else:
            raise ValueError("需要設(shè)備連接地址（ip 或 別名）")
        self.port = int(port)
        self.username = username
        self.password = password
        self._open_ssh()
    
    def _open_ssh(self):
        """初始化 SSH 連接，調(diào)起一個(gè)模擬終端，會(huì)話(huà)結(jié)束前可以一直執(zhí)行命令。
 
        Raises:
            e: 拋出 paramiko 連接失敗的任何異常
 
        """
        ssh_connect_params = {
            "hostname": self.ip,
            "port": self.port,
            "username": self.username,
            "password": self.password,
            "look_for_keys": False,
            "allow_agent": False,
            "timeout": 5,   # TCP 連接超時(shí)時(shí)間
        }
        conn = paramiko.SSHClient()
        conn.set_missing_host_key_policy(paramiko.AutoAddPolicy())
        try:
            conn.connect(**ssh_connect_params)
        except Exception as e:
            raise e
        self.conn = conn.invoke_shell(term="vt100", width=500, height=1000)
        return ""
 
    def exec_cmd(self, cmd, recv_time=3):
        """登錄設(shè)備，執(zhí)行命令
 
        Args:
            cmd ([type]): 命令字符串
            recv_time (int, optional): 讀取回顯信息的超時(shí)時(shí)間. Defaults to 3.
 
        Raises:
            EOFError: 沒(méi)有任何信息輸出，說(shuō)明連接失敗。
 
        Returns:
            output:
        """
        cmd = cmd.strip() + "\n"
        self.conn.sendall("screen disable\n")
        self.conn.sendall(cmd)
        time.sleep(int(recv_time))
        output = self.conn.recv(1024*1024)
        if len(output) == 0:
            raise EOFError("連接可能被關(guān)閉，沒(méi)有任何信息輸出")
        return output.decode('utf-8', 'ignore')
 
 
dev = {
    "ip":"192.168.56.21",
    "username":"netdevops",
    "password":"Admin@h3c.com",
    "name": "sw1"
}
# sw1 = NetworkDevice(**dev)
# ret = sw1.exec_cmd("dis version")
# print(ret)
 
def parse_interface_drop(output):
    """把設(shè)備的輸出隊(duì)列丟包信息解析成累加值
    命令及輸出示例如下：
    # [H3C]dis qos queue-statistics interface outbound | in "^ Drop"
    #  Dropped: 0 packets, 0 bytes
    """
    ptn = re.compile(r"\s(\S+):\s+(\d+)\s+(\S+),\s+(\d+)\s+(\S+)")
    count = 0
    for i in ptn.findall(output):
        count += int(i[1])
    return count
 
def run(cmd, **conn_parms):
    """登錄單臺(tái)設(shè)備，執(zhí)行指定命令，解析丟包統(tǒng)計(jì)
    """
    sw = NetworkDevice(**conn_parms)
    output = sw.exec_cmd(cmd)
    drop_count = parse_interface_drop(output)
    return "%s %s %s"%(
        conn_parms.get("name"),
        conn_parms.get("ip"),
        drop_count)
 
# cmd = r'dis qos queue-statistics interface outbound | in "^ Drop"'
# ret = run(cmd,**dev)
# print(ret)
 
if __name__== "__main__":
    """獲取設(shè)備列表，使用多線(xiàn)程登錄設(shè)備獲取信息并返回
    """
    with ThreadPoolExecutor(10) as pool:
        futures = []
        cmd = r'dis qos queue-statistics interface outbound | in "^ Drop"'
        dev_info = get_device_list("./iplist.txt")
        for d in dev_info:
            future = pool.submit(run, cmd, **d)
            futures.append(future)
        # for f in futures:
        #     print(f.result())
    # 根據(jù)執(zhí)行時(shí)間把結(jié)果寫(xiě)入文件，精確到小時(shí)
    with open("./drops/%s.log"%time.strftime("%Y%m%d_%H"),'w') as f:
         for line in futures:
            f.write(line.result() + "\n")

以上就是python Paramiko的SSH用法，希望對(duì)大家有所幫助。更多Python學(xué)習(xí)指路：創(chuàng)新互聯(lián)python教程

本文教程操作環(huán)境：windows7系統(tǒng)、Python 3.9.1，DELL G3電腦。

分享標(biāo)題：創(chuàng)新互聯(lián)Python教程：python Paramiko的SSH用法
本文路徑：http://www.dlmjj.cn/article/coehhgh.html