Skip to content

Commit

Permalink
Cherry-pick to 6.6: Ignore timestamp in redis, haproxy and system fil…
Browse files Browse the repository at this point in the history
…ebeat module (#9855) (#9858) (#10072)

(cherry picked from commit b9a20f7)

The icing/startup log file does not contain a timestamp. Because of this the timestamp from filebeat is taken. During the generation of golden files still a timestamp was added but every skipped on comparison. Instead now the timestamp is not added to the generated file anymore to now show a diff each time GENERATE is run.

(cherry picked from commit 6defdd4)

Co-authored-by: Nicolas Ruflin <spam@ruflin.com>
Co-authored-by: kaiyan-sheng <kaiyan.sheng@elastic.co>
  • Loading branch information
3 people authored Jan 17, 2019
1 parent 5a582bd commit 38a4856
Show file tree
Hide file tree
Showing 8 changed files with 6 additions and 27 deletions.
1 change: 0 additions & 1 deletion filebeat/module/haproxy/log/test/default.log-expected.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
[
{
"@timestamp": "2018-09-20T15:42:59.000Z",
"fileset.module": "haproxy",
"fileset.name": "log",
"haproxy.client.ip": "1.2.3.4",
Expand Down
1 change: 0 additions & 1 deletion filebeat/module/haproxy/log/test/haproxy.log-expected.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
[
{
"@timestamp": "2018-07-30T09:03:52.726Z",
"fileset.module": "haproxy",
"fileset.name": "log",
"haproxy.backend_name": "docs_microservice",
Expand Down
1 change: 0 additions & 1 deletion filebeat/module/haproxy/log/test/tcplog.log-expected.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
[
{
"@timestamp": "2018-09-20T15:44:23.285Z",
"fileset.module": "haproxy",
"fileset.name": "log",
"haproxy.backend_name": "app",
Expand Down
2 changes: 0 additions & 2 deletions filebeat/module/icinga/startup/test/test.log-expected.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
[
{
"@timestamp": "2018-07-24T21:15:27.590Z",
"fileset.module": "icinga",
"fileset.name": "startup",
"icinga.startup.facility": "cli",
Expand All @@ -11,7 +10,6 @@
"prospector.type": "log"
},
{
"@timestamp": "2018-07-24T21:15:27.590Z",
"fileset.module": "icinga",
"fileset.name": "startup",
"icinga.startup.facility": "cli",
Expand Down
4 changes: 0 additions & 4 deletions filebeat/module/redis/log/test/test.log-expected.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
[
{
"@timestamp": "2018-05-30T12:23:52.442Z",
"fileset.module": "redis",
"fileset.name": "log",
"input.type": "log",
Expand All @@ -12,7 +11,6 @@
"redis.log.role": "master"
},
{
"@timestamp": "2018-05-30T10:05:20.000Z",
"fileset.module": "redis",
"fileset.name": "log",
"input.type": "log",
Expand All @@ -22,7 +20,6 @@
"redis.log.message": "0 clients connected (0 slaves), 618932 bytes in use, 0 shared objects."
},
{
"@timestamp": "2018-05-31T04:32:08.000Z",
"fileset.module": "redis",
"fileset.name": "log",
"input.type": "log",
Expand All @@ -32,7 +29,6 @@
"redis.log.message": "The server is now ready to accept connections on port 6379\""
},
{
"@timestamp": "2017-05-30T10:57:24.000Z",
"fileset.module": "redis",
"fileset.name": "log",
"input.type": "log",
Expand Down
10 changes: 0 additions & 10 deletions filebeat/module/system/auth/test/test.log-expected.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
[
{
"@timestamp": "2018-02-21T21:54:44.000Z",
"fileset.module": "system",
"fileset.name": "auth",
"input.type": "log",
Expand All @@ -17,7 +16,6 @@
"system.auth.user": "vagrant"
},
{
"@timestamp": "2018-02-23T00:13:35.000Z",
"fileset.module": "system",
"fileset.name": "auth",
"input.type": "log",
Expand All @@ -33,7 +31,6 @@
"system.auth.user": "vagrant"
},
{
"@timestamp": "2018-02-21T21:56:12.000Z",
"fileset.module": "system",
"fileset.name": "auth",
"input.type": "log",
Expand All @@ -47,7 +44,6 @@
"system.auth.user": "test"
},
{
"@timestamp": "2018-02-20T08:35:22.000Z",
"fileset.module": "system",
"fileset.name": "auth",
"input.type": "log",
Expand All @@ -69,7 +65,6 @@
"system.auth.user": "root"
},
{
"@timestamp": "2018-02-21T23:35:33.000Z",
"fileset.module": "system",
"fileset.name": "auth",
"input.type": "log",
Expand All @@ -84,7 +79,6 @@
"system.auth.user": "vagrant"
},
{
"@timestamp": "2018-02-19T15:30:04.000Z",
"fileset.module": "system",
"fileset.name": "auth",
"input.type": "log",
Expand All @@ -96,7 +90,6 @@
"system.auth.timestamp": "Feb 19 15:30:04"
},
{
"@timestamp": "2018-02-23T00:08:48.000Z",
"fileset.module": "system",
"fileset.name": "auth",
"input.type": "log",
Expand All @@ -111,7 +104,6 @@
"system.auth.user": "vagrant"
},
{
"@timestamp": "2018-02-24T00:13:02.000Z",
"fileset.module": "system",
"fileset.name": "auth",
"input.type": "log",
Expand All @@ -127,7 +119,6 @@
"system.auth.user": "tsg"
},
{
"@timestamp": "2018-02-22T11:47:05.000Z",
"fileset.module": "system",
"fileset.name": "auth",
"input.type": "log",
Expand All @@ -140,7 +131,6 @@
"system.auth.timestamp": "Feb 22 11:47:05"
},
{
"@timestamp": "2018-02-22T11:47:05.000Z",
"fileset.module": "system",
"fileset.name": "auth",
"input.type": "log",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
[
{
"@timestamp": "2018-12-13T11:35:28.000Z",
"fileset.module": "system",
"fileset.name": "syslog",
"input.type": "log",
Expand All @@ -16,7 +15,6 @@
"system.syslog.timestamp": "Dec 13 11:35:28"
},
{
"@timestamp": "2018-12-13T11:35:28.000Z",
"fileset.module": "system",
"fileset.name": "syslog",
"input.type": "log",
Expand All @@ -29,7 +27,6 @@
"system.syslog.timestamp": "Dec 13 11:35:28"
},
{
"@timestamp": "2018-04-04T03:39:57.000Z",
"fileset.module": "system",
"fileset.name": "syslog",
"input.type": "log",
Expand Down
11 changes: 6 additions & 5 deletions filebeat/tests/system/test_modules.py
Original file line number Diff line number Diff line change
Expand Up @@ -159,6 +159,7 @@ def _test_expected_events(self, test_file, objects):
for k, obj in enumerate(objects):
objects[k] = self.flatten_object(obj, {}, "")
clean_keys(objects[k])

json.dump(objects, f, indent=4, sort_keys=True)

with open(test_file + "-expected.json", "r") as f:
Expand All @@ -175,11 +176,6 @@ def _test_expected_events(self, test_file, objects):
obj = self.flatten_object(obj, {}, "")
clean_keys(obj)

# Remove timestamp for comparison where timestamp is not part of the log line
if obj["fileset.module"] == "icinga" and obj["fileset.name"] == "startup":
delete_key(obj, "@timestamp")
delete_key(ev, "@timestamp")

if ev == obj:
found = True
break
Expand All @@ -199,6 +195,11 @@ def clean_keys(obj):
for key in host_keys + time_keys + other_keys:
delete_key(obj, key)

# Remove timestamp for comparison where timestamp is not part of the log line
dataset = "%s.%s" % (obj['fileset.module'], obj['fileset.name'])
if dataset in ["icinga.startup", "redis.log", "haproxy.log", "system.auth", "system.syslog"]:
delete_key(obj, "@timestamp")


def delete_key(obj, key):
if key in obj:
Expand Down

0 comments on commit 38a4856

Please sign in to comment.