analize.py 文件源码

def main(log_dir='.'):

    # Check stack.sh status
    rm = 'stack_failed'
    log = "%s/%s/logs/stack.sh.log.gz" % ( log_dir, known_issues[rm]['file'])
    last_line = commands.getoutput('tail -n1 %s ' % log)
    if last_line.find(known_issues[rm]['pattern']) >= 0:
        send_email(rm)
    del known_issues[rm]


    for rm, details in known_issues.iteritems():
        try:
            log = "%s/%s" % ( log_dir, details['file'])
            print ("Checking %s for %s" % (log, details['pattern']))
            if details['pattern'] in open(log).read():
                print "RM#%s happened again in %s" % (rm, log_dir)
                send_email(rm)
        except Exception as e:
            print "Exception %s" % ( e )
            pass