PYTHON--定期監測服務器端口，并將結果寫入MYSQL

定時監測服務器端口，然后將結果入寫數據庫。

監測用NC命令，入庫就用PYTHON的MYSQL模塊

再調一個基于函數的多線程。。。

妥妥的。。

是網上兩個功能的合成。。

?

俺不生產代碼，俺只是BAIDU的搬運工！

?

#!/usr/bin/env python import multiprocessing 
import subprocess 
import MySQLdbhost_list = []
for line in open("/xxx/data_ip_port"):host_list.append(line.strip('\n'))
if len(host_list) > 10: process_number = 10
else: process_number = len(host_list) def insert_mysql(sql_str):try:conn=MySQLdb.connect(host='xxxx',user='xxxx',passwd=xxxxxxx',db='xxxx',port=xxxx)cur=conn.cursor()cur.execute(sql_str)cur.close()conn.commit()conn.close()except MySQLdb.Error,e:print "Mysql Error %d: %s" % (e.args[0], e.args[1])def ping_host(ipaddr): if subprocess.call('nc -vz -w 2 %s > /dev/null' % ipaddr, shell=True) == 0: print '%s is OK' % ipaddrip = ipaddr.split()[0]port = int(ipaddr.split()[1])sqlstr = "INSERT INTO monitor_crawler (ip,port,status) VALUES ('%s',%d,0)" % (ip, port)insert_mysql(sqlstr)else: print '%s is DOWN' % ipaddr ip = ipaddr.split()[0]port = int(ipaddr.split()[1])sqlstr = "INSERT INTO monitor_crawler (ip,port,status) VALUES ('%s',%d,1)" % (ip, port)insert_mysql(sqlstr)pool = multiprocessing.Pool(processes=process_number) 
for ip in host_list: pool.apply_async(ping_host,(ip,)) 
pool.close() 
pool.join()

?