OpenCode experiments...
This commit is contained in:
3
gauge.py
3
gauge.py
@@ -26,7 +26,6 @@ import utime
|
|||||||
import ujson
|
import ujson
|
||||||
import gc
|
import gc
|
||||||
import usocket
|
import usocket
|
||||||
from umqtt.robust import MQTTClient
|
|
||||||
from machine import UART
|
from machine import UART
|
||||||
|
|
||||||
# ---------------------------------------------------------------------------
|
# ---------------------------------------------------------------------------
|
||||||
@@ -898,6 +897,7 @@ def _subscribe_all(c):
|
|||||||
|
|
||||||
def connect_mqtt():
|
def connect_mqtt():
|
||||||
global client_ref, _mqtt_connected
|
global client_ref, _mqtt_connected
|
||||||
|
from umqtt.robust import MQTTClient
|
||||||
info(f"Connecting to MQTT broker {MQTT_BROKER}:{MQTT_PORT} ...")
|
info(f"Connecting to MQTT broker {MQTT_BROKER}:{MQTT_PORT} ...")
|
||||||
last_error = None
|
last_error = None
|
||||||
for attempt in range(3):
|
for attempt in range(3):
|
||||||
@@ -986,6 +986,7 @@ def check_mqtt():
|
|||||||
_mqtt_connected = False
|
_mqtt_connected = False
|
||||||
|
|
||||||
log_err("Attempting MQTT reconnection...")
|
log_err("Attempting MQTT reconnection...")
|
||||||
|
from umqtt.robust import MQTTClient
|
||||||
for attempt in range(3):
|
for attempt in range(3):
|
||||||
try:
|
try:
|
||||||
client_ref = MQTTClient(
|
client_ref = MQTTClient(
|
||||||
|
|||||||
Reference in New Issue
Block a user