问题内容
我有以下文件：
ping.py：
from utilities.env import packet_cout, ping_time, max_workers_count
from utilities.cmds import create_ping_cmd
from subprocess import popen, pipe, devnull, timeoutexpired
from re import findall
from concurrent.futures import threadpoolexecutor
max_ping_time = float(packet_cout) * (float(ping_time))
ping_cmd = create_ping_cmd()
def check_ping_process(ping_process):
ping_result = {}
try:
out = ping_process.communicate(timeout=max_ping_time)[0]
is_successes = findall("ttl", out)
if ping_process.returncode == 0 and is_successes:
return true
else:
return false
except timeoutexpired:
ping_process.kill()
return false
def ping_ip(ip):
ping_cmd.append(ip)
ping_process = popen(
ping_cmd,
stdout=pipe,
stderr=devnull,
text=true
)
result = check_ping_process(ping_process)
return result
def ping_ip_list(ip_list):
ping_results = []
with threadpoolexecutor(max_workers=max_workers_count) as executor:
results = executor.map(ping_ip, ip_list)
for ip, result in zip(ip_list, results):
print({ip, result})
ping_results.append({ip, result})
return ping_results
main.py：
from ping import ping_ip_list
ip_list = [
'192.168.0.100',
'192.168.0.1',
'192.168.0.104',
'192.168.0.124124',
'192.168.0.103'
]
def monitor_network_devices(ip_list):
results = ping_ip_list(ip_list)
monitor_network_devices(ip_list)
该程序的目标是查明网络设备是否可 ping 通。我正在运行 main.py 文件，它给出了错误的结果。我尝试debug，似乎是线程的问题，但无法解决。
任何帮助将不胜感激
正确答案
一些观察
-
如前所述，您不断向
ping_cmd追加更多内容，您的命令将拥有越来越多的 ip 地址。最好每次构建一个新命令，而不是附加到ping_cmd列表
金戈企业建站系统0.1下载软件介绍：金戈企业建站系统不仅是一份免费的企业建站代码包，而且它还是完全开源的，它倾注了作者1个多月来日日夜夜的心血，虽然有些地方没做到尽善尽美，可我相信在接下来的日子里我会通过反馈信息让她更丰满实用起来。1.完美的摸板机制，即使你对php一点也不懂，只要你会做网页。就可以立即打造新颖别致的网站界面（摸板制作方法手册正在紧张制作中，稍后发布）可惜作者精力有限，目前只提供一套摸板。不过只是暂时的2.
-
考虑这一行
is_successes = findall("ttl", out)我看一下 linux 的输出，它看起来像这样：
ping 192.168.1.1 (192.168.1.1) 56(84) bytes of data. 64 bytes from 192.168.1.1: icmp_seq=1 ttl=63 time=11.9 ms 64 bytes from 192.168.1.1: icmp_seq=2 ttl=63 time=5.18 ms --- 192.168.1.1 ping statistics --- 2 packets transmitted, 2 received, 0% packet loss, time 1024ms rtt min/avg/max/mdev = 5.182/8.541/11.901/3.359 ms
在您的代码中，您搜索 ttl（大写），这将始终导致
false。此外，要搜索文本，您不需要使用正则表达式：is_success = "ttl" in out
-
由于您没有发布
utilities包的内容，因此我不知道packet_cout等值是什么 -
处理多线程时，最好使用
logging而不是 print，因为前者是线程安全的，而后者则不然。
这样，这是我提出的解决方案
# ping.py
import logging
import subprocess
from concurrent.futures import ThreadPoolExecutor
logging.basicConfig(
level=logging.DEBUG,
format="%(asctime)s | %(levelname)s | %(threadName)-15s | %(funcName)-18s | %(message)s",
)
def ping_ip(ip):
ping_command = ["ping", "-c1", ip]
logging.debug("Execute command %r", ping_command)
completed_process = subprocess.run(
ping_command,
text=True,
capture_output=True,
check=False,
)
success = completed_process.returncode == 0
logging.debug("%s -> %r", ip, success)
return success
def ping_ip_list(ip_list):
with ThreadPoolExecutor() as executor:
out = dict(zip(ip_list, executor.map(ping_ip, ip_list)))
return out
