SHA256
46 lines
1.1 KiB
Python
46 lines
1.1 KiB
Python
# Aquitectura: 4 hilos -> Websocket -> Procesamiento -> Visualización -> Guardado:CSV
|
|
|
|
# Base: Hilos y datos buffer de datos compartidos
|
|
import queue
|
|
import threading
|
|
|
|
from src.cliente_ws import websocket_cliente
|
|
from src.graficar import graficar
|
|
from src.gurdar import guardar_datos
|
|
from src.procesor_data import data_procesor
|
|
|
|
# Datos globals
|
|
ip_server = "10.42.0.100:81"
|
|
|
|
# Cola de datos compartidos
|
|
raw_data = queue.Queue()
|
|
data_clean = queue.Queue()
|
|
data_grafica = queue.Queue()
|
|
i_paquetes = queue.Queue()
|
|
buffer_size = queue.Queue()
|
|
data_guardar = queue.Queue()
|
|
|
|
# def debug_print():
|
|
# while True:
|
|
# raw = data_grafica.get()
|
|
# print(raw)
|
|
|
|
|
|
hilo_1 = websocket_cliente(raw_data, i_paquetes, ip_server)
|
|
hilo_2 = data_procesor(raw_data, data_clean, data_grafica, buffer_size, data_guardar)
|
|
# hilo_3 = threading.Thread(target=debug_print)
|
|
hilo_4 = guardar_datos(data_guardar)
|
|
|
|
hilo_1.daemon = True
|
|
hilo_2.daemon = True
|
|
# hilo_3.daemon = True
|
|
hilo_4.daemon = True
|
|
|
|
hilo_1.start()
|
|
hilo_2.start()
|
|
# hilo_3.start()
|
|
hilo_4.start()
|
|
|
|
|
|
graficar(data_clean, data_grafica, buffer_size)
|