sqlio_log_parser.py

sqlio_log_parser.py

import os
import re
import sys
import subprocess
import time
from subprocess import Popen, PIPE

def ps(pid):
    p = Popen('ps -ef | grep {}'.format(pid), shell=True, stdout=PIPE, stderr=PIPE)
    stdout, _ = p.communicate()
    print(stdout.decode())

def follow(thefile):
    # seek the end of the file
    thefile.seek(0, os.SEEK_END)

    # start infinite loop
    while True:
        # read last line of file
        line = thefile.readline()
        # sleep if file hasn't been updated
        if not line:
            time.sleep(0.1)
            continue

        yield line

filein = open(sys.argv[1], 'r')

for line in follow(filein):
    m = re.match(r'^.*replication slot .* is active for PID ([0-9]+)', line)
    if m:
        print("=====================  PS  ======================")
        ps(m.groups()[0])

    m = re.match(r'^.*"stack-trace":"(.*)","serialized-throwable"', line)
    if m:
        print(m.groups()[0].replace(r'\n', '\n').replace(r'\t', '\t'))
        continue

    if 'Unable to obtain Principal Name for authentication' in line:
        continue

    if re.match(r'^[ \t]*(Caused by|at |.*Exception)', line):
        print(line.rstrip())
        continue