From ca854f60e59cb49e10868a3f14d9ee99731dc00b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lauri=20V=C3=B5sandi?= Date: Tue, 15 Nov 2022 23:22:53 +0200 Subject: [PATCH] Fix JSON message handling --- log_shipper.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/log_shipper.py b/log_shipper.py index c4fa87f..8014c0b 100755 --- a/log_shipper.py +++ b/log_shipper.py @@ -381,7 +381,7 @@ class LogFile(object): if args.parse_json and o["message"].startswith("{\""): # TODO: Follow Filebeat hints try: - j = ujson.loads(message) + j = ujson.loads(o["message"]) except ujson.JSONDecodeError: counter_heuristic_failures.labels("invalid-json").inc() else: