Python Paho MQTT如何在Postgresql关闭连接或其他情况后自动重新连接
Python Paho MQTT是一个用于实现MQTT协议的Python库。MQTT是一种轻量级的消息传输协议，常用于物联网设备之间的通信。
在使用Python Paho MQTT时，可以通过设置一些参数来实现在PostgreSQL关闭连接或其他情况下自动重新连接的功能。具体步骤如下：
- 导入必要的库和模块：import paho.mqtt.client as mqtt import time
- 创建一个MQTT客户端对象：client = mqtt.Client()
- 定义连接成功后的回调函数：def on_connect(client, userdata, flags, rc): if rc == 0: print("Connected to MQTT broker") else: print("Failed to connect, return code: " + str(rc))
- 将回调函数注册到客户端对象：client.on_connect = on_connect
- 定义断开连接后的回调函数：def on_disconnect(client, userdata, rc): if rc != 0: print("Unexpected disconnection")
- 将断开连接回调函数注册到客户端对象：client.on_disconnect = on_disconnect
- 定义重新连接的函数：def reconnect(): while not client.is_connected(): try: client.reconnect() except: print("Reconnection failed, retrying in 5 seconds...") time.sleep(5)
- 在需要连接到MQTT代理的地方调用连接函数：client.connect("mqtt.example.com", 1883, 60)其中，"mqtt.example.com"是MQTT代理的地址，1883是默认的MQTT端口号，60是连接超时时间（单位为秒）。
- 在主循环中添加断线重连的逻辑：while True: try: client.loop_forever() except KeyboardInterrupt: client.disconnect() break except: print("Connection lost, reconnecting...") reconnect()
以上代码实现了在连接断开后自动重新连接的功能。当连接断开时，会调用断开连接回调函数，并在主循环中调用重新连接函数进行重连。
对于PostgreSQL关闭连接或其他情况，可以根据具体情况在断开连接回调函数中添加相应的处理逻辑，例如重新连接到PostgreSQL数据库。
推荐的腾讯云相关产品：腾讯云消息队列 CMQ、腾讯云数据库 PostgreSQL。
腾讯云消息队列 CMQ是一种高可靠、高可用的消息队列服务，可用于实现分布式系统之间的异步通信。它提供了多种消息传递模式，包括点对点、发布/订阅和广播等，适用于各种场景，如物联网、移动应用、实时数据处理等。了解更多信息，请访问：腾讯云消息队列 CMQ
腾讯云数据库 PostgreSQL是一种高性能、可扩展的关系型数据库服务，基于开源的PostgreSQL数据库引擎。它提供了自动备份、容灾、监控等功能，适用于各种应用场景，如Web应用、物联网、大数据分析等。了解更多信息，请访问：腾讯云数据库 PostgreSQL
相关·内容
我的MQTT订阅一般是正常的，但是当服务器出现异常时，我的MQTT就不能工作了，比如内存不足，服务器就会杀死postgresql或一些任务，Postgresql进入恢复模式，这会让我的MQTT的postgresql连接失败(连接关闭)，尽管PostgreSQL服务恢复了，我的MQTT仍然连接失败(或关闭)。
那么，有没有办法自动重新连接呢？
import threading
import paho.mqtt.client as paho_mqtt
def t1():
client = paho_mqtt.Client(client_id="*****")
c
浏览 33提问于2018-07-23得票数 0
回答已采纳
3回答
最近，我开始使用paho mqtt for java和mqtt，我一直使用mqtt broker和paho客户端it self提供的持久性机制。也许我误解了(可能是这样) mqtt上下文中持久性的概念。
我们必须支持的用例如下：我们的mqtt客户端已经断开了7天(我非常怀疑这将发生，但很好)，甚至应用程序在这7天没有恢复连接的情况下关闭，并且一旦启动并运行，在断开连接时发送所有7天的所有消息。
Paho客户端支持缓冲消息在其或代理故障时的持久性，一旦网络恢复或代理运行，就会发送缓冲消息，但如果应用程序在客户端断开连接或代理不可用时关闭，则无法发送缓冲消息。
基本上，我的问题是-断开连接的缓冲消
浏览 0提问于2017-03-09得票数 2
1回答
与外部MQTT代理连接时出现问题
、、、、
我在松树A64+上使用Ubuntu mate 1 1Gb，我已经用python3安装了paho mqtt库，我通过创建本地蚊子服务器测试了库，它工作得很好。现在我需要连接到具有用户名和密码的外部代理，我尝试使用以下代码，但它对我不起作用。有了这个，我甚至无法连接到代理。
import paho.mqtt.client as mqtt
import time
broker_address = "121.242.232.175.xip.io"
port = 1883
def on_connect(client, userdata, flags, rc):
if rc==0
浏览 1提问于2021-01-08得票数 0
1回答
为什么我会有这个错误？
Mysql.connector.errors.DatabaseError: 2003 (HY000)：无法连接到MySQL服务器n‘3.XX.XXX.89 (110)
我正在从MQTT收集数据，并将其存储在MySQL数据库中。为了订阅MQTT上的主题，我使用Paho MQTT客户端，为了连接到MySQL数据库服务器，我使用MySQL python连接器。我在Amazon实例(Virtual )上连续地在后台运行这个python脚本：
import mysql.connector
import paho.mqtt.client as mqtt
#Mysql Sett
浏览 5提问于2020-05-22得票数 1
回答已采纳
1回答
我有一个Flask客户端正在运行，如果代理是可访问的，那么一切都很好。当无法访问MQTT代理时，问题就开始了。通常，我将能够处理on_connect函数上的异常情况下的失败连接，但是我不太明白如何用Flask实现它。
我希望处理失败的代理连接，同时允许web服务器运行网页。
的文档和例子
处理代理连接失败的代码(基于Steve的Internet指南)
def on_connect(client, userdata, flags, rc):
if rc==0:
client.connected_flag=True #set flag
print("
浏览 15提问于2021-03-14得票数 0
默认的PAHO MQTT实现是否将所有正在推送的消息保持不变，直到在QoS 2中具体确认它们的传递为止？如果不是，我们如何才能实现这一目标？
更新，因为paho安卓服务版本1.1.0自动重新连接和离线缓冲功能是实现的。欲了解更多信息：
浏览 4提问于2015-08-05得票数 3
回答已采纳
3回答
目前正在开发类似“智能家居”的东西，而我的家里几乎没有不同的设备。它们都是通过MQTT连接到OpenHab的。我使用Paho MQTT library (Python)来实现我的目的。
一般而言，MQTT具有"keepalive“属性。此属性描述当订阅的主题没有更新时，我的客户端将连接(AFAIK，它将ping发送到服务器)到MQTT服务器的时间。
但是这里我有一个很大的问题。所需的主题可以每小时更新一次，甚至每几天/月更新一次。假设这是室内警报。如何避免保持连接超时或忽略该字段？它可能是无限的吗？
浏览 15提问于2017-07-06得票数 4
回答已采纳
我正在尝试使用Python类来设置MQTT连接器。我面临的问题是，self.connected总是被打印为False，即使在on_connect模块中我已经更改了它的值。此外，没有执行on_connect模块中的两个打印指令。但是，如果我这样做了：
print(self.client.connect(host=broker, port=port, keepalive=120))
在bootstrap_mqtt模块中，结果为0，这意味着客户端已连接。
我做错了什么？
我使用这个例子来更好地理解Python类是如何工作的，特别是如何管理类中的模块/变量。
谢谢!
这是我的密码：
import pa
浏览 14提问于2022-07-18得票数 0
回答已采纳
1回答
我对mqtt协议很陌生。我很难将我的mqtt客户端(它连接到另一个网络)与我的mqtt代理连接到我的pc上，它有ip地址。
我的mqtt代理连接到我的家庭wifi，当我的客户连接到一个不同的家庭wifi。
我使用的是蚊帐经纪人，配置如下：
listener 1883 0.0.0.0
allow_anonymous true
Mqtt客户端代码：
import paho.mqtt.client as mqtt
from random import randrange, uniform
import time
broker = "10.18.124.166"
port = 188
浏览 6提问于2022-05-25得票数 0
回答已采纳
我用Python在Raspberry Pi W(使用Buster)上编写了几个mqtt驱动的服务器，以便在订阅了一组主题(打开/关闭gpios，通过mqtt温度读取和发布等)后从mqtt代理接收到给定的mqtt消息时，执行一组命令。
这个Raspberry是安装在一个远程位置，我想在启动后执行这些程序，以保证它们将是活动的，即使发生了暂时的电力供应中断和Raspi在停电后重新启动。
我在"sudo crontab -e“中包含了一个@reboot条目，以便在引导后启动一个启动多个服务器的bash文件：
@reboot /usr/bin/sleep 60 && /home
浏览 4提问于2021-11-27得票数 0
请找到我试图在下面运行的脚本：
def initialize(global_listener):
global MQTT_CLIENT
global SUBSCRIBERS_ACTIVE_COUNT
SUBSCRIBERS_ACTIVE_COUNT = 0
MQTT_CLIENT = setup_mqtt_client()
global_listener.set_client(MQTT_CLIENT)
subscribe_and_listen(MQTT_CLIENT)
def subscribe_and_listen(client):
# Star
浏览 1提问于2017-03-09得票数 0
回答已采纳
我使用 Java (JAR)连接到MQTT。
但是我想连接两个使用同一个库的代理。我已经实现了与两个代理连接的代码，它确实是连接的，但问题是在某个连接之后，随机断开连接(任何一个连接)。
那么，使用一个MQTT客户端库与两个MQTT Broker连接的最佳方法是什么。
更新的
连接代码如下所示：
import org.eclipse.paho.client.mqttv3.MqttClient;
Class com.test.A
{
MqttClient mMqttClient;
A()
{
mMqttClient = new MqttClient(&#
浏览 0提问于2017-07-21得票数 1
在Python中创建了两个paho.mqtt客户机(client1和client2)，后者连接到mosquitto代理。两个客户端订阅不同的主题。client1运行loop_forever()，client2运行loop_start()。client1 1的on_message()回调将消息存储在MySQL数据库中。client2 2的on_message()回调运行一个简单的测试。
测试包含一个使用模拟对象paho.mqtt.client.MQTTMessage的测试方法。对于client2，我将在命令行中发布来自mosquitto_pub的消息。当我收到要运行测试的消息时，测试将成功运行。
浏览 1提问于2018-01-24得票数 0
回答已采纳
如果连接丢失，我的paho-mqtt服务无法重新连接到代理。
在连接丢失时，我使用adb和服务器(Windows 10)中的Android设备(Windows 10)发送来自Android客户端的代理程序。
我通过我的RaspberyPI3B通过局域网连接到网络，部署了Android系统(最新版本)。局域网相当稳定。对于Paho MQTT，我使用的是最新版本。
我注意到我的MQTT连接是随机丢失的。
fun connect(context: Context) {
connectOptions.keepAliveInterval=30//seconds
connectOption
浏览 6提问于2021-10-18得票数 3
1回答
我在我的笔记本电脑上运行MQTT Mosquitto。然后我尝试连接2个Paho MQTT客户端: 1)从Android手机使用Java Paho和2)从树莓派使用Python Paho。
从Android连接是完美的。没问题。
但是，由于某些原因，Raspberry无法连接。相反，client.connect方法会阻塞，一段时间后，我会收到以下内容：
Traceback (most recent call last):
File "sensorsClient.py", line 28, in <module>
client.connect(mqttSe
浏览 0提问于2017-04-14得票数 3
我是MQTT的新手。我在两台电脑里安装了蚊子和泛美卫生组织mqtt图书馆。计算机通过本地网络中的路由器连接。我在一台电脑上运行出版商和蚊子，在另一台电脑中运行订户。
# publisher.py code
# ===================================================================
#!/usr/local/bin/python3
import paho.mqtt.publish as publish
publish.single("paho/single", payload="boo", hos
浏览 2提问于2015-12-10得票数 0
回答已采纳
2回答
我试图在MQTT服务器上读取消息。在某些情况下，连接是不稳定的，需要重新连接。但是在重新连接之后，我无法收到来自我以前订阅的主题的任何消息。我正在使用paho的python包来处理MQTT连接。下面是我正在使用的一些代码
TopicName='some/topic/name'
class Counter:
def __init__(self, mqttClient):
self.messages_recieved = 0
self.mqttClient = mqttClient
self.mqttClient.subsc
浏览 4提问于2020-12-02得票数 1
回答已采纳
1回答
我正在运行一个.sh文件，并在其中安装pip和paho-mqtt。我正在ubuntu中运行这个文件。但是当我第二次运行该文件时，pip和paho的安装也在发生。我想在执行这些谎言之前检查是否安装了这些谎言。有人能帮我做这个吗。
我的档案如下，
#install mqtt dependency
git clone git://git.eclipse.org/gitroot/paho/org.eclipse.paho.mqtt.python.git
cd org.eclipse.paho.mqtt.python
sudo python setup.py install
sudo apt inst
浏览 3提问于2017-06-13得票数 0
回答已采纳
1回答
我需要通过websocket连接到代理。
<script src="https://cdnjs.cloudflare.com/ajax/libs/paho-mqtt/1.0.1/mqttws31.min.js" type="text/javascript"></script>
<script>
// Create a client instance
client = new Paho.MQTT.Client("broker.hivemq.com", 8000, "" , "
浏览 8提问于2020-06-08得票数 0
回答已采纳
1回答
Python握手错误，连接未升级
、、、、
我正在尝试连接到一个现有的MQTT服务(通过websockets)，它不是由我使用paho.mqtt.client管理的。
这是我的密码：
import paho.mqtt.client as mqtt
def on_connect(client, userdata, flags, rc):
print("Connected with result code "+str(rc))
client.subscribe("$SYS/#")
def on_message(client, userdata, msg):
print(msg.to
浏览 28提问于2022-11-07得票数 0
好的，所以我在windows机器上，想要使用包。下载了正式的Python3InstallerMSI文件，并安装了Python 3，在此之前我不记得任何python的安装。
>python --version
Python 3.8.1
接下来，通过paho-mqtt通过pip安装
>pip install paho-mqtt
Collecting paho-mqtt
Using cached https://files.pythonhosted.org/packages/59/11/.../paho-mqtt-1.5.0.tar.gz
Installing collected p
浏览 3提问于2019-12-30得票数 0
回答已采纳
1回答
我想设计一个网页，我可以在其中连接到AWS服务器。在python-Paho-mqtt中，我可以使用tls_set选项来提供安全证书和其他东西。如何使用MQTT.js提供相同的功能？如果不能，我如何从HTML运行python-PAHO-MQTT？
提前谢谢。
浏览 16提问于2016-08-09得票数 0
2回答
我有以下代码-->
var last_will = new Paho.MQTT.Message("last message");
last_will.destinationName = "Bridge123";
client = new Paho.MQTT.Client("broker.mqttdashboard.com", Number("8000"), "AX123");
client.onConnectionLost = onConnectionLost;
client.onMessageArrived
浏览 0提问于2014-12-25得票数 0
1回答
我试图将在MQTT主题上发送的消息解析为JSON，但是当我试图在解码的字符串上调用json.loads()时，代码会出现异常：
File "/usr/lib/python3.7/json/decoder.py", line 340, in decode
raise JSONDecodeError("Extra data", s, end)
json.decoder.JSONDecodeError: Extra data: line 1 column 153 (char 152)
守则如下：
def on_message_mqtt(self, cl
浏览 8提问于2021-05-24得票数 0
我已经为MQTT订阅者编写了一个python脚本，它在本地非常好地工作。
Python订阅者脚本
import paho.mqtt.client as mqtt
import os,json
filePath = "logs.csv"
def initiateFile():
if (os.path.exists(filePath) == False):
fileObj = open(filePath, "w")
fileObj.write("Label,x,y,z\n")
def readFile()
浏览 0提问于2017-09-30得票数 1
回答已采纳
我正在尝试设置一个mqtt客户端，但是我得到了一个ImportError：
我用以下命令安装了paho：
pip install paho-mqtt
上面写着：Successfully installed dnspython-1.15.0 paho-mqtt-1.3.1 python-etcd-0.4.5 urllib3-1.22
但是当我尝试用sudo python listen.py调用我的python脚本时，它说：
File "listen.py", line 6, in <module>
import paho.mqtt.client as mqtt
I
浏览 0提问于2018-02-13得票数 3
回答已采纳
0回答
我正在创建一个包含python和php的docker。我正在编写一个python脚本来连接到驻留在另一个docker中的MQTT代理。
在我的dockerfile中，我确保使用以下命令安装paho客户端：
RUN apt-get install -y python3-dev
RUN apt-get install -y libffi-dev
RUN apt-get install -y libssl-dev
ADD https://bootstrap.pypa.io/get-pip.py /tmp/get-pip.py
RUN cat /tmp/get-pip.py | python3
浏览 20提问于2017-01-05得票数 12
回答已采纳
2回答
我正在尝试为我的python项目安装paho-mqtt包。但是它给出了错误
Error: Python packaging tool 'pip' not found.
我正在使用ubuntu 16.04，并且正在运行以下命令
pip install paho-mqtt
有没有人能告诉我有没有别的安装方法？
浏览 15提问于2017-02-07得票数 0
1回答
MQTT与离子3连接
、、、、
我需要在我的Ionic 3应用程序中使用发布订阅方法。
我跟踪了。
有任何方法，我们可以连接MQTT与我们的Ionic 3应用程序？如果是，怎么做？为了成功的连接，我到底需要做些什么呢？
我使用以下方法安装ng2-mqtt服务
npm install ng2-mqtt --save
这是我的密码：
index.html
<script src="cordova.js"></script>
<script src="node_modules/ng2-mqtt/mqttws31.js" type="text/javascript
浏览 1提问于2018-02-09得票数 3
回答已采纳
我正在编写一个MQTT客户机，它只需连接到代理，发布一条消息，然后断开连接。下面是代码：
def on_connect_v5(client, userdata, flags, rc, properties):
print('connected')
client.publish(topic, payload, 0)
def on_publish(client, userdata, mid):
print(f'mid: {mid}')
client.disconnect()
client = paho.Client(protoco
浏览 13提问于2022-04-18得票数 -1
回答已采纳
我正在用javascript编写一个web应用程序，我希望一个Paho.MQTT.Client能够断开与MQTT代理的连接，并使用不同的IP地址将其连接到另一个MQTT代理。
这个是可能的吗？
或者，为了在不同的Paho.MQTT.Client之间切换，我是否必须删除现有的MQTT并使用不同的IP地址创建一个新的MQTT？
我尝试过myClient._setHost("a.b.c.d")；，即使在调用myClient.disconnect()之后也会返回“Unsupported”。
浏览 0提问于2018-06-15得票数 0
我想学习中提到的例子，以连接到Python中的代理。代码只是停留在实例化部分。没有回应，什么都没有！有什么不对的？
pi@raspberrypi ~ $ python
Python 2.7.3 (default, Mar 18 2014, 05:13:23)
[GCC 4.6.3] on linux2
Type "help", "copyright", "credits" or "license" for more information.
>>> import paho.mqtt.client as mqtt
浏览 6提问于2015-04-26得票数 0
1回答
智能插件IoT
、、
我是一个全新的IoT新手，我有一个我大学的代码练习。我不知道如何连接这个脚本才能连接到MQTT并无错误地运行。
如何连接MQTT？脚本如下：
import paho.mqtt.client as mqtt
import ssl
import os
import sys
import matplotlib.pyplot as plt
from matplotlib.widgets import Button
from threading import Timer
from datetime import datetime
class IoTExample:
def __init__(
浏览 0提问于2020-10-10得票数 0
1回答
当我在互联网上尝试一个教程时，我没能连接到mqtt代理--有人可以帮我吗？
import paho.mqtt.client as mqtt
broker_url = "mqtt.eclipse.org"
broker_port = 1883
client = mqtt.Client()
client.connect(broker_url, broker_port)
print(client)
Traceback (most recent call last):
File "C:\Workspace\FI Systemintegration\Python\Mit
浏览 8提问于2022-01-11得票数 1
这里是我的脚本
import paho.mqtt.subscribe as subscribe
topics = ['#']
m = subscribe.simple(topics, hostname="eu.thethings.network", retained=False, msg_count=2)
for a in m:
print(str(a.topic))
print(str(a.payload))
将此作为错误消息返回：
Traceback (most recent call last):
File "MQTT_s
浏览 0提问于2018-03-08得票数 1
回答已采纳
我有一个Android客户端，它监听传感器数据，并在出现任何阈值违规时提醒用户。我的app.gradle中有以下内容：
implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.1.0'
implementation 'org.eclipse.paho:org.eclipse.paho.android.service:1.1.1'
我将其登记为舱单上的服务：
<service android:name="org.eclipse.paho.android.service.Mqt
浏览 1提问于2018-07-15得票数 4
回答已采纳
3回答
蚊子和遗嘱的问题(遗嘱)
、、、
我正在使用Mosquitto和Paho的Python实现来尝试与几个程序通信。当我使用最后一个will函数时，我遇到了一些麻烦。我的代码是：
Suscriber：
import paho.mqtt.client as mqtt
def on_message(client, userdata, msg):
print 'Received: ' + msg.payload
client = mqtt.Client()
client.on_message = on_message
client.connect('localhost', 1883)
clie
浏览 0提问于2015-02-20得票数 4
回答已采纳
1回答
我实现了与代理的连接，例如：
app.py
import paho.mqtt.client as mqtt
client = mqtt.Client(client_id='my_client', clean_session=False)
my_client = MyClient(client)
try:
my_client.start()
while True:
try:
client.loop()
except Exception as e:
my_client.start()
e
浏览 5提问于2021-11-23得票数 0
回答已采纳
这是我的paho javascript客户端代码
client = new Paho.MQTT.Client(host, Number(port), clientId);
client.onMessageArrived = onMessageArrived;
client.onMessageDelivered = onMessageDelivered;
client.onConnectionLost = onConnectionLost;
在这里，port 8083与其他代理合作，但不与Rabbitmq合作。在文档中，我找不到任何正确的端口号。
运行sudo rabbitm
浏览 3提问于2016-05-26得票数 0
回答已采纳
1回答
我有一个mqtt beoker，我正在尝试连接和订阅python。代码
client = mqtt.Client("P1",clean_session=True) #create new instance
client.on_connect = on_connect
client.on_message = on_message #attach function to callback
client.on_disconnect = on_disconnect
print("connecting to broker")
client.connect(broker_a
浏览 54提问于2019-08-07得票数 2
回答已采纳
我试图在on_message回调时并行运行一些测试。当我的on_message回调被调用时，基于一些消息，我创建一个线程来运行一些测试，并将它设置为守护进程线程。当我跑的时候，我得到了这个运行时错误。
“无法设置活动线程的守护进程状态”。
#this is the callback attached to paho.mqtt.client client.on_message = self.on_message
def on_message(self, client, userdata, msg):
if msg.topic.startswith("hello/
浏览 0提问于2018-02-16得票数 1
回答已采纳
我正试图通过MQTT协议连接我的覆盆子Pi和我的PC窗口。我在我的电脑上有一个无法解决的问题--我不能导入我安装到我的程序中的库：
import paho.mqtt.client as mqtt
导致错误
ModuleNotFoundError: No module named 'paho'
这个主题已经在这里发布了()，但是解决方案对我不起作用。
我在python文件夹中看到它：
C:\Users\mhucl\AppData\Local\Programs\Python\Python310\Lib\site-packages\paho\mqtt\client
我在单子上看到了。
浏览 39提问于2022-03-22得票数 -1
这段代码被建议用来处理每10秒发布一条消息。但是，如果需要，如何处理重新连接呢？
import paho.mqtt as mqtt
import time
mqttc=mqtt.Client("ioana")
mqttc.connect("127.0.0.1" 1883, 60, True)
#mqttc.subscribe("test/", 2) # <- pointless unless you include a subscribe callback
mqttc.loop_start()
while True:
mqttc
浏览 2提问于2015-11-17得票数 1
1回答
我在我的android应用中使用了mqtt paho库。它工作正常，直到mqtt客户端由于网络问题而失去连接。我是否需要手动连接客户端，或者它有某种自动连接机制。
浏览 0提问于2016-04-07得票数 2
因此，我有一个托克/蚊子码头集装箱运行，我可以连接从外部码头。
然后，我使用了一个Python码头容器，它应该向我的蚊虫经纪人发布数据。这是我的密码：
import paho.mqtt.client as paho
import time
import random
broker = "localhost"
port = 1883
def on_publish(client, userdata, result):
print("Device 1 : Data published.")
pass
client = paho.Client(&
浏览 6提问于2020-04-05得票数 5
回答已采纳
我正在尝试使用来自Python3的MQTT，运行在一个基于SBC的小型ARM上(想想Raspberry或BeagleBone)。我尝试使用以下方法安装paho-mqtt：
apt-get install python3-pip
pip3 install paho-mqtt
但这是错误的：
Collecting paho-mqtt
Downloading paho-mqtt-1.2.tar.gz (49kB)
100% |################################| 51kB 170kB/s
Complete output from command
浏览 0提问于2017-03-07得票数 0
回答已采纳
2回答
我正在使用paho-mqtt从emqx代理接收数据，但我正在丢失数据，因为有时我的paho-mqtt订阅者会宕机。当我再次运行subscriber时，任何获取数据的方法都会给出所有已发布的数据。
浏览 88提问于2020-02-12得票数 0
我使用基于Python的paho mqtt客户端向mqtt代理发布数据。
让我们假设一个场景，当客户端想发布消息而代理被断开连接时。
因此，基于python的客户端对象在_out_message (有序字典)中缓冲该消息，并继续尝试发送消息。
我想知道
在多长时间内，mqtt客户端将缓冲这种消息？
是否有任何时限或重试限制之后，客户端将删除该消息。
我想转储/记录这样的消息。
浏览 3提问于2020-04-02得票数 1
我即将建立一个Raspberry Pi 3+模型A作为openHAB2的客户端。这里，我有一个传感器上的Pi和WS2812b (别名Neopixel)连接。
现在，我用Python编写了(我的第一个脚本)，通过paho mqtt向代理发布传感器数据(Bosch BMP280)。当我用“ filename.py”.启动Python文件时，
如果我想用启动相同的文件"sudo python3 filename.py"，将出现以下错误消息：
Traceback (most recent call last):
File "mqtt_client.py", li
浏览 6提问于2019-11-22得票数 2
回答已采纳
3回答
我正在运行下面的代码来连接到mqtt服务器。
import paho.mqtt.client as mqtt
import ssl
import uuid
client = mqtt.Client(str(uuid.uuid1()))
client.tls_set(
"ca.crt",
"client.crt",
"client.key",
cert_reqs=ssl.CERT_REQUIRED,
tls_version=ssl.PROTOCOL_TLSv1
)
client.connect(
&
浏览 2提问于2018-10-17得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
