Fix JSON message handling

2022-11-15 23:22:53 +02:00 · 2022-11-15 23:22:53 +02:00 · ca854f60e5
parent 3b0787e37f
commit ca854f60e5
1 changed files with 1 additions and 1 deletions
--- 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: