diff --git a/wizard-work/spark/log_filter.py b/wizard-work/spark/log_filter.py new file mode 100644 index 0000000..0846671 --- /dev/null +++ b/wizard-work/spark/log_filter.py @@ -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) \ No newline at end of file