中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

python怎么實現linux下抓包并存庫功能

發布時間:2021-04-13 09:45:30 來源:億速云 閱讀:209 作者:小新 欄目:開發技術

這篇文章主要介紹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

以上是“python怎么實現linux下抓包并存庫功能”這篇文章的所有內容,感謝各位的閱讀!希望分享的內容對大家有幫助,更多相關知識,歡迎關注億速云行業資訊頻道!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

乳山市| 海阳市| 江川县| 兰西县| 阿鲁科尔沁旗| 游戏| 海晏县| 萨迦县| 兰考县| 新巴尔虎右旗| 开原市| 贵州省| 神农架林区| 金山区| 西盟| 雷州市| 洱源县| 阜阳市| 蒙自县| 故城县| 深州市| 东乌珠穆沁旗| 株洲市| 琼结县| 江口县| 得荣县| 咸丰县| 定南县| 宝山区| 沁源县| 五台县| 石棉县| 东明县| 阳高县| 红安县| 舒兰市| 华宁县| 迁西县| 和政县| 赤峰市| 咸丰县|