FastAPI MQTT
A FastAPI extension that provides MQTT client functionality with decorator-based callbacks and Pydantic configuration.
What is FastAPI MQTT?
fastapi-mqtt is a FastAPI extension that adds MQTT client capabilities to web applications, allowing them to communicate with MQTT brokers for real-time messaging. It wraps the gmqtt library to provide an async MQTT 5.0 client with decorator-based event handling and Pydantic configuration. This solves the problem of integrating lightweight IoT messaging protocols into modern Python web services without manual client management.
Python developers building FastAPI applications that need to interact with IoT devices, sensors, or other MQTT-based systems for real-time data exchange.
Developers choose fastapi-mqtt for its seamless integration with FastAPI's async ecosystem, declarative decorator API that reduces boilerplate, and type-safe configuration using Pydantic, making MQTT client setup more maintainable and intuitive.
Overview
fastapi-mqtt is extension for MQTT protocol
Use Cases
Best For
- Adding MQTT messaging to FastAPI webhooks or real-time APIs
- Building IoT dashboards that subscribe to sensor data streams
- Creating bidirectional communication between web services and MQTT-enabled devices
- Prototyping MQTT integrations with minimal configuration overhead
- Developing microservices that publish telemetry data to MQTT brokers
- Testing MQTT client behavior within FastAPI test suites
Not Ideal For
- Projects not using FastAPI, as the library's decorators and lifecycle management are tightly coupled to FastAPI's async framework.
- Applications requiring an embedded MQTT broker, since fastapi-mqtt only provides client functionality to connect to external brokers.
- Teams needing low-level control over MQTT client behavior, because the wrapper abstracts gmqtt details and may limit customization.
Pros & Cons
Pros
Uses decorators like @fast_mqtt.on_message() to define MQTT callbacks directly in FastAPI routes, reducing boilerplate and improving code organization as shown in the guide.
Employs Pydantic for the MQTTConfig class, ensuring connection settings are validated and providing IDE autocompletion support, as highlighted in the features.
Designed to work with FastAPI's async lifespan, allowing non-blocking message handling and seamless integration with other async endpoints, evidenced by the use of asynccontextmanager.
Built on gmqtt for full compatibility with MQTT 5.0 features, such as user properties and enhanced error handling, per the README's specification.
Cons
Requires running a separate MQTT broker like Mosquitto, adding infrastructure management and potential network latency, as testing relies on external brokers like 'test.mosquitto.org'.
Tightly bound to gmqtt, so any bugs or missing features in the underlying library are inherited without direct fixes, limiting flexibility for advanced use cases.
Integration with FastAPI's lifespan requires manual context managers, as shown in the guide, which can be confusing for developers new to async Python and adds initial overhead.
Frequently Asked Questions
Related Projects
Strawberry GraphQLA GraphQL library for Python that leverages type annotations 🍓
FastAPI UtilitiesReusable utilities for FastAPI
SlowApiA rate limiter for Starlette and FastAPI
FastAPI Cachefastapi-cache is a tool to cache fastapi response and function result, with backends support redis and memcached.
Found a gem we're missing?
Open-Awesome is built by the community, for the community. Submit a project, suggest an awesome list, or help improve the catalog on GitHub.