[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [List Home]
Re: [paho-dev] Re - Unable to push MQTT message

Hi,

my first tough on this problem is that you don't "wait" enough to let message be published.

You do connect, (submit as message to) publish, wait 1 second, and - I assuming - terminate the program.

One second may be enough to complete the message publishing depending on your connection speed (which may explain why the same code work on your local machine but not on DO). But you can't be sure.

The correct solution is not to wait for an arbitrary number of seconds, but to wait for on_publish to be called for all your messages, and then disconnect from here. The easiest way to achieve this (connect, publish, wait, disconnect) is to use the publish helper.

You are not the first one to fall in this trap, I'll try to improve documentation to avoid this for future one: https://github.com/eclipse/paho.mqtt.python/issues/210

Regards,

PierreF


Le 13/07/2017 Ã 22:16, Shailendra Singh a ÃcritÂ:

I am facing a very strange issue. I am working on a DIY project of home automation using MQTT + Python. I have hosted my code on Digital ocean and using UFW i have allowed traffic on 1883 port (MQTT broker port). I am running a copy of the code on my local machine in which i am calling aÂfunction xÂfrom a python file which takeÂtopicÂandÂpayloadÂas a argument and push theÂtopic + payloadÂto aÂMQTTÂbroker. This happen successfully and even i get theÂmidÂof the published message. Below is the code which i am using

import paho.mqtt.client as paho
import time

def on_publish(client, userdata, mid):
    print("mid: "+str(mid))

client = paho.Client()
client.
client.connect("broker.mqttdashboard.com", 1883)
client.loop_start()



def my_mqtt_publish(topic, payload):
    try:
        (rc, mid) = client.publish(topic, payload, qos=2)
        time.sleep(1)
        print "going to publish topic and i am in the other module"
        print "going to publish topic : {0} and payload {1}".format(topic,payload)
    except Exception as e:
        print e.args, e.message

Also when i run a subscriber code on the digital ocean, i am able to get the message.

Now when i run the same publishing code on digital ocean, i don't get

  1. The MID of the published message .
  2. Also when i run subscriber code on my local machine, i don't get any message.
  3. Also when i run a test code on the digital ocean and the corresponding subscriber code on the local machine, i get the message. Below is my test code

    import paho.mqtt.client as paho
    import time
    
    def on_publish(client, userdata, mid):
       print("mid: "+str(mid))
    
    client = paho.Client()
    client.
    client.connect("broker.mqttdashboard.com", 1883)
    client.loop_start()
    
    
    
    def my_mqtt_publish():
    try:
        client.publish( "message/msg", "A", qos=1)
        print "going to publish topic : {0} and payload {1}".format(" message/msg","A")
    except Exception as e:
        print e.args, e.message
    
    if __name__ == "__main__":
            while 1:
                my_mqtt_publish()
                time.sleep(5)
    

I am really clueless what am i missing here in the code and really feel akward to ask this kind of question where everything is infront of my eyes and i am not able to find the problem.


With regards.
ShailendraÂSingh
+91-9910908382


Here's to the crazy ones, the misfits, the rebels, the troublemakers,the
round pegs in the square holes... the ones who see things differently --
they're not fond of rules... You can quote them, disagree with them, glorify
or vilify them, but the only thing you can't do is ignore them because they
change things... they push the human race forward, and while some may see
them as the crazy ones, we see genius, because the ones who are crazy enough
to think that they can change the world, are the ones who do.
-- Steve Jobs, US computer engineer & industrialist (1955 - )*



_______________________________________________
paho-dev mailing list
paho-dev@xxxxxxxxxxx
To change your delivery options, retrieve your password, or unsubscribe from this list, visit
https://dev.eclipse.org/mailman/listinfo/paho-dev