##// END OF EJS Templates
.
Armando123x -
r297:c9b442208466
parent child
Show More
@@ -239,7 +239,7 def send_check(topic):
239 client.on_disconnect = on_disconnect
239 client.on_disconnect = on_disconnect
240 client.username_pw_set(mqtt_user,mqtt_pass)
240 client.username_pw_set(mqtt_user,mqtt_pass)
241
241
242 client.connect(mqtt_broker,mqtt_port,150)
242 client.connect(mqtt_broker,mqtt_port,30)
243
243
244 client.publish(topic,"received_200")
244 client.publish(topic,"received_200")
245
245
@@ -490,7 +490,7 def on_disconnect(client,userdata,rc):
490
490
491 return
491 return
492
492
493 write_status("Se ha desconectado el MQTT, recuperando conexión.")
493 write_status("[MANAGE] Se ha desconectado el MQTT, recuperando conexión.")
494
494
495 if rc != 0:
495 if rc != 0:
496 count_attempts = 0
496 count_attempts = 0
@@ -502,12 +502,12 def on_disconnect(client,userdata,rc):
502
502
503 error = traceback.format_exc()
503 error = traceback.format_exc()
504
504
505 write_status(f"Error al reconectar MQTT broker. Intento {count_attempts+1}/inf. Copia del error: {error}")
505 write_status(f"[Error][Manage] Error al reconectar MQTT broker. Intento {count_attempts+1}. Copia del error: {error}")
506
506
507 count_attempts +=1
507 count_attempts +=1
508 time.sleep(1)
508 time.sleep(5)
509
509
510 if count_attempts == 60*15:
510 if count_attempts == 4*60*60:
511
511
512 write_status("[Error] Se alcanzó la máxima cantidad de intento de conexiones. No se puede recibir comandos. Reiniciando el sistema.")
512 write_status("[Error] Se alcanzó la máxima cantidad de intento de conexiones. No se puede recibir comandos. Reiniciando el sistema.")
513 raise MyErrorForManage("[Error] Se alcanzó la máxima cantidad de intento de conexiones. No se puede recibir comandos. Reiniciando el sistema.")
513 raise MyErrorForManage("[Error] Se alcanzó la máxima cantidad de intento de conexiones. No se puede recibir comandos. Reiniciando el sistema.")
@@ -589,7 +589,7 if __name__ =='__main__':
589 client.on_disconnect = on_disconnect
589 client.on_disconnect = on_disconnect
590 client.username_pw_set(mqtt_user,mqtt_pass)
590 client.username_pw_set(mqtt_user,mqtt_pass)
591
591
592 client.connect(mqtt_broker,mqtt_port,150)
592 client.connect(mqtt_broker,mqtt_port,30)
593 client.loop_forever()
593 client.loop_forever()
594
594
595 except MyErrorForManage as e:
595 except MyErrorForManage as e:
@@ -338,10 +338,17 def on_disconnect(client,userdata,rc):
338
338
339 count_attempts +=1
339 count_attempts +=1
340
340
341 time.sleep(10)
341 time.sleep(5)
342
343 if count_attempts == 30:
344
342
343 if count_attempts == 60*60*10:
344 '''
345 Existen dos posibilidades en desconexión:
346 - Perdida de conectividad a internet.
347 - No exista disponibilidad del servidor.
348 El bucle permitirá reconectarse al servido en caso de desconexión por un día.
349 Si el tiempo es superado, la RPI se reiniciará automaticamente mediante la rutina
350 implementada en manage.py
351 '''
345 write_status(f"Error al reconectar MQTT broker. Nos desconectamos del servidor.")
352 write_status(f"Error al reconectar MQTT broker. Nos desconectamos del servidor.")
346
353
347 return
354 return
General Comments 0
You need to be logged in to leave comments. Login now