Discussion :

[max235]

Bonjour,

J'ai un problème avec mon script qui utilise les threads. Dès que j'exécute plus de un thread, les threads font tout leur boulot correctement, mais une fois fini, le programme plante et je se suis obligé de le killer car je ne peux pas récupérer ma console. D'après les tests que j'ai pu effectué, c'est dès lors que le premier thread a terminé, que le programme plante. Et la je n'arrive vraiment pas à comprendre le problème.

Voici mon code pour plus de détails:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
 
class analyse(Thread):
        def __init__(self):
                Thread.__init__(self)
 
        def run(self):
                while len(PORT) != 0:
                        i = PORT.pop()
                        snmp_in = os.popen("snmpget -v 2c -c **** " + i[1] + " IF-MIB::ifInUcastPkts." + str(i[0]))
                        for a in snmp_in:
                                ucast_in = re.search(match, a).group()
                        snmp_out = os.popen("snmpget -v 2c -c **** " + i[1] + " IF-MIB::ifOutUcastPkts." + str(i[0]))
                        for a in snmp_out:
                                ucast_out = re.search(match, a).group()
                        id_port = str(i[2])
                        con1.query("INSERT INTO traffic VALUES ('" + id_port + "', current_timestamp, '" + ucast_in + "', '" + ucast_out + "')" )
                        print i
                        print " OK"
                        print len(PORT)
                print "FIN"
 
con1 = pg.connect(****)
PORT = con1.query("SELECT ifIndex, ip, switch_port.id FROM switch_port, switch WHERE switch_port.id_switch = switch.id;").getresult()
match = re.compile('(?<=Counter32:\s)\d+$')
# Permet de choisir le nombre de threads à créer
x = 5
getlist = []
for i in range(0,x):
        current = analyse()
        getlist.append(current)
        current.start()
 
for proc in getlist:
        proc.join()
 
sys.exit(0)

Merci d'avance

[max235]

Suite aux nouveaux tests effectués, le problème viendrait de la requête SQL dans le run. Mais je ne comprends toujours pas pourquoi

[max235]

Bon je continue mon monoloque

J'ai réussi à régler le problème. Pour ceux que ca intéresse, le module pygresql ne supporte pas les threads, et c'est donc pour cela que le programme planté. J'ai donc mis en place le module DBUtils qui permet d'établir des connexions persistantes par thread avec la base de données.