FastAPI Integration

# Install TigerOps with FastAPI extras
pip install tigerops[fastapi]

# Set environment variables
export TIGEROPS_API_KEY="your-api-key"
export TIGEROPS_SERVICE_NAME="my-fastapi-service"
export TIGEROPS_ENVIRONMENT="production"

# main.py
import tigerops
from fastapi import FastAPI, BackgroundTasks, Depends
from sqlalchemy.ext.asyncio import AsyncSession

app = FastAPI(title="Order Service")

# Instrument FastAPI — must be called after app creation
tigerops.instrument_fastapi(app)

# Database sessions are auto-traced
async def get_db() -> AsyncSession:
    async with async_session() as session:
        yield session

@app.get("/orders/{order_id}")
async def get_order(
    order_id: str,
    db: AsyncSession = Depends(get_db),
):
    # SQLAlchemy query is auto-instrumented
    result = await db.execute(
        select(Order).where(Order.id == order_id)
    )
    return result.scalar_one_or_404()

@app.post("/orders")
async def create_order(
    payload: OrderCreate,
    background_tasks: BackgroundTasks,
    db: AsyncSession = Depends(get_db),
):
    order = Order(**payload.model_dump())
    db.add(order)
    await db.commit()

    # Background task is linked to this request trace
    background_tasks.add_task(send_confirmation_email, order.id)
    return order

# Custom span with the context manager
from tigerops import span

@app.post("/checkout")
async def checkout(cart_id: str):
    async with span("inventory.check") as s:
        s.set_attribute("cart.id", cart_id)
        available = await check_inventory(cart_id)

    async with span("payment.charge") as s:
        charge = await charge_payment(cart_id)
        s.set_attribute("payment.charge_id", charge.id)

    return {"status": "ok"}