MQTT Publish stops

I'm using MQTT to publish data to weewx; works great; but, I'm finding MQTT fails silently after somewhere between 1 and 4 days. The call to mqtt publish returns; but no data shows up at the broker.   Restarting SkyWeather2 will "clear" problem.

I'm pretty sure it's because the paho mqtt publish method expects a persistent connection AND uses callbacks.   There's a "publish single" method that the paho docs say does NOT require the callbacks and just "publishes and disconnects".  So, I replaced the calls "publish" calls in wirelessSenors.py and publishMQTT.py with "publish.single"; it's been "cooking" for about a day now and appears to work.  I'll report back after a week or so (I want to see if it survives a reboot).

I think the "ultimate" solution will be to add the callbacks and keep a persistent connection (to avoid connect/disconnects and also do better error handling; but I wanted to make sure this solves the problem first

Here's "git diff's" on the code - I've hardcoded the broker hostname for now; but that can be had in the config file.

diff --git a/wirelessSensors.py b/wirelessSensors.py

index 9b4f344..25943ea 100644

--- a/wirelessSensors.py

+++ b/wirelessSensors.py

@@ -22,8 +22,9 @@ import time

import os

import signal

import traceback

-sys.path.append('./SDP_Pi_HM3301/aqi')

+sys.path.append('./SDL_Pi_HM3301/')

import aqi

+import paho.mqtt.publish as publishSingle



import MySQLdb as mdb

# ---------------------------------------------------------------------------------------------------------------------------------------------------------------

@@ -68,7 +69,7 @@ def mqtt_publish_single(message, topic):

topic = '{0}/{1}'.format("skyweather2", topic)

#print ("topic=", topic)

try:

- state.mqtt_client.publish(topic, message)

+ publishSingle.single(topic, message, hostname = "weewx")

except:

traceback.print_exc()

print('Mosquitto not available')

===============================================


diff --git a/publishMQTT.py b/publishMQTT.py

index 60d56cf..f3aa689 100644

--- a/publishMQTT.py

+++ b/publishMQTT.py

@@ -3,12 +3,13 @@ import config

import state



import paho.mqtt.client

+import paho.mqtt.publish as publishMQTT





def publish():



if (config.SWDEBUG):

print("--->Sending MQTT Packet<---")

- state.mqtt_client.publish("skyweather2/state", state.StateJSON)

+ publishMQTT.single("skyweather2/state", state.StateJSON, hostname = "weewx")