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

Une fois suffit

Browse source 
darcs-hash:20060103190628-6d78a-83be4f0dac0d3d777e648ffbb734feab0a8ce1f2.gz
This commit is contained in:
pessoles 2006-01-03 20:06:28 +01:00
parent 772fd71a44
commit f45ef90c90
1 changed files with 1 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

8
surveillance/filtrage_firewall.py
View file

@ -26,15 +26,13 @@ reseau = ["138.231.136.0/21", "138.231.148.0/22"]
###################################
pgsql = PgSQL.connect(host='rouge.adm.crans.org', database='filtrage', user='crans')
pgsql.autocommit = True
curseur = pgsql.cursor()
###########################################
# Récupération des tables de protocoles : #
###########################################
curseur = pgsql.cursor()
requete = "SELECT nom,id_p2p from protocole_p2p"
curseur.execute(requete)
curseur.fetchall
@ -43,7 +41,6 @@ protocole_p2p = {}
for cellule in tableau:
protocole_p2p[cellule[0]]=cellule[1]
curseur = pgsql.cursor()
requete = "SELECT nom,id from protocole"
curseur.execute(requete)
curseur.fetchall
@ -94,7 +91,6 @@ for log in filtre :
# On remplit la base :
######################
curseur = pgsql.cursor()
requete = "INSERT INTO p2p (date,ip_src,ip_dest,id_p2p,id,port_src,port_dest) VALUES ('%s','%s','%s',%d,%d,%d,%d)" % (date,ip_src,ip_dest,id_p2p,proto,port_src,port_dest)
curseur.execute(requete)
@ -113,7 +109,6 @@ for log in filtre :
# On remplit la base :
######################
date=strptime.syslog2pgsql(date)
curseur = pgsql.cursor()
requete = "INSERT INTO virus (date,ip_src,ip_dest,id,port_src,port_dest) VALUES ('%s','%s','%s',%d,%d,%d)" % (date,ip_src,ip_dest,proto,port_src,port_dest)
curseur.execute(requete)
@ -131,6 +126,5 @@ for log in filtre :
# On remplit la base :
######################
date=strptime.syslog2pgsql(date)
curseur = pgsql.cursor()
requete = "INSERT INTO flood (date,ip_src,ip_dest,id,port_src,port_dest) VALUES ('%s','%s','%s',%d,%d,%d)" % (date,ip_src,ip_dest,proto,port_src,port_dest)
curseur.execute(requete)