# let us initialize the AuParser
aup = auparse.AuParser(auparse.AUSOURCE_FEED)

# we initalize the callback to be fn_process_event
aup.add_callback(fn_process_event, None)

myfile = "/var/log/audit/audit.log"

while True:
    try:
        # we read in line by line from stdin
        for line in fileinput.input():
        #for line in fileinput.input(myfile):
            aup.feed(line)
    except:
        logger.error("Fatal error in while loop", exc_info=True)

# we flush the feed when we quit
aup.flush_feed()