Skip to content

Commit be14d73

Browse files
committed
chg: [zmq importer] add filter content
1 parent eb8cc79 commit be14d73

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

bin/importer/ZMQImporter.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,8 +41,9 @@ def get_zmq_filter():
4141
str_end = d.get('end')
4242
file_start = d.get('file_start')
4343
file_end = d.get('file_end')
44+
content = d.get('content')
4445
description = d.get('description')
45-
if not str_start and not str_end and not file_start and not file_end:
46+
if not str_start and not str_end and not file_start and not file_end and not content:
4647
continue
4748
feeder = {'description': description}
4849
if str_start and str_end:
@@ -52,6 +53,8 @@ def get_zmq_filter():
5253
feeder['file_start'] = file_start
5354
if file_end:
5455
feeder['file_end'] = file_end
56+
if content:
57+
feeder['content'] = content
5558
filters[feeder_name].append(feeder)
5659
print('loaded zmq filters: ', filters)
5760
return filters
@@ -138,6 +141,10 @@ def compute(self, messages):
138141
if same_pattern:
139142
to_filter = True
140143
break
144+
elif 'content' in f:
145+
if content == f['content']:
146+
to_filter = True
147+
break
141148
elif 'file_start' in f:
142149
if content.startswith(f['file_start']):
143150
to_filter = True

0 commit comments

Comments
 (0)