X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=activity%2F__init__.py;h=4719a61cd800694bd3140aba21728e9608f5d67c;hb=485d5ae5ddd76213a6ba7d80a7a6d5048786b804;hp=ab2cd0d39d92eb88aca3c68a08f57e509301dcd9;hpb=cee44fa48fde5073d590879135c49b360ac411eb;p=unfold.git diff --git a/activity/__init__.py b/activity/__init__.py index ab2cd0d3..4719a61c 100644 --- a/activity/__init__.py +++ b/activity/__init__.py @@ -34,7 +34,7 @@ else : # default log server server = "http://athos.ipv6.lip6.fr/activity/push/log" -def logWrite(request, action, message): +def logWrite(request, action, message, objects = None): if not apikey : print "===============>> activity: no apikey" @@ -54,17 +54,31 @@ def logWrite(request, action, message): "action" : action, "message" : message, "apikey" : apikey, - "signature" : sign(secret, "%s%s%s%s" % (timestamp, ip, request.user, action)) + "signature" : sign(secret, "%s%s%s%s" % (timestamp, ip, request.user, action)), + "slice" : None, + "resource" : None, + "resource_type" : None, + "facility" : None, + "testbed" : None, } + + if objects is not None: + for o in objects : + if (o in log) : + log[o] = objects[o] + try : result = urllib2.urlopen(server, urllib.urlencode(log)) + print "===============>> activity: %s <%s> %s" % (action, request.user,message) content = result.read() except urllib2.URLError as e: print "===============>> activity: connection to " + server + " impossible, could not log action" + print e.strerror + print "" -def log(request, action, message): +def log(request, action, message, objects = None): # Create a new thread in Daemon mode to send the log entry - t = threading.Thread(target=logWrite, args=(request, action, message)) + t = threading.Thread(target=logWrite, args=(request, action, message, objects)) t.setDaemon(True) t.start()