commit 01e2b9be882cb7cc6b419affb8410ad60577c169
author Krysiak Adam <adam.krysiak@nokia.com> Thu Dec 20 15:33:52 2018 +0100
committer Krysiak Adam <adam.krysiak@nokia.com> Thu Dec 20 15:34:52 2018 +0100
tree 88690ab85705e22c0185929b90617aa5664d0f8d
parent 3328d4f819471637c738eb0689d19780f8cfa324

Fix error tag condition

Compared status code to integer instead of string

Issue-ID: CLAMP-256
Change-Id: I88536238f3058574c6971df8ab9bd963ea20dad7
Signed-off-by: Krysiak Adam <adam.krysiak@nokia.com>

kubernetes/clamp/charts/clamp-dash-logstash/resources/config/pipeline.conf

diff --git a/kubernetes/clamp/charts/clamp-dash-logstash/resources/config/pipeline.conf b/kubernetes/clamp/charts/clamp-dash-logstash/resources/config/pipeline.conf
index 317b428..78ca65a 100644
--- a/kubernetes/clamp/charts/clamp-dash-logstash/resources/config/pipeline.conf
+++ b/kubernetes/clamp/charts/clamp-dash-logstash/resources/config/pipeline.conf
@@ -57,13 +57,13 @@
         drop { }
     }
 
-    if [http_request_failure] or [@metadata][code] != "200" {
+    if [http_request_failure] or [@metadata][code] != 200 {
        mutate {
        	   add_tag => [ "error" ]
        }
     }
 
-    if "dmaap_source" in [tags] {
+    if "dmaap_source" in [@metadata][request][tags] {
         #
         # Dmaap provides a json list, whose items are Strings containing the event
         # provided to Dmaap, which itself is an escaped json.
@@ -76,13 +76,26 @@
             source => "[message]"
             target => "message"
         }
-        ruby {
-            code => "
-            for ev in event.get('message', [])
-                ev.set('@metadata', event.get('@metadata'))
-            end
-            "
-        }
+#        ruby {
+#            code => '
+#            require "json"
+#            puts "\n======================================= MESSAGE"
+#            print event.get("message")
+#            puts "\n======================================= METADATA"
+#            print event.get("@metadata")
+#            puts ""
+#
+#
+#            for ev in event.get("message")
+#                puts "\n======================================= PARSED JSON EV"
+#                print JSON.parse(ev)
+#                puts "\n======================================= JSON EV"
+#                print JSON.parse(ev).get("@metadata")
+#                puts ""
+#                ev.set("[@metadata]", event.get("@metadata"))
+#            end
+#            '
+ #       }
     	
         split {
             field => "message"
@@ -194,7 +207,7 @@
     }
 
 
-    if "error" not in [tags] {
+    if "error" not in [@metadata][request][tags]{
         #
         # Creating data for a secondary index
         #
@@ -203,7 +216,7 @@
             add_tag => [ "event-cl-aggs" ]
         }
         
-        if  "event-cl-aggs" in [tags] {
+        if  "event-cl-aggs" in [@metadata][request][tags]{
             #
             # we only need a few fields for aggregations; remove all fields from clone except :
             #   vmName,vnfName,vnfType,requestID,closedLoopAlarmStart, closedLoopControlName,closedLoopAlarmEnd,abated,nbrDmaapevents,finalFailure