1
2
3
4
5
6
7
8
9
10
11
12
13 from zephir.backend import config
14 from twisted.enterprise import adbapi
15 import traceback
16
18
20 """errback du deffered
21 """
22 try:
23 traceback.print_exc()
24 return 0, str(error.type), error.getErrorMessage()
25 except:
26 return 0,''
27
29 """callback du deffered
30 """
31 if l:
32 return 1,'ok'
33 else:
34 return 0,"no records"
35 raise DBException("No records")
36
41
42 -def db_log(dbpool,id_serveur,date,type_msg,msg):
43 """insère un log dans la base zephir
44 """
45 query = """insert into log_serveur (id_serveur,date,type,message) values (%s,%s,%s,E%s)"""
46 return dbpool.runOperation(query, (int(id_serveur),date,type_msg,msg))
47
49 """classe utilitaire pour récupérer diverses données sur un serveur"""
50
52 """initialise l'objet serveur et récupère les infos
53 """
54
55 import psycopg2 as pgsql
56 cx = PgSQL.connect(database=config.DB_NAME,user=config.DB_USER,password=config.DB_PASSWD)
57 cu = cx.cursor()
58 cu.execute("select * from serveurs where id=%s", (int(id_s),))
59 cu.close()
60 cx.close()
61