python3批量ping检测

背景：
公司核心交换机更换，而各个分公司的内网是通过IPSec互连的，子网段有*百个，为了验证割接前后网段互通情况，
诞生此脚本。

使用方法：
1. 从核心交换中拉取vlanif接口ip，存入hostip.txt文件
2. 设置脚本只保留能ping通的ip作为记录留存，方法：注释 脚本中函数`def ping_IP (IP_QUEUE):`内的`logging.info("%s IP = %s %s" % (today,ip,res))`，这样没有ping通的ip就不会记录到日志 ping_host.log
3. 第一次运行脚本
4. 取消第二步的注释
5. 割接完设备后，脚本中 存有待检测ip的文件名hostip.txt 替换为 ping_host.log（检测割接前能通的ip是否还通）
6. 第二次运行脚本，查看结果

待检测的服务器ip地址;每行包含一个ip地址
`cat hostip.txt`
```
vlanif100 vlan100 100.50.220.19/24
2021 - 07 - 09 10 : 35 : 57 IP = 100.50.223.34 网络连接失败!
100.50.223.35
```
运行后生成的日志文件
`cat ping_host.log`
```
2021 - 07 - 26 10 : 22 : 29 IP = 100.50.220.19 网络连接失败!
2021 - 07 - 26 10 : 22 : 31 IP = 100.50.223.34 网络可以正常连通平均延时 = 11ms
2021 - 07 - 26 10 : 22 : 32 IP = 100.50.223.35 网络可以正常连通平均延时 = 11ms
```

ping_net_v0.2.py
```python
import subprocess
import logging
import datetime
import time
import threading
from queue import Queue
import re
import sys
# 实现日志导出
def set_logging_format():
  logging.basicConfig(level=logging.INFO,
            format='%(message)s',
            filename='ping_host.log',
            filemode='w'
            )
  console = logging.StreamHandler()
  console.setLevel(logging.INFO)
  formatter = logging.Formatter('%(message)s')
  console.setFormatter(formatter)
  logging.getLogger('').addHandler(console)
# 将需要ping 连接的IP加入队列
def insert_ip_queue(ip_list_path):
  IP_QUEUE = Queue()
  with open (ip_list_path,'r') as f:
    for ip in f.readlines():
      ip = ip.strip('\n')
      # 判断一个字符串是否包含合法IP地址
      ip = re.search(r'((25[0-5]|2[0-4]\d|1\d{2}|[1-9]?\d)\.){3}(25[0-5]|2[0-4]\d|1\d{2}|[1-9]?\d)', ip)
      if ip:
        ip = ip.group()  # 提取出合法ip地址
        IP_QUEUE.put(ip)
    f.close()
  return IP_QUEUE
def IP_list (ip_list_path):
  ip_list = Queue()
  with open (ip_list_path,'r') as f:
    for ip in f.readlines():
      ip = ip.strip('\n')
      # 判断一个字符串是否包含合法IP地址
      ip = re.search(r'((25[0-5]|2[0-4]\d|1\d{2}|[1-9]?\d)\.){3}(25[0-5]|2[0-4]\d|1\d{2}|[1-9]?\d)', ip)
      if ip:
        ip = ip.group()  # 提取出合法ip地址
        list_segment = ip.split('.')
        ip_index = 1
        # 将需要 ping 的 ip 加入队列
        for i in range(0, 254):
          list_segment[-1] = str(ip_index + i)
          addr = ('.').join(list_segment)
          print(addr)
          ip_list.put(addr)
    f.close()
  return ip_list
# print (IP_list())
#print (IP_list())
#定义 ping 函数
def ping_IP (IP_QUEUE):
  while not IP_QUEUE.empty():
    ip = IP_QUEUE.get().strip('\n')
    #print (ip)
    res = subprocess.call('ping -w 1000 -n 1 %s' % ip , stdout=subprocess.PIPE,shell=True)

#print (res)
    if res == 0:
      h =subprocess.getoutput('ping' + ' ' + ip)
      #print (h)

if 'TTL=' in h:
        res = ('网络可以正常连通平均延时 = %s' % h.split('平均 = ')[1])

today = datetime.datetime.now().strftime("%Y - %m - %d %H : %M : %S")
        logging.info("%s IP = %s %s" % (today, ip, res))
    else:
      res = '网络连接失败!'
      today = datetime.datetime.now().strftime("%Y - %m - %d %H : %M : %S")
      logging.info("%s IP = %s %s" % (today,ip,res))
      #开关
      pass
def main ():
  set_logging_format()
  ip_list_path = './hostip.txt'
  # IP_QUEUE = insert_ip_queue(ip_list_path)
  # IP_LIST = IP_list(ip_list_path)
  threads = []
  THREAD_NUM = 200
  user_iput = input('please input modren: ')
  if user_iput == 'net':
    IP_LIST = IP_list(ip_list_path)
    IP_L = IP_LIST
  if user_iput == 'ip':
    IP_QUEUE = insert_ip_queue(ip_list_path)
    IP_L = IP_QUEUE
  for i in range (THREAD_NUM):
    t = threading.Thread(target = ping_IP, args = (IP_L,))
    threads.append(t)
  for i in range (THREAD_NUM):
    threads[i].start()
  for i in range (THREAD_NUM):
    threads[i].join()
if __name__ == '__main__':
  main()

#hostip.txt中每行写一个ip地址，运行时根据输入ip或net来ping单个地址或ip对应的C类网段。
```