log_parser.py

import time, datetime, re

def parse_go(logger, line):
    event = {
        'msg_text': line,
        'priority': 'low',
    }
    try:
        date = datetime.datetime.strptime(line[:19], "%Y/%m/%d %H:%M:%S")
    except ValueError:
        pass
    else:
        date = time.mktime(date.timetuple())
        event['timestamp'] = date
        if re.search(r'\bpanic\b', line):
            event['alert_type'] = 'warning'
    if line.startswith("panic:"):
        event['priority'] = 'normal'
        event['alert_type'] = 'error'
    return event

def main():
    import sys
    for line in sys.stdin:
        print(globals()[sys.argv[1]](None, line))

if __name__ == '__main__':
    main()