一種日志實(shí)時(shí)處理方法及系統(tǒng)

基本信息

申請(qǐng)?zhí)?/td> CN201910897915.X 申請(qǐng)日 -
公開(公告)號(hào) CN110825598A 公開(公告)日 2020-02-21
申請(qǐng)公布號(hào) CN110825598A 申請(qǐng)公布日 2020-02-21
分類號(hào) G06F11/34;G06F16/18 分類 計(jì)算;推算;計(jì)數(shù);
發(fā)明人 周滔 申請(qǐng)(專利權(quán))人 武漢智美互聯(lián)科技有限公司
代理機(jī)構(gòu) 北京匯信合知識(shí)產(chǎn)權(quán)代理有限公司 代理人 王維新
地址 430000 湖北省武漢市東湖新技術(shù)開發(fā)區(qū)光谷大道77號(hào)金融后臺(tái)服務(wù)中心基地建設(shè)項(xiàng)目二期B17棟11層01室-7
法律狀態(tài) -

摘要

摘要 本發(fā)明公開了一種日志實(shí)時(shí)處理方法及系統(tǒng),包括:接收日志:采用mmap的libpcap捕獲日志報(bào)文;過濾報(bào)文:根據(jù)發(fā)送日志的設(shè)備IP過濾掉非法報(bào)文;解析日志:按照預(yù)設(shè)格式逐個(gè)字段解析日志;格式化日志:按照預(yù)設(shè)字段順序拼接成標(biāo)準(zhǔn)csv格式的字符串,多線程入無鎖隊(duì)列;生成csv文件:根據(jù)硬件適配寫csv文件的線程及多隊(duì)列的數(shù)量;采用所適配的多線程多隊(duì)列,從無鎖隊(duì)列中取出數(shù)據(jù)寫入csv文件中;csv文件入庫:動(dòng)態(tài)監(jiān)測(cè)csv文件大小,若csv文件大于預(yù)設(shè)閾值,則立即入庫;對(duì)數(shù)據(jù)庫表進(jìn)行分區(qū)并設(shè)定索引key值;數(shù)據(jù)匯聚:按照預(yù)設(shè)條件對(duì)數(shù)據(jù)庫的原始數(shù)據(jù)進(jìn)行匯聚。