@@ -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, |
|
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} |
|
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( |
|
508 | time.sleep(5) | |
509 |
|
509 | |||
510 |
if count_attempts == 60* |
|
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, |
|
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( |
|
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