crans/scripts
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

On passe plus par ldap crans, et on vire les try accept

Browse source 
darcs-hash:20050903150412-6d78a-0321607649bb63d5b07611ee4ec90ed717385a0f.gz
This commit is contained in:
pessoles 2005-09-03 17:04:12 +02:00
parent 97a3602c21
commit f06db0f92d
1 changed files with 26 additions and 51 deletions
Download patch file Download diff file Expand all files Collapse all files

77
surveillance/statistiques.py
View file

@ -9,8 +9,9 @@ import commands
import sys import sys
from pyPgSQL import PgSQL from pyPgSQL import PgSQL
sys.path.append('/usr/scripts/gestion') sys.path.append('/usr/scripts/gestion')
from ldap_crans import crans_ldap from ldap_crans import crans_ldap,crans
import smtplib import smtplib
import socket
############################### ###############################
# Ouverture des connections : # # Ouverture des connections : #
@ -32,19 +33,15 @@ ldap=crans_ldap()
requete = "SELECT ip_crans,sum(upload)/1024/1024 as somme,sum(download)/1024/1024 FROM upload WHERE ip_crans IN (SELECT ip_crans FROM avertis_upload where hard='1' or soft='1') and date > timestamp 'now' - interval '1 day' GROUP BY ip_crans order by somme" requete = "SELECT ip_crans,sum(upload)/1024/1024 as somme,sum(download)/1024/1024 FROM upload WHERE ip_crans IN (SELECT ip_crans FROM avertis_upload where hard='1' or soft='1') and date > timestamp 'now' - interval '1 day' GROUP BY ip_crans order by somme"
curseur.execute(requete) curseur.execute(requete)
hard = curseur.fetchall() hard = curseur.fetchall()
liste_upload=""
for i in range(0,len(hard)): for i in range(0,len(hard)):
IP=hard[i][0] IP=hard[i][0]
machine = ldap.search('ipHostNumber=%s' % IP)['machine'][0] hostname = socket.gethostbyaddr("%s"%IP)[0]
hostname = machine.nom()
upload = round((hard[i][1]),2) upload = round((hard[i][1]),2)
download=round((hard[i][2]),2) download = round((hard[i][2]),2)
if i==0 : liste_upload += "%10s%10s\t%s\n"%(str(upload),str(download),str(hostname))
liste_upload="%10s%10s\t%s\n"%(str(upload),str(download),str(hostname))
else :
liste_upload=liste_upload+"%10s%10s\t%s\n"%(str(upload),str(download),str(hostname))
liste_upload
# Upload exemptés : # Upload exemptés :
################### ###################
@ -52,25 +49,24 @@ for i in range(0,len(hard)):
requete = "SELECT ip_crans,sum(upload)/1024/1024 AS somme , sum(download)/1024/1024 FROM upload WHERE ip_crans IN ( SELECT ip_crans from exemptes) and date > timestamp 'now' - interval '1 day' GROUP BY ip_crans order by somme" requete = "SELECT ip_crans,sum(upload)/1024/1024 AS somme , sum(download)/1024/1024 FROM upload WHERE ip_crans IN ( SELECT ip_crans from exemptes) and date > timestamp 'now' - interval '1 day' GROUP BY ip_crans order by somme"
curseur.execute(requete) curseur.execute(requete)
exemptes = curseur.fetchall() exemptes = curseur.fetchall()
liste_exemptes=""
for i in range(0,len(exemptes)): for i in range(0,len(exemptes)):
IP=exemptes[i][0] IP=exemptes[i][0]
machine = ldap.search('ipHostNumber=%s' % IP)['machine'][0] hostname = socket.gethostbyaddr("%s"%IP)[0]
hostname = machine.nom()
upload=round(exemptes[i][1],2) upload=round(exemptes[i][1],2)
download=round(exemptes[i][2],2) download=round(exemptes[i][2],2)
if i==0 : liste_exemptes=liste_exemptes+"%10s%10s\t%s\n"%(str(upload),str(download),str(hostname))
liste_exemptes="%10s%10s\t%s\n"%(str(upload),str(download),str(hostname))
else :
liste_exemptes=liste_exemptes+"%10s%10s\t%s\n"%(str(upload),str(download),str(hostname))
# Upload des serveurs : # Upload des serveurs :
####################### #######################
for i in (10,1,3,4,5,7,8,9,11):
IP='138.231.136.'+str(i) machines=crans().machines()
machine = ldap.search('ipHostNumber=%s' % IP)['machine'][0] liste_serveurs=""
for machine in machines:
hostname = machine.nom() hostname = machine.nom()
hostname
IP=machine.ip()
requete = "SELECT sum(upload)/1024/1024,sum(download)/1024/1024 FROM upload WHERE ip_crans='%s' AND date > timestamp 'now' - interval '1 day' "%IP requete = "SELECT sum(upload)/1024/1024,sum(download)/1024/1024 FROM upload WHERE ip_crans='%s' AND date > timestamp 'now' - interval '1 day' "%IP
curseur.execute(requete) curseur.execute(requete)
traffic=curseur.fetchall() traffic=curseur.fetchall()
@ -79,32 +75,19 @@ for i in (10,1,3,4,5,7,8,9,11):
except TypeError: except TypeError:
print "Pas d'upload ou download" print "Pas d'upload ou download"
else : else :
upload=round(traffic[0][0],2) liste_serveurs += "%10s%10s\t%s\n"%(str(upload),str(download),str(hostname))
download=round(traffic[0][1],2)
if i==10 :
liste_serveurs="%10s%10s\t%s\n"%(str(upload),str(download),str(hostname))
else :
liste_serveurs=liste_serveurs+"%10s%10s\t%s\n"%(str(upload),str(download),str(hostname))
# Machines infectées : # Machines infectées :
###################### ######################
requete = "SELECT ip_crans FROM avertis_virus WHERE date>timestamp 'now' - interval '1 day'" requete = "SELECT ip_crans FROM avertis_virus WHERE date>timestamp 'now' - interval '1 hour'"
curseur.execute(requete) curseur.execute(requete)
infections = curseur.fetchall() infections = curseur.fetchall()
liste_virus=""
for i in range(1,len(infections)): for i in range(1,len(infections)):
IP=infections[i][0] IP=infections[i][0]
machine = ldap.search('ipHostNumber=%s' % IP)['machine'][0] hostname = socket.gethostbyaddr("%s"%IP)[0]
hostname = machine.nom() liste_virus+="%s\n"%(str(hostname))
try :
print len(liste_virus)
except NameError:
liste_virus="%s%s\n"%('--','--')
else :
if i==0 :
liste_virus="%s\n"%(str(hostname))
else :
liste_virus=liste_virus+"%s\n"%(str(hostname))
# Machines utilisant des protocoles P2P : # Machines utilisant des protocoles P2P :
@ -112,20 +95,12 @@ for i in range(1,len(infections)):
requete = "SELECT ip_crans,protocole FROM avertis_p2p WHERE date>timestamp 'now' - interval '1 day'" requete = "SELECT ip_crans,protocole FROM avertis_p2p WHERE date>timestamp 'now' - interval '1 day'"
curseur.execute(requete) curseur.execute(requete)
p2p = curseur.fetchall() p2p = curseur.fetchall()
liste_p2p=""
for i in range(0,len(p2p)): for i in range(0,len(p2p)):
IP=p2p[i][0] IP=p2p[i][0]
protocole = p2p[i][1] protocole = p2p[i][1]
machine = ldap.search('ipHostNumber=%s' % IP)['machine'][0] hostname = socket.gethostbyaddr("%s"%IP)[0]
hostname = machine.nom() liste_p2p+="%9s\t%s\n"%(str(protocole),str(hostname))
try :
print len(liste_p2p)
except NameError:
liste_p2p="%s%20s\n"%('--','--')
else :
if i==0 :
liste_p2p="%9s\t%s\n"%(str(protocole),str(hostname))
else :
liste_p2p=liste_p2p+"%9s\t%s\n"%(str(protocole),str(hostname))
############# #############
@ -176,5 +151,5 @@ corps = message %{'From':expediteur,
'liste_serveurs':liste_serveurs} 'liste_serveurs':liste_serveurs}
#corps = corps.encode('iso 8859-15') #corps = corps.encode('iso 8859-15')
mail.sendmail('pessoles@crans.org','disconnect@crans.org',corps) #mail.sendmail('pessoles@crans.org','disconnect@crans.org',corps)
#print corps print corps