blob: fbf41a62bb73677f668312743d29b13e88e5849a (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
import argparse
import os
import sys
PIPELINE_MARKER = "[Pipeline]"
PIPELINE_BLOCK_START = '{'
PIPELINE_BLOCK_START_NOTE = '('
PIPELINE_BLOCK_START_NOTE_END= ')'
PIPELINE_BLOCK_END = '}'
PIPELINE_BLOCK_END_NOTE = "//"
def consume_token(s, token):
return s[s.find(token) + len(token) + 1:]
def parse_log(filename):
block_depth = 0
block_reading = False
data = open(filename, "r").read()
for lineno, line in enumerate(data.splitlines()):
# Consume pipeline marker
if line.startswith(PIPELINE_MARKER):
event_type = ""
event_name = ""
line = consume_token(line, PIPELINE_MARKER)
if line.startswith(PIPELINE_BLOCK_END):
line = consume_token(line, PIPELINE_BLOCK_END)
block_reading = False
block_depth -= 1
print(f"Block depth: {block_depth}")
elif line.startswith(PIPELINE_BLOCK_END_NOTE):
continue
if line.startswith(PIPELINE_BLOCK_START):
line = consume_token(line, PIPELINE_BLOCK_START)
if line.startswith(PIPELINE_BLOCK_START_NOTE):
event_name = line[1:len(line) - 1]
block_reading = True
block_depth += 1
print(f"Block depth: {block_depth}")
else:
event_type = line
if event_type:
print(f"[{lineno}] Event Type: {event_type}")
if event_name:
print(f"[{lineno}] Event Desc.: {event_name}")
elif block_reading:
print(f"[{lineno}] Data: {line}")
def main():
parser = argparse.ArgumentParser()
parser.add_argument('logfile')
args = parser.parse_args()
if not os.path.exists(args.logfile):
print(f"{args.logfile}: does not exist")
parse_log(args.logfile)
if __name__ == "__main__":
sys.exit(main())
|
