moai-domain-backend

JWT authentication in FastAPI uses HTTPBearer or OAuth2PasswordBearer security dependencies with python-jose for token encoding. Create tokens with HS256 algorithm and expiration claims, then validate them in a dependency that raises 401 errors on expired or invalid tokens.

Configure create_async_engine with QueuePool, pool_size of 20, max_overflow of 30, pool_pre_ping enabled, and pool_recycle of 3600 seconds. Pair it with an async sessionmaker and a context manager that commits on success and rolls back on exceptions.

The repository pattern encapsulates data access in a class that checks Redis before querying the database and caches results with a TTL. Write operations invalidate the corresponding cache keys to keep data consistent.

Yes, aio-pika provides async RabbitMQ integration for FastAPI services. Declare a topic exchange, publish JSON messages with routing keys, and subscribe with durable queues so services like notifications react to events such as order.created.

Blocking occurs when synchronous libraries like requests run inside async endpoints, freezing the event loop. Use httpx.AsyncClient or run blocking calls in a thread pool, and add circuit breakers with tenacity retries for resilience.

Circuit breakers add unnecessary complexity for internal calls on reliable networks or low-traffic prototypes. They are most valuable for external payment or third-party APIs where cascading failures and timeouts must be contained.