mqttsqlite.py 文件源码

def main():
    parser = argparse.ArgumentParser(description='Sqlite Logger for MQTT broker')
    parser.add_argument('--host', dest='mqtt_host', default='localhost', help='Mqtt Broker URL')
    parser.add_argument('--port', dest='mqtt_port', default=1883, help='Mqtt Broker Port')
    parser.add_argument('--root', dest='root_topic', default='logger/', help='Root topic for logger commands')
    parser.add_argument('--mgpassword', dest='management_password', default='admin1234', help='password for management options')
    parser.add_argument('--qrpassword', dest='query_password', default='query1234', help='password for query options')

    init_settings(parser.parse_args())

    client = mqtt.Client()
    client.on_connect = on_connect
    client.on_message = on_message

    print(get_host() + ':' + str(get_port()))
    client.connect(get_host(), int(get_port()), 60)

    client.loop_forever()