def main():
client = mqtt.Client(parser.get('mqtt', 'clientname'),
userdata=file, clean_session=True)
client.on_connect = on_connect
client.on_message = on_message
client.connect(parser.get('mqtt', 'server'),
parser.get('mqtt', 'port'), 60)
# Loop forever
try:
client.loop_forever()
# Catches SigINT
except KeyboardInterrupt:
global exit_me
exit_me = True
client.disconnect()
logger.info("Exiting main thread")
time.sleep(2.0)
评论列表
文章目录