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

A suivre...

Browse source 
darcs-hash:20051129210841-6d78a-e827d6bc0789fca58a079e737f820aa2d09484ed.gz
This commit is contained in:
pessoles 2005-11-29 22:08:41 +01:00
parent 000784bbd2
commit 04a7f54889
1 changed files with 18 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

25
surveillance/deconnexion.py
View file

@ -65,12 +65,23 @@ ldap = crans_ldap()
# Vérification de l'upload et du download #
###########################################
# Table des uploaders :
#######################
requete = "SELECT round(sum(upload)/1024/1024) AS total,ip_crans FROM upload WHERE upload>download AND date>timestamp 'now' - interval '1 day' AND date<'now' AND NOT EXISTS ( SELECT 1 FROM exemptes WHERE upload.ip_crans<<=exemptes.ip_crans and upload.ip_ext<<=exemptes.ip_dest) GROUP BY ip_crans ORDER BY total desc"
requete = "SELECT ip_crans,round(sum(upload)/1024/1024) AS total FROM upload WHERE upload>download AND date>timestamp 'now' - interval '1 day' AND date<'now' AND NOT EXISTS ( SELECT 1 FROM exemptes WHERE upload.ip_crans<<=exemptes.ip_crans and upload.ip_ext<<=exemptes.ip_dest) GROUP BY ip_crans ORDER BY total desc"
curseur.execute(requete)
uploadeurs= curseur.fetchall()
uploadeurs_dump = curseur.fetchall()
uploadeurs = uploadeurs_dump
requete = "SELECT ip_crans,round(sum(upload)/1024/1024) AS total FROM dump WHERE upload>download AND NOT EXISTS ( SELECT 1 FROM exemptes WHERE upload.ip_crans<<=exemptes.ip_crans and upload.ip_ext<<=exemptes.ip_dest) GROUP BY ip_crans ORDER BY total desc"
curseur.execute(requete)
uploadeurs_dump += curseur.fetchall()
uploadeurs_dump.sort()
#for i in range(0,len(uploadeurs_dump)-1):
# if uploadeurs_dump[i][0]==uploadeurs_dump[i+1][0]:
# uploadeurs_dump[i][1]=uploadeurs_dump[i][1]+uploadeurs_dump[i+1][1]
# uploadeurs_dump.pop(i+1)
# Table des avertis
###################
@ -359,6 +370,4 @@ for ip, id_p2p, nombre in fraudeurs :
# fermeture des connections
mail.quit()
# On vide la base de dump
requete="DELETE FROM dump"
curseur.execute(requete)