Add cloudtrail sqs queue name as a tag to each event

mozilla · Feb 12, 2020 · 87b1083 · 87b1083
1 parent 1eb6a01
commit 87b1083
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/mq/esworker_cloudtrail.py b/mq/esworker_cloudtrail.py
@@ -62,6 +62,7 @@ def keyMapping(aDict):
     returndict["category"] = "cloudtrail"
     returndict["processid"] = str(os.getpid())
     returndict["processname"] = sys.argv[0]
+    returndict["tags"] = [options.taskexchange]
     returndict["severity"] = "INFO"
     if "sourceIPAddress" in aDict and "eventName" in aDict and "eventSource" in aDict:
         summary_str = "{0} performed {1} in {2}".format(