Tsumugi

A job management system designed for the Cloudflare stack.

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

See documentation at https://tsumugi.mq1.dev.

ドキュメントはhttps://tsumugi.mq1.devにあります。

Requirements

• A paid Workers plan. SQLite-backed Durable Objects and Queues both require it.
• compatibility_date of 2025-11-17 or later, for ctx.exports.
• A D1 database for the read model. Migrations shipped with the package must be applied.
• Analytics Engine is optional, and only needed for time series metrics.

• Workers Paidが必要, SQLite版のDurable ObjectsとQueuesの両方に必要
• compatibility_dateは2025-11-17以降, ctx.exportsのため
• D1が必要, 読み取りモデルの置き場でパッケージ同梱のマイグレーションの適用が必要
• Analytics Engineは任意, 時系列メトリクスを書く場合だけ設定する

Quickstart

pnpm create cloudflare@latest my-jobs --type=hello-world
cd my-jobs
pnpm add tsumugi
npx tsumugi init

tsumugi init creates the D1 database and the queue, generates the wrangler config and the source templates, and applies the migrations.

tsumugi initはD1とQueuesの作成, wrangler設定とソースの雛形の生成, マイグレーションの適用までを行います。

See Getting Started for what is generated and how to handle an existing configuration.

生成される内容と既存の設定がある場合の扱いはGetting Startedを参照してください。

Usage

Enqueue from any Worker, and Tsumugi orders and dispatches the jobs to your performers.

投入側のWorkerからenqueueを呼び出すと、Tsumugiが実行順序を決定し、performerへ配送します。

1. Define a performer

The body of the job goes in a performer class.

ジョブの処理内容はperformerクラスに記述します。

// src/performers/send-mail.ts
import { Performer } from 'tsumugi/performer';

export class SendMail extends Performer<{ to: string }, void, {}, Env> {
  async perform(payload: { to: string }): Promise<void> {
    await this.env.MAILER.send(payload.to);
  }
}

2. Register it in the Worker

Export the performers from the top level of the Worker. The binding name is the exported name, and the payload type is derived from the same place.

performerはWorkerのトップレベルからexportします。binding名はexportした名前が利用され、payloadの型も同じ場所から決定されます。

// src/index.ts
import { bearerAuth, defineTsumugi } from 'tsumugi';
import { ui } from 'tsumugi/ui';
import * as performers from './performers/index.js';

export * from './performers/index.js';
export { TsumugiJobShard } from 'tsumugi';

export const tsumugi = defineTsumugi({
  performers,
  auth: bearerAuth((env: Env) => env.TSUMUGI_TOKEN, { cookie: 'tsumugi_token' }),
  ui: ui({ tokenCookie: 'tsumugi_token' }),
});

export default tsumugi;

npx tsumugi init generates this file, so it rarely needs to be written by hand.

このファイルはnpx tsumugi initが生成するため、基本的に手動で編集する必要はありません。

3. Enqueue a job

enqueue can be called from any handler. It returns the job ID, and the binding name decides the payload type.

enqueueは任意のハンドラから呼び出すことが可能です。戻り値はジョブIDで、binding名からpayloadの型が決定されます。

const id = await tsumugi.enqueue(env, { binding: 'SendMail', payload: { to: 'a@example.com' } });

Common options are passed in the same call.

よく使うオプションは呼び出し時に指定可能です。

// 1分後に実行
await tsumugi.enqueue(env, { binding: 'SendMail', payload, delayMs: 60_000 });

// 待機中の他のジョブより先に投入
await tsumugi.enqueue(env, { binding: 'SendMail', payload, priority: 10 });

// 同じキーのジョブが残っている間は作成せず、既存のジョブIDを返す
await tsumugi.enqueue(env, { binding: 'SendMail', payload, uniqueKey: 'a@example.com' });

Dashboard and API

The dashboard is served at / and the REST API under /api, both behind the token configured above. Listing, search, retry and cancellation need no code of your own.

/にダッシュボード, /apiにREST APIが用意され、どちらも上で設定したトークンで認証します。

Runs: Flowの実行状況と依存関係	Job detail: 試行ごとのエラーと再実行
Schedules: 定期実行の予定と直近の発火	Bindings: 同時実行数の変更と一時停止

Flow, recurring execution, rate limits, delivery guarantees and remote performers are described in the documentation.

Flow, 定期実行, 流量制御, 実行保証, 別Workerへの配置についてはドキュメントを参照してください。

Development

Node.js 22 and pnpm are required.

Node.js 22とpnpmが必要です。

pnpm install
pnpm build
pnpm test

Layout

Path	Description
packages/tsumugi	The published package and its CLI
packages/dashboard	Dashboard UI, built into the package
packages/spec	TypeSpec definition of the REST API
examples/basic	Worker that defines and runs performers
examples/remote-performer	Performers placed in a separate Worker
site	Documentation site
docs/decision	Architecture decision records

Commands

Command	Description
pnpm build	Builds the dashboard, the spec and the package
pnpm typecheck	Typechecks every workspace
pnpm test	Typecheck and all test projects
pnpm test:unit	Pure functions, runs without workerd
pnpm test:workers	Tests running on workerd
pnpm format	Formats with Prettier

To run the documentation site or an example locally, use the workspace filter.

ドキュメントサイトやexampleを動かす場合はワークスペースを指定します。

pnpm --filter @tsumugi/site dev
pnpm --filter tsumugi-example-basic dev

License

MIT