aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorToni Uhlig <matzeton@googlemail.com>2020-07-10 22:14:23 +0200
committerToni Uhlig <matzeton@googlemail.com>2020-07-10 22:14:23 +0200
commitd1739d97a8e01ebae3a93855d6ce13d280093ad1 (patch)
tree1100a1fe7f00e8fda8c7d9777f0e9d5ead1bf6a5
parentc2aa13c0102997b91b4fb54114c1da3e695418b7 (diff)
support json key w/o value filtering
Signed-off-by: Toni Uhlig <matzeton@googlemail.com>
-rwxr-xr-xnDPId-collect.py11
1 files changed, 8 insertions, 3 deletions
diff --git a/nDPId-collect.py b/nDPId-collect.py
index 5c84ca19e..ec1ce375b 100755
--- a/nDPId-collect.py
+++ b/nDPId-collect.py
@@ -17,6 +17,8 @@ def json_filter_check(json_object):
return True
for (key, value) in JSON_FILTER:
if key in json_object:
+ if value is None:
+ return True
if str(json_object[key]) == str(value):
return True
return False
@@ -46,10 +48,13 @@ class JsonCollector(asyncio.Protocol):
def main():
for arg in sys.argv[1:]:
kv = arg.split('=')
- if len(kv) != 2:
- sys.stderr.write('JSON filter format invalid for argument "{}", required format: "key=value"\n'.format(str(arg)))
+ if len(kv) == 1:
+ json_filter_add(kv[0], None)
+ elif len(kv) == 2:
+ json_filter_add(kv[0], kv[1])
+ else:
+ sys.stderr.write('JSON filter format invalid for argument "{}", required format: either "key" or "key=value"\n'.format(str(arg)))
sys.exit(1)
- json_filter_add(kv[0], kv[1])
loop = asyncio.get_event_loop()
coro = loop.create_unix_server(JsonCollector, JSON_SOCKPATH)