Redis Streams でイベントを残せる通知システムを書いてみる
Pub/Sub では取りこぼしていた起動前のイベントを、Redis Streams（XADD + XREAD）でログとして残し、あとから起動した consumer でも読めるようにしてみた。
backendpython
Pub/Sub では取りこぼしていた起動前のイベントを、Redis Streams（XADD + XREAD）でログとして残し、あとから起動した consumer でも読めるようにしてみた。
注文完了イベントを Redis Pub/Sub で発火し、メール通知とポイント付与の2つの subscriber が独立して受け取る処理をで書いてみた。
時間のかかる画像リサイズを Celery のタスクキューに逃がし、ステータスを Redis で追えるようにして動かしてみた。