Changeset 871 for trunk/Monitoring/Watch/watch

Timestamp:

06/11/13 09:33:58 (11 years ago)

Author:

jripsl

Message:

Improve "config-card" file handling.
Use explicite function for "repo_io" module initialization

File:

• trunk/Monitoring/Watch/watch (modified) (5 diffs)

trunk/Monitoring/Watch/watch

@@ -29 +29 @@
 import smon.types
 
-"""
-Code list reminder
-
-0000 (la simulation démarre)
-1000 (le job d'une simulation démarre)
-2000 (PushStack)
-3000 (PopStack OK)
-9000 (PopStack NOK)
-9999 (FATAL)
-"""
-
 class Mail():
 
@@ -129 +118 @@
         @classmethod
         def start(cls):
-                pass
+                repo_io.init() # open DB connection
 
         @classmethod
         def stop(cls):
-                pass
+                repo_io.free() # close DB connection
 
         @classmethod
@@ -174 +163 @@
 
                                 # debug
-                                print " [x] Received %s" % field
+                                #print " [x] Received %s" % field
 
                                 splitted_field=field.split(":")
@@ -185 +174 @@
 
                         # debug
-                        print " [x] Received %s (encoded)" % l__tmp_dic["body"]
+                        #print " [x] Received %s (encoded)" % l__tmp_dic["body"]
 
                         
@@ -194 +183 @@
                         # debug
                         #print " [x] Received %s" % raw_msg
-                        print " [x] Received %s (uudecoded)" % base64_decoded_msg 
                         #print " [x] Received %s (uudecoded)" % base64_decoded_msg 
-
-
+                        #print " [x] Received %s (uudecoded)" % base64_decoded_msg 
+
+
+                        # message deserialization 
                         message=None
                         try:
-                                # body deserialization 
                                 JSON_msg=json.loads(base64_decoded_msg)
                                 message=smon.types.Message(JSON_msg)      # all JSON object members will be available in smon.types.Message object
 
-                                if "file" in l__tmp_dic:
-
-                                        # base64 decode file
-                                        base64_decoded_file=base64.b64decode(l__tmp_dic["file"])
-
-                                        # add into msg
-                                        message.file=base64_decoded_file
-
+
+
+                        except Exception,e:
+                                print "ERR009 - exception occurs (exception=%s,msg=%s)"%(str(e),base64_decoded_msg)
+
+                                #traceback.print_exc()
+                                #raise
+
+
+
+                        # manage config-card file which is attached to the "0000" type message (this file is base64 encoded and need to be unencoded)
+                        #
+                        if "file" in l__tmp_dic:
+
+                                # base64 decode file
+                                base64_decoded_file=base64.b64decode(l__tmp_dic["file"])
+
+                                # add as msg attribute
+                                message.file=base64_decoded_file
+
+
+
+                        # execute actions
+                        try:
                                 # message code based action
-                                Actions.execActions(message)
-
+                                #Actions.execActions(message)
+                                pass
                         except Exception,e:
-                                print "Exception occurs (exception=%s,msg=%s)"%(str(e),base64_decoded_msg)
-
-                                #traceback.print_exc()
+                                print "ERR019 - exception occurs (exception=%s,msg=%s)"%(str(e),base64_decoded_msg)
+
+                                traceback.print_exc()
 
                                 raise
+
+
 
                 self.channel.basic_consume(callback, queue='myqueue', no_ack=True)