日志文件分析---统计五分钟内流量和

先发个日志的格式参考：

#! -*- coding: utf-8 -*-
import time
import re
import xlrd
from xlwt import *
def get_fluxandtime(filename):
    with open(filename,"r") as f:
        reg = r"\[(\d+?)\]"
        flux_reg = re.compile(reg)
        list1 = {}
        for line in f:
            _time = line.split(",")[0]
            _time2 = time.strptime(_time,'%Y-%m-%d %H:%M:%S')
            _date_shijianchuo = int(time.mktime(_time2))
            flux1 = re.findall(flux_reg,line)
            _flux1 = ''.join(flux1)
            _5mintues = (_date_shijianchuo / 300)*300
            timeArray = time.localtime(_5mintues)
            otherStyleTime = time.strftime("%Y-%m-%d %H:%M:%S", timeArray)
            list1[otherStyleTime] = list1.get(otherStyleTime,0) + int(_flux1)
        return list1

def input_excel():
    details = get_fluxandtime("ASDL_log_20140310")
    a_date = details.keys()
    row =1
    w = Workbook()
    sheet = w.add_sheet('pv_flux_sum',cell_overwrite_ok=True)
    for b_date in a_date:
        _flux = details[b_date]
        flux_in = _flux/1024/1024
        Titles = ("time,pv_flux_sum(MB)").split(",")
        ceii = 0
        for title in Titles:
            sheet.write(0,ceii,title)
            ceii +=1
        sheet.write(row,0,b_date)
        sheet.write(row,1,flux_in)
        row += 1
    time_sjc = time.time()
    w.save("pv-objct_sum_%s.xls"%time_sjc)


if __name__ == '__main__':
    # print get_fluxandtime("ASDL_log_20140310")
    input_excel()