event-monitoring

A tiny, non-blocking emitter that publishes business/contextual events from any Python app to a Redis Stream for a monitoring dashboard to consume.

• Sync (emit) and async (aemit) APIs.
• Transaction-safe under Django (transaction.on_commit); works fine without Django.
• Opt-in — a no-op unless MONITORING_ENABLED is truthy, so it's inert when installed into an app nobody has wired up to a dashboard.
• Only hard dependency is redis.

Install

pip install event-monitoring
# or
uv add event-monitoring

Pre-release / unpublished, straight from Git:

pip install "git+https://github.com/<you>/event-monitoring.git@v0.1.0"

For local cross-repo dev, as a uv path source:

[tool.uv.sources]
event-monitoring = { path = "../event-monitoring", editable = true }

Usage

import event_monitoring

# Sync (Django views, scripts, workers)
event_monitoring.emit(
    event="offer_approved",
    entity_type="offer", entity_id=offer.id,
    actor_id=request.user.id,
    url=request.build_absolute_uri(offer.get_absolute_url()),
    payload={"amount": offer.amount},
)

# Async (asyncio apps — e.g. a Discord bot). Offloads the blocking publish.
await event_monitoring.aemit("music_played", entity_type="guild", entity_id=guild_id,
                             actor_id=user.id, payload={"song": title})

Configuration (env vars)

Publish failures are swallowed (warned once) — monitoring never breaks the host app.

Event shape

{"app":"rms","event":"offer_approved","entity_type":"offer","entity_id":"123",
 "actor_id":"55","url":"https://rms.example/offers/123",
 "timestamp":"<naive-UTC-iso>","payload":{}}