Changeset 866 for trunk/Monitoring/Watch/watch

Timestamp:

06/09/13 23:52:36 (11 years ago)

Author:

jripsl

Message:

Add demo scenarios.

File:

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

trunk/Monitoring/Watch/watch

@@ -26 +26 @@
 sys.path.append("/home/jripsl/snapshot/Monitoring")
 
-import smon.repo_io
-
+import smon.repo_io as repo_io
+import smon.types
 
 """
@@ -66 +66 @@
 
         @classmethod
-        def store_msg(cls):
-                repo_io.store_messages(name)
-
-        @classmethod
-        def set_sim_status_to_error(cls):
+        def store_msg(cls,message):
+                repo_io.create_message(message)
+
+        @classmethod
+        def set_sim_status_to_error(cls,message):
                 repo_io.update_simulation_status()
 
         @classmethod
-        def crea_sim(cls):
+        def crea_sim(cls,message):
+
                 #repo_io.retrieve_simulation(name)
                 #repo_io.delete_simulation(name)
-                repo_io.create_simulation()
+
+                simulation=smon.types.Simulation(name=message.simuid)
+
+                repo_io.create_simulation(simulation)
 
         @classmethod
@@ -88 +92 @@
 
                 if "file" in message:
-                        print "%s %s %s\n"%(message["code"],message["jobid"],message["file"])
+                        print "%s %s %s\n"%(message.code,message.jobid,message.file)
                 else:
-                        print "%s %s\n"%(message["code"],message["jobid"])
+                        print "%s %s\n"%(message.code,message.jobid)
 
         @classmethod
         def log(cls,message):
                 with open("/home/jripsl/supervisor/log/supervisor.log", "a") as log_file:
-                        log_file.write("%s %s %s\n"%(datetime.now().strftime('%Y%m%d_%H%M%S'), message["code"],message["jobid"]))
+                        log_file.write("%s %s %s\n"%(datetime.now().strftime('%Y%m%d_%H%M%S'), message.code,message.jobid))
 
         @classmethod
         def execActions(cls,message):
 
-                message_code=message["code"]
+                message_code=message.code
 
                 for action in MessageActionsMapping.mapping[message_code]:
@@ -155 +159 @@
 
                 def callback(ch, method, properties, raw_msg):
-                        #
-                        #return
-
-                        base64_decoded_msg=base64.b64decode(raw_msg)
+
+                        # msg fmt: body:base64,file:base64 (no JSON here !!!)
+
+
+
+
+                        # first deserialization (no JSON here !!!)
+
+                        fields=raw_msg.split(",")
+
+                        l__tmp_dic={}
+
+                        for field in fields:
+
+                                # debug
+                                print " [x] Received %s" % field
+
+                                splitted_field=field.split(":")
+
+                                key=splitted_field[0]
+                                val=splitted_field[1]
+
+                                l__tmp_dic[key]=val
+
+
+                        # debug
+                        print " [x] Received %s (encoded)" % l__tmp_dic["body"]
+
+                        
+                        # base64 decode body
+                        base64_decoded_msg=base64.b64decode(l__tmp_dic["body"])
+
 
                         # debug
                         #print " [x] Received %s" % raw_msg
+                        print " [x] Received %s (uudecoded)" % base64_decoded_msg 
                         #print " [x] Received %s (uudecoded)" % base64_decoded_msg 
+
 
                         message=None
                         try:
-                                message=json.loads(base64_decoded_msg)
+                                # 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
 
                                 # message code based action
-                                Watcher.execActions(message)
+                                Actions.execActions(message)
+
                         except Exception,e:
                                 print "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)
@@ -198 +247 @@
         except Exception, e:
 
-                traceback.print_exc()
+                #traceback.print_exc()
 
                 sys.exit(1)