目的：
1、根据文本日志的每行的关键字，对日志进行拆分
2、把拆分后的日志文件，加载到mysql数据库

源码LogDeal.py：
# -*- coding: utf-8 -*- 
import MySQLdb,datetime


#获取当前时间的上一小时
now = datetime.datetime.now()
beforeHour = (now + datetime.timedelta(hours=-1)).strftime("%Y%m%d%H")
print beforeHour


fileDictionary = {}
f = open('log.txt', 'r')
for i in f.readlines():
    fileKey = 'tb' + i.split('|')[0]
    if fileDictionary.has_key(fileKey):
        print u'发现：' + fileKey
    else:
        print u'not find:' + fileKey
        fileName = fileKey + beforeHour
        outFile = open(fileName, 'a')
        fileDictionary[fileKey] = outFile
    #fileDictionary[fileKey].tell()
    #i += '\n'
    fileDictionary[fileKey].write(i)
        
#关闭读文件
f.close()


#关闭写文件
outFiles = fileDictionary.values()
for outFile in outFiles:
    outFile.write('\n')
    outFile.close()


#log文件入库到mysql
tableNames = fileDictionary.keys()
for tableName in tableNames:
    try:
        print tableName
        conn = MySQLdb.connect(host='192.168.1.81', user='noyce', passwd='123', db='test', port=3306)
        cur = conn.cursor()
        sql = "load data local infile '" + tableName + beforeHour + "' into table " + tableName + " fields terminated by '|'";
        print sql
        cur.execute(sql)
        conn.commit()
        cur.close()
        conn.close()
    except MySQLdb.Error, e:  
        print "Mysql Error %d: %s" % (e.args[0], e.args[1])