Redis Streams の Consumer Group で処理済みを管理する
素の XREAD では読んだ位置を自分で持つだけだったのを Consumer Group にして、位置を Redis に記憶させ ack で処理済みを管理できるようにしてみた。
backendpython
素の XREAD では読んだ位置を自分で持つだけだったのを Consumer Group にして、位置を Redis に記憶させ ack で処理済みを管理できるようにしてみた。
Pub/Sub では取りこぼしていた起動前のイベントを、Redis Streams（XADD + XREAD）でログとして残し、あとから起動した consumer でも読めるようにしてみた。
注文完了イベントを Redis Pub/Sub で発火し、メール通知とポイント付与の2つの subscriber が独立して受け取る処理をで書いてみた。