python paho mqtt 运行客户端 x 分钟

Question

我想运行我的 paho mqtt 客户端指定的时间段而不是永远。实施它的正确方法是什么？

P.S。我想要一个阻塞调用而不是事件驱动 loop_start()/stop() 设施

谢谢！

Answer 1

您必须使用事件循环，否则将无法正常工作。

所以最好的办法是实现自己的循环并跟踪时间。例如

startTime = time.time()
runTime = 5 * 60
while True:
  mqttc.loop()
  currentTime = time.time()
  if (currentTime - startTime) > runTime:
    break

这应该运行 5 分钟

python paho mqtt 运行 客户端 x 分钟