Skip to main content
WALEventBusMiddleware appends completed event snapshots to a JSONL file.

​
Constructor params

  • wal_path: filesystem path for append-only JSONL output

​
Setup with EventBus

from bubus import EventBus
from bubus.middlewares import WALEventBusMiddleware

bus = EventBus(
    name='AppBus',
    middlewares=[WALEventBusMiddleware('./events.jsonl')],
)

​
Behavior

  • Writes one JSON line per completed event.
  • Uses internal locking for thread-safe file appends.
  • Creates parent directories automatically.
  • Intended for replay/debug/audit workflows.