1
2
3
4
5
6
7
8
9
10
11
12
13
14 import os,random
15 from twisted.internet import utils, reactor
16
17 from zephir.monitor.config import Config
18
19 from zephir.monitor import website
20 try:
21 import zephir.zephir_conf.zephir_conf as conf_zeph
22 from zephir.lib_zephir import zephir_proxy, convert
23 except:
24
25 pass
26
28 """Appelle un agent
29 """
31 self.name = name
32 self.xml_filename = Config().get_xml_name(self.name)
33 self.delay = delay
34
35 self._run_agent()
36
38 try:
39 adresse_zephir = conf_zeph.adresse_zephir
40 except:
41
42 pass
43 else:
44 retour=os.system(Config().get_agent_script(self.name))
45
46 reactor.callLater(self.delay, self._run_agent)
47
49 """Modifie en live le nouveau délai
50 """
51 self.delay = delay
52
54 """Récupère la liste des agents et Créée les objets agent correspondant
55 """
65
71
73 """Lancement de la génération du site web
74 et envoi à zephir
75 """
76
77 conf_ok = 1
78
79 timeout = 600
80 try:
81 reload(conf_zeph)
82 adresse_zephir = conf_zeph.adresse_zephir
83
84 timeout = convert(zephir_proxy.serveurs.get_timeout(conf_zeph.id_serveur)[1])
85 except:
86 conf_ok = 0
87
88 reactor.callLater(timeout, self.run_website)
89 if conf_ok == 1:
90
91 web = website.Site()
92
93 web.send_zephir()
94
95 if __name__ == "__main__":
96 lance = Lanceur()
97 lance.create()
98
99
100 try:
101 timeout = convert(zephir_proxy.serveurs.get_timeout(conf_zeph.id_serveur)[1])
102 except:
103
104 timeout = 600
105 delay = random.randrange(60,timeout)
106 reactor.callLater(delay, lance.run_website)
107 reactor.run()
108