Workersのデプロイコマンド

# wrangler.toml
[env.staging]
route = "staging.example.com/*"
vars = { API_URL = "https://api-staging.example.com" }

[env.production]
route = "example.com/*"
vars = { API_URL = "https://api.example.com" }

# バージョンをアップロードのみ（まだトラフィックには流れない）
wrangler versions upload

# トラフィックの10%だけ新バージョンに流す
wrangler versions deploy --version-id <id> --percentage 10

# 問題があれば即ロールバック
wrangler rollback

# wrangler.toml
[[kv_namespaces]]
binding = "MY_KV"          # env.MY_KV でアクセス
id = "xxxxxxxxxxxxxxxx"    # 本番KVのID
preview_id = "yyyyyyyy"    # wrangler dev 用のプレビューID

// Worker コード
export default {
  async fetch(req: Request, env: Env) {
    // 書き込み（TTLも指定可能）
    await env.MY_KV.put("user:123", JSON.stringify({ name: "Taro" }), {
      expirationTtl: 3600,  // 1時間で自動削除
    });

    // 読み込み
    const val = await env.MY_KV.get("user:123", { type: "json" });

    // 削除
    await env.MY_KV.delete("user:123");

    // キー一覧（prefix で絞り込み可）
    const list = await env.MY_KV.list({ prefix: "user:" });
  }
};

[[d1_databases]]
binding = "DB"
database_name = "my-database"
database_id = "xxxxxxxxxxxxxxxx"

export default {
  async fetch(req: Request, env: Env) {
    // 単一クエリ
    const user = await env.DB.prepare(
      "SELECT * FROM users WHERE id = ?"
    ).bind(123).first();

    // 複数行取得
    const { results } = await env.DB.prepare(
      "SELECT * FROM users WHERE active = 1"
    ).all();

    // バッチ実行（複数クエリをアトミックに）
    await env.DB.batch([
      env.DB.prepare("INSERT INTO logs (msg) VALUES (?)").bind("started"),
      env.DB.prepare("UPDATE users SET last_seen = ? WHERE id = ?")
        .bind(Date.now(), 123),
    ]);
  }
};

[[r2_buckets]]
binding = "MY_BUCKET"
bucket_name = "my-app-assets"
preview_bucket_name = "my-app-assets-dev"  # dev用

export default {
  async fetch(req: Request, env: Env) {
    const url = new URL(req.url);
    const key = url.pathname.slice(1);  // "/image.png" → "image.png"

    if (req.method === "PUT") {
      // アップロード
      await env.MY_BUCKET.put(key, req.body, {
        httpMetadata: { contentType: req.headers.get("Content-Type") ?? "" },
        customMetadata: { uploadedBy: "worker" },
      });
      return new Response("OK");
    }

    // ダウンロード
    const obj = await env.MY_BUCKET.get(key);
    if (!obj) return new Response("Not found", { status: 404 });

    return new Response(obj.body, {
      headers: { "Content-Type": obj.httpMetadata?.contentType ?? "application/octet-stream" },
    });
  }
};

[[durable_objects.bindings]]
name = "ROOM"
class_name = "ChatRoom"

[[migrations]]
tag = "v1"
new_classes = ["ChatRoom"]

// Durable Object クラス（同じWorkerファイルに定義）
export class ChatRoom {
  state: DurableObjectState;
  constructor(state: DurableObjectState) {
    this.state = state;
  }

  async fetch(req: Request) {
    // 永続ストレージへの読み書き
    const count = (await this.state.storage.get<number>("count")) ?? 0;
    await this.state.storage.put("count", count + 1);
    return new Response(`count: ${count + 1}`);
  }
}

// Worker 本体
export default {
  async fetch(req: Request, env: Env) {
    // IDによって「どのインスタンスか」を決定
    const id = env.ROOM.idFromName("room-general");
    const stub = env.ROOM.get(id);
    return stub.fetch(req);  // そのインスタンスへ転送
  }
};

# 送信側（Producer）
[[queues.producers]]
binding = "MY_QUEUE"
queue = "my-task-queue"

# 受信側（Consumer）
[[queues.consumers]]
queue = "my-task-queue"
max_batch_size = 10       # 一度に処理するメッセージ数
max_batch_timeout = 5     # 秒
max_retries = 3

export default {
  // Producer: キューにメッセージを送る
  async fetch(req: Request, env: Env) {
    await env.MY_QUEUE.send({ userId: 123, action: "welcome_email" });
    return new Response("Queued!");
  },

  // Consumer: バッチでメッセージを受け取る
  async queue(batch: MessageBatch, env: Env) {
    for (const msg of batch.messages) {
      console.log(msg.body);  // { userId: 123, action: "welcome_email" }
      msg.ack();              // 処理完了を通知
    }
  }
};

[[services]]
binding = "AUTH_SERVICE"
service = "my-auth-worker"  # 別Workerの名前

export default {
  async fetch(req: Request, env: Env) {
    // 別のWorkerをHTTPリクエストと同じ感覚で呼び出せる
    const authRes = await env.AUTH_SERVICE.fetch(
      new Request("https://internal/verify", {
        method: "POST",
        body: JSON.stringify({ token: req.headers.get("Authorization") }),
      })
    );

    if (!authRes.ok) return new Response("Unauthorized", { status: 401 });
    return new Response("Hello, authenticated user!");
  }
};

[vars]
ENVIRONMENT = "production"
API_BASE_URL = "https://api.example.com"

wrangler secret put STRIPE_SECRET_KEY
# → プロンプトが出て、値を入力するとCF側に暗号化保存される