[surveillance/{filtrage_netacct,statistiques}.py] Traitement protocoles inconnus
Si le protocole est inconnu, on utilise -1 (par contrainte dans la base Pgsql, l'id doit correspondre à un protocole inscrit dans la table protocole). Statistiques.py envoie un resume des IPs ayant envoye des paquets avec des protocoles Ethernet inconnus. darcs-hash:20091120165732-ddb99-21e096790eb19b1ca581bc14b487241ffde5d721.gz
This commit is contained in:
parent
d0a6e18cf5
commit
a29343a4d4
2 changed files with 42 additions and 0 deletions
|
@ -30,6 +30,18 @@ reseau = config.NETs['all']
|
|||
pgsql = PgSQL.connect(host='pgsql.adm.crans.org', database='filtrage', user='crans')
|
||||
pgsql.autocommit = True
|
||||
|
||||
# Récupération de la table de protocoles :
|
||||
##########################################
|
||||
requete = "SELECT id from protocole"
|
||||
curseur = pgsql.cursor()
|
||||
curseur.execute(requete)
|
||||
curseur.fetchall
|
||||
tableau = curseur.fetchall()
|
||||
protocole = []
|
||||
for cellule in tableau:
|
||||
protocole.append(cellule[0])
|
||||
|
||||
|
||||
# Fonction de commit :
|
||||
######################
|
||||
def commit(act, prec={'donnees':0}):
|
||||
|
@ -59,6 +71,9 @@ def commit(act, prec={'donnees':0}):
|
|||
port_crans = int(act["port_%s" % crans])
|
||||
port_ext = int(act["port_%s" % ext])
|
||||
|
||||
if proto not in protocole:
|
||||
proto = -1
|
||||
|
||||
# Traitement dans la base SQL
|
||||
date = strptime.syslog2pgsql(strftime("%b %d %H:%M:%S",localtime(int(act["date"]))))
|
||||
curseur = pgsql.cursor()
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue