import serial, serial.tools.list_ports, sys, time, json
from socketIO_client import SocketIO, BaseNamespace
direccionIP=''
puertoConexion=''
# Variables globales para el envio de datos a traves del
# puerto serial
puertoPredefinido = ''
puertosSeriales = ''
arduino = ''
# Variables globales para la comunicacion con la app
# utilizando SocketIO
mensaje = ''
socketIO = ''
# Funcion ejecutada con cada actualizacion
# La variable msg recibe los datos provenientes del servidor
def enviar_a_Arduino(msg):
# Recuperamos el objeto JSON que viene en la comunicacion
argumentoJson = json.loads(msg)
try:
# Si el Arduino esta conectado, procesamos los datos y los enviamos
if not mensaje == '{"STATUS":"ERROR","CODIGO":"ARDUINO NO CONECTADO"}':
# Obtencion de cantidad de LEDs
cantidadDeLEDS = 0
for contador in argumentoJson['LEDS']:
cantidadDeLEDS += 1
# Formacion de la cadena de datos con el numero de LED y su color
datosParaEnviar = str(cantidadDeLEDS)
for contador in argumentoJson['LEDS']:
datosParaEnviar += ','+str(contador['NUM'])+','+str(contador['RGB'])
# Envio de datos
global arduino
arduino.write(datosParaEnviar.encode())
time.sleep(1.5)
# Envio de status al servidor
global mensaje
mensaje = '{"STATUS":"OK"}'
global socketIO
socketIO.emit('response', mensaje)
#Si no esta conectado el Arduino, se procede a intentar conectarlo de nuevo
else:
try:
# Enlistado de los puertos seriales disponibles
global puertosSeriales
puertosSeriales = list(serial.tools.list_ports.comports())
for puerto in puertosSeriales:
# Si el puerto contiene como identificaro la palabra Arduino,
# este es el puerto conectado al Arduino Mega
if "Arduino" in puerto[1]:
global puertoPredefinido
puertoPredefinido = puerto[0]
# Se abre el puerto a 115200 baudios
global arduino
arduino = serial.Serial(puertoPredefinido, 115200)
time.sleep(2)
# Inicio del proceso de envio de datos
cantidadDeLEDS = 0
for contador in argumentoJson['LEDS']:
cantidadDeLEDS += 1
datosParaEnviar = str(cantidadDeLEDS)
for contador in argumentoJson['LEDS']:
datosParaEnviar += ','+str(contador['NUM'])+','+str(contador['RGB'])
global arduino
arduino.write(datosParaEnviar.encode())
time.sleep(1.5)
global mensaje
mensaje = '{"STATUS":"OK"}'
global socketIO
socketIO.emit('response', mensaje)
except Exception:
# Si el Arduino no fue encontrado conectado al PC, se envia el error
global mensaje
mensaje = '{"STATUS":"ERROR","CODIGO":"ARDUINO NO CONECTADO"}'
global socketIO
socketIO.emit('response', mensaje)
except Exception:
# Si el Arduino no fue encontrado conectado al PC, se envia el error
global mensaje
mensaje = '{"STATUS":"ERROR","CODIGO":"ARDUINO NO CONECTADO"}'
global socketIO
socketIO.emit('response', mensaje)
# Informacion del Socket
#Servidor y puerto
socketIO = SocketIO(direccionIP, int(puertoConexion))
# Primer intento de abrir el puerto serial conectado al
# Arduino cuando inicia el sistema
try:
global puertosSeriales
puertosSeriales = list(serial.tools.list_ports.comports())
for puerto in puertosSeriales:
if "Arduino" in puerto[1]:
global puertoPredefinido
puertoPredefinido = puerto[0]
global arduino
arduino = serial.Serial(puertoPredefinido, 115200)
time.sleep(2)
except Exception:
global mensaje
mensaje = '{"STATUS":"ERROR","CODIGO":"ARDUINO NO CONECTADO"}
socketIO.on('status', enviar_a_Arduino, '/32-BGO-1')# Metodo a ejecutar en caso de que se reciban datos bajo el evento "status" en el canal "/32-BGO-1"
socketIO.on('status', enviar_a_Arduino, '/32-BGR-1') #Metodo a ejecutar en caso de que se reciban datos bajo el evento "status" en el canal "/32-BGR-1"
socketIO.wait() # Espera indefinida
El problema es que no funciona si creo un evento reconnect, viendo la documentación de la biblioteca, es escasa, pero mi función sería
def on_reconnect():
socketIO.on('status', enviar_a_Arduino, '/32-BGO-1')
socketIO.on('status', enviar_a_Arduino, '/32-BGR-1')
socketIO.on('reconnect', on_reconnect)
?