Как я могу проверить передачу данных по сетевому интерфейсу в python? - PullRequest
Новая
       22

Как я могу проверить передачу данных по сетевому интерфейсу в python?

5 голосов
/ 11 октября 2011

Существует метод сокетов для получения IP-адреса данного сетевого интерфейса: 

import socket
import fcntl
import struct

def get_ip_address(ifname):
    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    return socket.inet_ntoa(fcntl.ioctl(
        s.fileno(),
        0x8915,  # SIOCGIFADDR
        struct.pack('256s', ifname[:15])
    )[20:24])

Что возвращает следующее: 

>>> get_ip_address('lo')
'127.0.0.1'

>>> get_ip_address('eth0')
'38.113.228.130'

Существует ли подобный метод для возврата передачи по сети этого интерфейса? Я знаю, что могу читать /proc/net/dev, но я бы хотел метод сокетов.

1 Ответ

7 голосов
/ 17 октября 2011

Лучший способ опроса статистики интерфейса Ethernet - через SNMP ...

  • Похоже, вы используете Linux ... если это так, загрузите ваш snmpd с этими опциями ... после установки snmpd, в ваш / etc / defaults / snmpd (убедитесь, что строка с SNMPDOPTS выглядит следующим образом):

    SNMPDOPTS='-Lsd -Lf /dev/null -u snmp -I -smux,usmConf,iquery,dlmod,diskio,lmSensors,hr_network,snmpEngine,system_mib,at,interface,ifTable,ipAddressTable,ifXTable,ip,cpu,tcpTable,udpTable,ipSystemStatsTable,ip,snmp_mib,tcp,icmp,udp,proc,memory,snmpNotifyTable,inetNetToMediaTable,ipSystemStatsTable,disk -Lsd -p /var/run/snmpd.pid'

  • Вам также может потребоваться изменить сообщество ro на public См. Примечание 1 и установить интерфейсы прослушивания в /etc/snmp/snmpd.conf (если не в петле) ...

  • Предполагая, что у вас есть функционал snmpd, на данный момент вы можете опросить ifHCInBytes и ifHCOutBytes См. Примечание 2 для вашего интерфейса (ов), о котором идет речь, используя это .. .

poll_bytes.py 

from SNMP import v2Manager
import time

def poll_eth0(manager=None):
    # NOTE: 2nd arg to get_index should be a valid ifName value
    in_bytes = manager.get_index('ifHCInOctets', 'eth0')
    out_bytes = manager.get_index('ifHCOutOctets', 'eth0')
    return (time.time(), int(in_bytes), int(out_bytes))

# Prep an SNMP manager object...
mgr = v2Manager('localhost')
mgr.index('ifName')
stats = list()
# Insert condition below, instead of True...
while True:
    stats.append(poll_eth0(mgr))
    print poll_eth0(mgr)
    time.sleep(5)

SNMP.py 

from subprocess import Popen, PIPE
import re

class v2Manager(object):
    def __init__(self, addr='127.0.0.1', community='public'):
        self.addr      = addr
        self.community = community
        self._index = dict()

    def bulkwalk(self, oid='ifName'):
        cmd = 'snmpbulkwalk -v 2c -Osq -c %s %s %s' % (self.community,
            self.addr, oid)
        po = Popen(cmd, shell=True, stdout=PIPE, executable='/bin/bash')
        output = po.communicate()[0]
        result = dict()
        for line in re.split(r'\r*\n', output):
            if line.strip()=="":
                continue
            idx, value = re.split(r'\s+', line, 1)
            idx = idx.replace(oid+".", '')
            result[idx] = value
        return result

    def bulkwalk_index(self, oid='ifOutOctets'):
        result = dict()
        if not (self._index==dict()):
            vals = self.bulkwalk(oid=oid)
            for key, val in vals.items():
                idx = self._index.get(key, None)
                if not (idx is None):
                    result[idx] = val
                else:
                    raise ValueError, "Could not find '%s' in the index (%s)" % self.index
        else:
            raise ValueError, "Call the index() method before calling bulkwalk_index()"
        return result

    def get_index(self, oid='ifOutOctets', index=''):
        # This method is horribly inefficient... improvement left as exercise for the reader...
        if index:
            return self.bulkwalk_index().get(index, "<unknown>")
        else:
            raise ValueError, "Please include an index to get"

    def index(self, oid='ifName'):
        self._index = self.bulkwalk(oid=oid)

ЗАКЛЮЧИТЕЛЬНЫЕ ЗАМЕЧАНИЯ:

  1. SNMP v2c использует аутентификацию в виде открытого текста. Если вы беспокоитесь о безопасности / о том, как кто-то отслеживает ваш трафик, измените сообщество и ограничьте запросы к вашей машине linux по IP-адресу источника. Идеальный мир - изменить SNMP.py выше, чтобы использовать SNMPv3 (который шифрует конфиденциальные данные); большинство людей просто используют закрытое сообщество и ограничивают запросы snmp по IP-адресу источника.

  2. ifHCInOctets и ifHCOutOctets предоставляют мгновенные значения для количества байтов, переданных через интерфейс. Если вы ищете скорость передачи данных, конечно, потребуется дополнительная математика.

...