scaffolding-fastapi-dapr

Define SQLModel classes with a Base/Table/Create/Read hierarchy, create an async engine with create_async_engine using a postgresql+asyncpg URL, and yield AsyncSession via a FastAPI dependency. Use await session.exec() for queries and session.get() for lookups by ID.

Expose a GET /dapr/subscribe endpoint returning your topic subscriptions, then create POST handlers for each topic route. Always unwrap the CloudEvent envelope by reading the data field from the raw JSON payload before processing your event.

Dapr Jobs API v1.0-alpha1 always calls back to POST /job/{job_name}, not a custom route. Register a handler at exactly that path pattern and unwrap the job payload from the request body to process reminders or scheduled tasks.

Fetch the JWKS from your auth server, cache it with a TTL, match the token's kid header to a key, and decode with python-jose using RS256. Use FastAPI's HTTPBearer security scheme so Swagger UI shows an Authorize button.

After commit, ORM objects become detached and attribute access triggers lazy loading that fails in async contexts. Extract primitive values like IDs right after flush, pass primitives to services, and commit once at the end of the endpoint.

Avoid it for simple scripts or non-microservice architectures where Dapr sidecars and pub/sub add unnecessary operational overhead. It is designed for event-driven services on Kubernetes, not single-process applications.