python实现批量监控网站详解及实例

">

最近又新上了一部分站点，随着站点的增多，管理复杂性也上来了，俗话说：人多了不好带，我发现站点多了也不好管，因为这些站点里有重要的也有不重要的，重要核心的站点当然就管理的多一些，像一些万年都不出一次问题的，慢慢就被自己都淡忘了，冷不丁那天出个问题，还的手忙脚乱的去紧急处理，所以规范的去管理这些站点是很有必要的，今天我们就做第一步，不管大站小站，先统一把监控做起来，先不说业务情况，最起码那个站点不能访问了，要第一时间报出来，别等着业务方给你反馈，就显得我们不够专业了，那接下来我们看看如果用python实现多网站的可用性监控，脚本如下：

#!/usr/bin/env python
 
 
import pickle, os, sys, logging
from httplib import HTTPConnection, socket
from smtplib import SMTP
 
def email_alert(message, status):
  fromaddr = &＃39;xxx@163.com&＃39;
  toaddrs = &＃39;xxxx@qq.com&＃39;
  
  server = SMTP(&＃39;smtp.163.com:25&＃39;)
  server.starttls()
  server.login(&＃39;xxxxx&＃39;, &＃39;xxxx&＃39;)
  server.sendmail(fromaddr, toaddrs, &＃39;Subject: %s\r\n%s&＃39; % (status, message))
  server.quit()
 
def get_site_status(url):
  respOnse= get_response(url)
  try:
    if getattr(response, &＃39;status&＃39;) == 200:
      return &＃39;up&＃39;
  except AttributeError:
    pass
  return &＃39;down&＃39;
    
def get_response(url):
  try:
    cOnn= HTTPConnection(url)
    conn.request(&＃39;HEAD&＃39;, &＃39;/&＃39;)
    return conn.getresponse()
  except socket.error:
    return None
  except:
    logging.error(&＃39;Bad URL:&＃39;, url)
    exit(1)
    
def get_headers(url):
  respOnse= get_response(url)
  try:
    return getattr(response, &＃39;getheaders&＃39;)()
  except AttributeError:
    return &＃39;Headers unavailable&＃39;
 
def compare_site_status(prev_results):
  
  def is_status_changed(url):
    status = get_site_status(url)
    friendly_status = &＃39;%s is %s&＃39; % (url, status)
    print friendly_status
    if urlin prev_resultsand prev_results[url] != status:
      logging.warning(status)
      email_alert(str(get_headers(url)), friendly_status)
    prev_results[url] = status
 
  return is_status_changed
 
def is_internet_reachable():
  if get_site_status(&＃39;www.baidu.com&＃39;) == &＃39;down&＃39; and get_site_status(&＃39;www.sohu.com&＃39;) == &＃39;down&＃39;:
    return False
  return True
  
def load_old_results(file_path):
  pickledata = {}
  if os.path.isfile(file_path):
    picklefile = open(file_path, &＃39;rb&＃39;)
    pickledata = pickle.load(picklefile)
    picklefile.close()
  return pickledata
  
def store_results(file_path, data):
  output = open(file_path, &＃39;wb&＃39;)
  pickle.dump(data, output)
  output.close()
  
def main(urls):
  logging.basicConfig(level=logging.WARNING, filename=&＃39;checksites.log&＃39;, 
      format=&＃39;%(asctime)s %(levelname)s: %(message)s&＃39;, 
      datefmt=&＃39;%Y-%m-%d %H:%M:%S&＃39;)
  
  pickle_file = &＃39;data.pkl&＃39;
  pickledata = load_old_results(pickle_file)
  print pickledata
    
  if is_internet_reachable():
    status_checker = compare_site_status(pickledata)
    map(status_checker, urls)
  else:
    logging.error(&＃39;Either the world ended or we are not connected to the net.&＃39;)
    
  store_results(pickle_file, pickledata)
 
if __name__ == &＃39;__main__&＃39;:
  main(sys.argv[1:])

脚本核心点解释：

1、getattr（）是python的内置函数，接收一个对象，可以根据对象属性返回对象的值。

2、compare_site_status（）函数是返回的是一个内部定义的函数。

3、map()，需要2个参数，一个是函数，一个是序列，功能就是将序列中的每个元素应用函数方法。

以上就是python实现批量监控网站详解及实例的详细内容，更多请关注 第一PHP社区 其它相关文章！