From 592084973f53ecf898a5d541bee28a17b9fc0f05 Mon Sep 17 00:00:00 2001 From: James Muscat Date: Tue, 28 Apr 2015 12:13:33 +0100 Subject: [PATCH] Tally each type of message we see, so we can track use of new schemas as they get deployed. --- src/eddn/Gateway.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/eddn/Gateway.py b/src/eddn/Gateway.py index 39f1563..d71ba24 100644 --- a/src/eddn/Gateway.py +++ b/src/eddn/Gateway.py @@ -128,6 +128,8 @@ def parse_and_error_handle(data): if validationResults.severity <= ValidationSeverity.WARN: + statsCollector.tally(parsed_message["$schemaRef"]) + parsed_message['header']['gatewayTimestamp'] = datetime.utcnow().isoformat() ip_hash_salt = Settings.GATEWAY_IP_KEY_SALT