commit 1214c463b693c6ec78b90320ec19b77aa9b20e22
author Michal Kobus <mkobus@mirantis.com> Fri Nov 20 16:17:19 2020 +0100
committer mkobus <mkobus@mirantis.com> Fri Nov 20 15:20:20 2020 +0000
tree 5dac2735cb8fe31d989dadbac68ff3f25c74c87e
parent 89a9135f186b967eae18ea607ce42a53167a3028

Fix key-checking in events extracted from RabbitMQ

Change-Id: I4d9eafc389af8e77ddd75ac5034ad2c21ec7e028
Related-PROD: PROD-35949

fluentd/label/notifications/input_rabbitmq.yml

diff --git a/fluentd/label/notifications/input_rabbitmq.yml b/fluentd/label/notifications/input_rabbitmq.yml
index 3d7edef..06fca7c 100644
--- a/fluentd/label/notifications/input_rabbitmq.yml
+++ b/fluentd/label/notifications/input_rabbitmq.yml
@@ -85,7 +85,7 @@
                 enable_ruby: true
                 record:
                   - name: notification_type
-                    value: '${fluentd:dollar}{ record["payload"]["eventType"] && record["payload"]["eventTime"] ? "audit" : "notification" }'
+                    value: '${fluentd:dollar}{ record["payload"].key?("eventType") && record["payload"].key?("eventTime") ? "audit" : "notification" }'
             match:
               rewrite_message_tag:
                 tag: raw_notifications