1

Tengo estas 2 listas:

list_ip = ["192.168.2.9", "192.168.2.8", "192.168.2.7", "192.168.2.6"]
list_traffic = [
    [u'192.168.2.9', u'23.67.224.83', u'10', u'2', u'*', u'*'],
    [u'23.67.208.186', u'192.168.2.9', u'10', u'1', u'*', u'*'],
    [u'192.168.2.7', u'74.125.139.124', u'10', u'1', u'*', u'*'],
    [u'23.67.208.186', u'192.168.2.7', u'10', u'1', u'*', u'*'],
    [u'23.67.208.186', u'192.168.2.7', u'10', u'1', u'*', u'*'],
    [u'192.168.2.9', u'74.125.139.125', u'10', u'1', u'*', u'*'],
    [u'23.67.208.186', u'192.168.2.7', u'10', u'1', u'*', u'*'],
]

El objetivo es sumar el valor de la posicion 2 (bytes) de cada una de las listas dentro de list_traffic. Solo deben sumarse las Ips que esten en list_ip (ip privada).

Como referencia comparto el valor de cada posicion de la lista:

 #list_example: [u'192.168.2.9', u'23.67.224.83', u'10', u'2', u'*', u'*'] 
 #position 0=src_ip  #Bytes downloaded
 #position 1=dst_ip  #Bytes Uploaded
 #position 2=bytes   #Valor a sumarse
 #position 3=packets

Ejemplo:

El primer valor de list_ip es "192.168.2.9", y se deben sumar los bytes(position 2) que tengan la ip "192.168.2.9", en este caso serian estas listas de list_traffic.

    [u'192.168.2.9', u'23.67.224.83', u'10', u'2', u'*', u'*'],
    [u'23.67.208.186', u'192.168.2.9', u'10', u'1', u'*', u'*'],
    [u'192.168.2.9', u'74.125.139.125', u'10', u'1', u'*', u'*'],

src_ip "192.168.2.9" 10 + 10 = 20 (bytes downloaded)

dst_ip "192.168.2.9 10 = 10 (bytes uploaded)

El resultado esperado seria este:

# Result
 new_list_traffic = { 
     "192.168.2.9": [20, 10],
     "192.168.2.7": [10, 30],
 }
#192.168.2.9 = 20/10  download/upload bytes
#192.168.2.7 = 10/30 download/upload bytes

Como podría sumar los valores de la posición bytes de forma eficiente?

Ya lo tengo implementado, pero me toma 2 segundos recorrer toda la lista, les comparto mi codigo:

def trafico_clientes2(request):
    start_time = time.clock()
    #list_example: [u'192.168.2.9', u'23.67.224.83', u'10', u'2', u'*', u'*'] 
    #0=src_ip, 1=dst_ip, 2=bytes, 3=packets

    list_ip = ["192.168.2.9", "192.168.2.8", "192.168.2.7", "192.168.2.6"]
    list_traffic = [
        [u'192.168.2.9', u'23.67.224.83', u'10', u'2', u'*', u'*'],
        [u'23.67.208.186', u'192.168.2.9', u'10', u'1', u'*', u'*'],
        [u'192.168.2.7', u'74.125.139.124', u'10', u'1', u'*', u'*'],
        [u'23.67.208.186', u'192.168.2.7', u'10', u'1', u'*', u'*'],
        [u'23.67.208.186', u'192.168.2.7', u'10', u'1', u'*', u'*'],
        [u'192.168.2.9', u'74.125.139.125', u'10', u'1', u'*', u'*'],
        [u'23.67.208.186', u'192.168.2.7', u'10', u'1', u'*', u'*'],
    ]
    new_list_traffic = { }

    for traffic_ip in list_traffic:
        src_ip = traffic_ip[0]
        dst_ip = traffic_ip[1]
        bytes = int(traffic_ip[2])
        if src_ip in list_ip:
            #bytes download
            total_bytes = new_list_traffic.get(src_ip)
            if total_bytes == None:
                new_list_traffic[src_ip] = [bytes, 0]
            else:
                total_bytes [0] = total_bytes [0] + bytes
                new_list_traffic[src_ip] = total_bytes

        elif dst_ip in list_ip:
            #bytes upload
            total_bytes = new_list_traffic.get(dst_ip)
            if total_bytes == None:
                new_list_traffic[dst_ip] = [0, bytes]
            else:
                total_bytes [1] = total_bytes [1] + bytes
                new_list_traffic[dst_ip] = total_bytes
    # Result
    # new_list_traffic = { 
    #     "192.168.2.9": [20, 10],
    #     "192.168.2.7": [10, 30],
    # }
    #192.168.2.9 = 20/10  download/upload bytes
    #192.168.2.7 = 10/30 download/upload bytes

    total_tiempo =  time.clock() - start_time, "seconds"
    return render(request, 'trafico.html',{"datos": list_traffic,  "lista_trafico": new_list_traffic, "total_tiempo": total_tiempo})

Espero puedan apoyarme optimizando el tiempo.

Saludos.

1
  • Si, pero si tomamos de ejemplo la ip 192.168.2.7, verás que está 3 veces esta línea [u'23.67.208.186', u'192.168.2.7', u'10', u'1', u'', u''], y en este caso el resultado sería 30 bytes uploaded, porque el dst_ip es 192.168.2.7
    – oscar
    el 16 may. 2017 a las 14:27

2 respuestas 2

3

Se me ocurre una forma sencilla usando collections.defaultdict que ahorra tener que recorrer la lista varias veces:

from collections import defaultdict

list_ip = ["192.168.2.9", "192.168.2.8", "192.168.2.7", "192.168.2.6"]
list_traffic = [
    [u'192.168.2.9', u'23.67.224.83', u'10', u'2', u'*', u'*'],
    [u'23.67.208.186', u'192.168.2.9', u'10', u'1', u'*', u'*'],
    [u'192.168.2.7', u'74.125.139.124', u'10', u'1', u'*', u'*'],
    [u'23.67.208.186', u'192.168.2.7', u'10', u'1', u'*', u'*'],
    [u'23.67.208.186', u'192.168.2.7', u'10', u'1', u'*', u'*'],
    [u'192.168.2.9', u'74.125.139.125', u'10', u'1', u'*', u'*'],
    [u'23.67.208.186', u'192.168.2.7', u'10', u'1', u'*', u'*'],
]

# construimos el diccionario donde guardar el resultado, con valor por
# defecto [0,0]
new_list_traffic = defaultdict(lambda: [0,0])

# iteramos por la lista de tráfico
for x in list_traffic:
    (src_ip, dst_ip, bytes) = x[:3]
    if src_ip in list_ip:
        new_list_traffic[src_ip][0] += int(bytes)
    if dst_ip in list_ip:
        new_list_traffic[dst_ip][1] += int(bytes)

print new_list_traffic.items()

Podría quedar aún más elegante si creamos una clase para representar el tráfico:

class Bytes:
    def __init__(self):
        self.upload = 0
        self.download = 0
    def __repr__(self):
        return "Bytes(upload={}, download={})".format(self.upload, self.download)

new_list_traffic = defaultdict(Bytes)

for x in list_traffic:
    (src_ip, dst_ip, bytes) = x[:3]
    if src_ip in list_ip:
        new_list_traffic[src_ip].upload += int(bytes)
    if dst_ip in list_ip:
        new_list_traffic[dst_ip].download += int(bytes)

print dict(new_list_traffic)
1
  • 1
    Qué buena respuesta, no sabía que el defaultdict podía tener un lambda como argumento. Por cierto, recomiendo renombrar la variable bytes, pues es un built-in: bytes.
    – fedorqui
    el 17 may. 2017 a las 6:05
1

Seguramente hay opciones mejores, pero se me ocurre la siguiente:

from itertools import groupby
from itertools import tee

list_ip = ["192.168.2.9", "192.168.2.8", "192.168.2.7", "192.168.2.6"]
list_traffic = [
    [u'192.168.2.9', u'23.67.224.83', u'10', u'2', u'*', u'*'],
    [u'23.67.208.186', u'192.168.2.9', u'10', u'1', u'*', u'*'],
    [u'192.168.2.7', u'74.125.139.124', u'10', u'1', u'*', u'*'],
    [u'23.67.208.186', u'192.168.2.7', u'10', u'1', u'*', u'*'],
    [u'23.67.208.186', u'192.168.2.7', u'10', u'1', u'*', u'*'],
    [u'192.168.2.9', u'74.125.139.125', u'10', u'1', u'*', u'*'],
    [u'23.67.208.186', u'192.168.2.7', u'10', u'1', u'*', u'*'],
]

lista = []

# Lista de download
for i, g in groupby(sorted([[l[0], l[2]] for l in list_traffic if l[0] in list_ip]), key=lambda x: x[0]):
    lista.append([i, "d", sum(int(v[1]) for v in g)])

# Lista de upload
for i, g in groupby(sorted([[l[1], l[2]] for l in list_traffic if l[1] in list_ip]), key=lambda x: x[0]):
    lista.append([i, "u", sum(int(v[1]) for v in g)])


# Consolidación de ambas listas y sumatoria
lista_final = []
for i, g in groupby(sorted([l for l in lista]), key=lambda x: x[0]):

  grp1, grp2 = tee(g)
  lista_final.append([i, 
                      sum(int(v[2]) for v in grp1 if v[1] == 'd'), 
                      sum(int(v[2]) for v in grp2 if v[1] == 'u')
                      ])

print(lista_final)
1
  • Por lo pronto es suficiente lo que compartes, muchas gracias Patricio Moracho
    – oscar
    el 16 may. 2017 a las 15:34

Tu Respuesta

Al pulsar en “Publica tu respuesta”, muestras tu consentimiento a nuestros términos de servicio, política de privacidad y política de cookies

¿No es la respuesta que buscas? Examina otras preguntas con la etiqueta o formula tu propia pregunta.