From 29d3994e612fab7c91c6cb05d94d3916bdb7c27c Mon Sep 17 00:00:00 2001
From: Matthias Puhr <42067854+puv13@users.noreply.github.com>
Date: Tue, 5 Nov 2019 15:43:14 +0100
Subject: [PATCH] Fixes column names in logstash config
The 'jdbc_streaming' plugin converts all column names to lowercase. This commit changes the column names in 'lookupResult' accordingly.
---
chapter-10/files/logstash_sensor_data_http.conf | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/chapter-10/files/logstash_sensor_data_http.conf b/chapter-10/files/logstash_sensor_data_http.conf
index 8363740..41c3b74 100644
--- a/chapter-10/files/logstash_sensor_data_http.conf
+++ b/chapter-10/files/logstash_sensor_data_http.conf
@@ -19,15 +19,15 @@ filter {
}
mutate {
- rename => {"[lookupResult][0][sensorType]" => "sensorType"}
+ rename => {"[lookupResult][0][sensortype]" => "sensorType"}
rename => {"[lookupResult][0][customer]" => "customer"}
rename => {"[lookupResult][0][department]" => "department"}
- rename => {"[lookupResult][0][buildingName]" => "buildingName"}
+ rename => {"[lookupResult][0][buildingname]" => "buildingName"}
rename => {"[lookupResult][0][room]" => "room"}
rename => {"[lookupResult][0][floor]" => "floor"}
- rename => {"[lookupResult][0][locationOnFloor]" => "locationOnFloor"}
+ rename => {"[lookupResult][0][locationonfloor]" => "locationOnFloor"}
add_field => {
- "location" => "%{[lookupResult][0][latitude]},%{[lookupResult][0][longitude]}"
+ "location" => "%{[lookupResult][0][latitude]},%{[lookupresult][0][longitude]}"
}
remove_field => ["lookupResult", "headers", "host"]
}