python實(shí)現(xiàn)linux下抓包并存庫(kù)功能

更新時(shí)間：2018年07月18日 09:11:38 作者：pingnanlee

這篇文章主要為大家詳細(xì)介紹了python實(shí)現(xiàn)linux下抓包并存庫(kù)功能，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

最近項(xiàng)目需要抓包功能，并且抓包后要對(duì)數(shù)據(jù)包進(jìn)行存庫(kù)并分析。抓包想使用tcpdump來(lái)完成，但是tcpdump抓包之后只能保存為文件，我需要將其保存到數(shù)據(jù)庫(kù)。想來(lái)想去shell腳本似乎不太好實(shí)現(xiàn)，于是用了比較熱門(mén)的python來(lái)實(shí)現(xiàn)。不得不說(shuō)，python豐富的第三方庫(kù)確實(shí)是很強(qiáng)大，下面是具體的功能代碼。

from apscheduler.scheduler import Scheduler
import os
import sys
import time
import MySQLdb
import ConfigParser
import Logger

def main():

  logger = Logger.Logger(logname='flowstat.log', loglevel=1, logger='flowstat').getlog()

  try:
    cf = ConfigParser.ConfigParser()
    cf.read('./flowstat.conf')

    filterNet1 = cf.get('packet', 'filterNet1')
    filterNet2 = cf.get('packet', 'filterNet2')
    packetFile = cf.get('packet', 'packetFile')

    db_host = cf.get('db', 'host')
    db_user = cf.get('db', 'user')
    db_passwd = cf.get('db', 'passwd')
    db_dbname = cf.get('db', 'dbname')

    conn = MySQLdb.connect(host=db_host, user=db_user, passwd=db_passwd, db=db_dbname, port=3306)

    os.system('nohup ./capturePacket.sh ' + filterNet1 + ' ' + filterNet2 + ' ' + packetFile + ' &')
  except Exception, e:
    logger.error(e)
    sys.exit(1)


  sched = Scheduler(daemonic = False)
  @sched.cron_schedule(day_of_week='0-4', hour='*', minute='0-59', second='*/60')
  def packagestat_job():
    logger.debug('stat package' + ' ' + time.strftime("%Y-%m-%d %H:%M:%S"))
    try:
      fos = open(packetFile, 'r+')
      lines = fos.readlines()
      values = []
      for line in lines:
        arr = line.split(',')
        if len(arr) > 4:
          values.append((arr[0].strip(), arr[2].strip(), arr[3].strip(), arr[4].strip()))

      if len(values) > 0:
        cur = conn.cursor()
        cur.executemany('insert into tbpk_packet(TimesMacs, LengthIps, Seq, Ack) values(%s,%s,%s,%s)', values)
        conn.commit()
        cur.close()

      fos.truncate(0)
      fos.close()
    except Exception, e3:
      Logger.error(e3)


  sched.start()

  while 1:
    time.sleep(60)

  conn.close()

if __name__ == '__main__':
  main()

shell腳本
#!/bin/sh
tcpdump -i eth0 -l >> *.txt

上面的功能涉及到了文件操作，數(shù)據(jù)庫(kù)操作，定時(shí)任務(wù)等幾個(gè)功能點(diǎn)。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: