cyberes
/
ha-noaa-space-weather
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add retry to feeder

This commit is contained in:
Cyberes 2024-08-18 14:54:40 -06:00
parent d348bee04f
commit 85636814ed
2 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@ -1,4 +1,5 @@
.idea .idea
test.sh
# ---> Python # ---> Python
# Byte-compiled / optimized / DLL files # Byte-compiled / optimized / DLL files

17
feeder-mqtt/main.py
View File

@ -43,12 +43,17 @@ client.loop_start()
def publish(topic: str, msg): def publish(topic: str, msg):
topic_expanded = MQTT_TOPIC_PREFIX + '/' + topic topic_expanded = MQTT_TOPIC_PREFIX + '/' + topic
result = client.publish(topic_expanded, msg) retries = 10
status = result[0] for i in range(retries): # retry
if status == 0: result = client.publish(topic_expanded, msg)
logging.info(f"Sent {msg} to topic {topic_expanded}") status = result[0]
else: if status == 0:
logging.error(f"Failed to send message to topic {topic_expanded}: {result}") logging.info(f"Sent {msg} to topic {topic_expanded}")
return
else:
logging.warning(f"Failed to send message to topic {topic_expanded}: {result}. Retry {i + 1}/{retries}")
time.sleep(10)
logging.error(f"Failed to send message to topic {topic_expanded}.")
def main(): def main():