spark: add log filter snippet for regex-based log filtering
This commit is contained in:
1 parent
794e21ba43
commit
041966ae30
1 file changed
+16
@@ -0,0 +1,16 @@
|
||||
#!/usr/bin/env python3
|
||||
"""Quick log filter snippet - filter log lines by regex pattern."""
|
||||
|
||||
import re
|
||||
import sys
|
||||
|
||||
def filter_lines(lines, pattern):
|
||||
"""Filter lines matching regex pattern."""
|
||||
regex = re.compile(pattern)
|
||||
return [line for line in lines if regex.search(line)]
|
||||
|
||||
if __name__ == "__main__":
|
||||
pattern = sys.argv[1] if len(sys.argv) > 1 else "ERROR"
|
||||
lines = sys.stdin.readlines()
|
||||
for line in filter_lines(lines, pattern):
|
||||
sys.stdout.write(line)
|
||||
Reference in new issue
Block a user