From c3047e1331748a91323faee256c738e91e34cd3a Mon Sep 17 00:00:00 2001 From: Ben Bangert Date: Fri, 5 May 2017 10:08:25 -0700 Subject: [PATCH] feat: update parquet schema for unified parquet logging Closes #888 --- ...{push.cfg => autopush.autoendpoint.docker.autoendpoint.cfg} | 1 + parquet_schemas/autopush/autopush.autopush.docker.autopush.cfg | 3 +++ 2 files changed, 4 insertions(+) rename parquet_schemas/autopush/{push.cfg => autopush.autoendpoint.docker.autoendpoint.cfg} (93%) create mode 100644 parquet_schemas/autopush/autopush.autopush.docker.autopush.cfg diff --git a/parquet_schemas/autopush/push.cfg b/parquet_schemas/autopush/autopush.autoendpoint.docker.autoendpoint.cfg similarity index 93% rename from parquet_schemas/autopush/push.cfg rename to parquet_schemas/autopush/autopush.autoendpoint.docker.autoendpoint.cfg index 35771505..9dd6b390 100644 --- a/parquet_schemas/autopush/push.cfg +++ b/parquet_schemas/autopush/autopush.autoendpoint.docker.autoendpoint.cfg @@ -1,4 +1,5 @@ -- vim:ft=lua +message_matcher = "(Type == 'autopush.autoendpoint.docker.autoendpoint' || Type == 'autopush.autopush.docker.autopush')" message_matcher = message_matcher .. " && (Fields[Fields.message] == 'Successful delivery' || Fields[Fields.message] == 'Router miss, message stored.' || Fields[Fields.message] == 'Request timings'" message_matcher = message_matcher .. " || Fields[Fields.message] == 'hello' || Fields[Fields.message] == 'Register' || Fields[Fields.message] == 'Unregister' || Fields[Fields.message] == 'Ack' || Fields[Fields.message] == 'Nack')" diff --git a/parquet_schemas/autopush/autopush.autopush.docker.autopush.cfg b/parquet_schemas/autopush/autopush.autopush.docker.autopush.cfg new file mode 100644 index 00000000..9515b3c3 --- /dev/null +++ b/parquet_schemas/autopush/autopush.autopush.docker.autopush.cfg @@ -0,0 +1,3 @@ +message_matcher = 'FALSE' + +parquet_schema = 'message Log {}'