python实现linux下抓包并存库功能_Python

python实现linux下抓包并存库功能

2021-03-18 00:35pingnanlee Python

这篇文章主要为大家详细介绍了python实现linux下抓包并存库功能，具有一定的参考价值，感兴趣的小伙伴们可以参考一下

最近项目需要抓包功能，并且抓包后要对数据包进行存库并分析。抓包想使用tcpdump来完成，但是tcpdump抓包之后只能保存为文件，我需要将其保存到数据库。想来想去shell脚本似乎不太好实现，于是用了比较热门的python来实现。不得不说，python丰富的第三方库确实是很强大，下面是具体的功能代码。

									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