Tsumugi

Cloudflareスタック向けに設計されたジョブ管理システム

書くのは2つだけ

performerクラスを定義して, enqueueを呼びます. どのDurable Objectへ渡すか, consumerで何を実行するか, 状態をいつD1へ書くかはTsumugiが持ちます

enqueue(env, { binding, payload })でジョブIDが返ります. キューもconsumerの分岐も読み取りモデルも表に出てきません

リトライ, バックオフ, 予約実行, 優先度, 同時実行数とレートの制限, 重複排除, 管理画面が揃っています. 後から足す必要がありません

全状態がD1に投影されるので, 一覧も検索も集計も通常のSQLで書けます. 失敗率や実行時間はAnalytics Engineに残ります

既定はat-least-onceです. 二重実行が致命的なジョブだけat-most-onceにすると, 実行前にDurable Objectへclaimを取得します

service binding越しに別Workerへ置けます. 投入するだけのWorkerはDurable Objectの実装をバンドルせずに済みます