Dmqtt.py 文件源码

def Publish(target,channel,message):
    client = mqtt.Client()
    #client.on_publish = on_publish
    client.max_inflight_messages_set(200000)
    client.connect(target, 1883)
    (rc, mid) = client.publish(channel, message, qos=1)
    #time.sleep(0.01)
    print "DMQTT RESULT : "+str(rc)