Python中IP地址的多线程ping

Question

我有一个IP地址列表，例如1000 no。我正在阅读ip_file.txt，并将结果文件存储为result_date.txt。以下是我达到结果的代码。但是我的问题是执行整个文件需要花费太长时间。有人可以建议多线程，以便可以快速实现所需的结果吗？提前致谢。

#!/usr/bin/env python
import os
import csv
import paramiko
from datetime import datetime
import time
import sys
import re
from collections import defaultdict

# Verifies your os type
from paramiko import file

OS_TYPE = os.name
# Sets the count modifier to the os type
count = '-n' if OS_TYPE == 'nt' else '-c'


def create_ip_list():
    ip_list = []
    with open("ip_file.txt", "r") as file:
        for line in file:
            ip_list.append(line.strip())
    return ip_list

# fetching data
now = datetime.now()
dat = now.strftime("%d/%m/%Y")
# time = now.strftime("%H:%M:%S")
date_string = dat.replace('/', '-')

timestr = time.strftime("%d%m%Y-%H%M%S")


def ping_device(ip_list):
    """Ping ip_list and return results
        return: None
        rtype: None
    """
    results_file = open("results_" + str(timestr) + ".txt", "w")
    for ip in ip_list:
        response = os.popen(f"ping {ip} {count} 1").read()
        time.sleep(1.5)
        #fetch Average time
        print(response)
        for i in response.split("\n"):
            para = i.split("=")
            try:
                if para[0].strip() == "Minimum":
                    latency = para[3].strip()
                    print(latency)
                    # output1=latency[0:8].split(" ")
                    # test=output1[0]
                    # print(test)
            except:
                print("time run")

        if "Received = 1" and "Approximate" in response:
            #print(f"UP {ip} Ping Successful")
            results_file.write(f"{ip},UP,{latency}" + "\n")
        else:
            print(f"Down {ip} Ping Unsuccessful")
            results_file.write(f"{ip} Down" + "\n")
    results_file.close()

if __name__ == "__main__":
    ping_device(create_ip_list())

Answer 1

编写一个功能ping_one_device，该采用单个ip并返回一个给出状态的单个字符串。从ping_device中将其拉出应该很容易。

然后

with open(results_file, "w") as results_file:
    with ThreadPoolExecutor() as executor:
        for result in map(ping_one_device, ip_list):
            results_file.write(result)