diff options
author | Toni Uhlig <matzeton@googlemail.com> | 2020-07-10 22:14:23 +0200 |
---|---|---|
committer | Toni Uhlig <matzeton@googlemail.com> | 2020-07-10 22:14:23 +0200 |
commit | d1739d97a8e01ebae3a93855d6ce13d280093ad1 (patch) | |
tree | 1100a1fe7f00e8fda8c7d9777f0e9d5ead1bf6a5 | |
parent | c2aa13c0102997b91b4fb54114c1da3e695418b7 (diff) |
support json key w/o value filtering
Signed-off-by: Toni Uhlig <matzeton@googlemail.com>
-rwxr-xr-x | nDPId-collect.py | 11 |
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) |