GASでClaude APIの
バッチ処理でコストを50%削減する方法

// APIキーはスクリプトプロパティに保存する（コードに直書きしない）
// 「プロジェクトの設定」→「スクリプト プロパティ」で CLAUDE_API_KEY を登録
function getApiKey() {
  const key = PropertiesService
    .getScriptProperties()
    .getProperty("CLAUDE_API_KEY");
  if (!key) {
    throw new Error("CLAUDE_API_KEY が未設定です。スクリプトプロパティに登録してください。");
  }
  return key;
}

// 全リクエスト共通のヘッダー（バッチ専用のベータヘッダーは不要）
function apiHeaders() {
  return {
    "x-api-key": getApiKey(),
    "anthropic-version": "2023-06-01",
  };
}

// シートの未処理行をまとめて1つのバッチとして投げる
// ポイント：custom_id に行番号を埋め込み、あとで結果と突き合わせられるようにする
function submitBatch() {
  const sheet = SpreadsheetApp.getActive().getSheetByName("問い合わせ");
  const data = sheet.getDataRange().getValues();

  const requests = [];
  for (let i = 1; i < data.length; i++) {
    const text = String(data[i][0]).trim();
    const done = data[i][1]; // B列に分類済みなら入っている
    if (!text || done) continue; // 空行・処理済みはスキップ

    requests.push({
      // custom_id は英数字・ハイフン・アンダースコアのみ、1〜64文字
      custom_id: "row-" + (i + 1), // 実際のシート行番号（1始まり）
      params: {
        model: "claude-sonnet-4-5",
        max_tokens: 300,
        system: "問い合わせを「見積依頼 / サポート / クレーム / 営業 / その他」から1つ選び、"
          + 'JSONのみで返してください。形式: {"category":"サポート"}',
        messages: [{ role: "user", content: text }],
      },
    });
  }

  if (requests.length === 0) {
    Logger.log("処理対象の行がありません。");
    return;
  }

  const res = UrlFetchApp.fetch("https://api.anthropic.com/v1/messages/batches", {
    method: "post",
    contentType: "application/json",
    headers: apiHeaders(),
    payload: JSON.stringify({ requests: requests }),
    muteHttpExceptions: true,
  });

  if (res.getResponseCode() !== 200) {
    throw new Error("バッチ作成に失敗: " + res.getResponseCode() + " / " + res.getContentText());
  }

  const batch = JSON.parse(res.getContentText());
  Logger.log("バッチID: " + batch.id);              // msgbatch_...
  Logger.log("状態: " + batch.processing_status);    // 最初は in_progress

  // バッチIDを保存しておく（あとで結果を取りに行くときに使う）
  PropertiesService.getScriptProperties().setProperty("BATCH_ID", batch.id);
  return batch.id;
}

// バッチの進み具合を確認する
// processing_status は in_progress → ended と変化し、ended で結果が揃う
function checkBatch(batchId) {
  const res = UrlFetchApp.fetch(
    "https://api.anthropic.com/v1/messages/batches/" + batchId,
    { method: "get", headers: apiHeaders(), muteHttpExceptions: true }
  );

  if (res.getResponseCode() !== 200) {
    throw new Error("状態取得に失敗: " + res.getContentText());
  }

  const batch = JSON.parse(res.getContentText());
  const counts = batch.request_counts;

  Logger.log("状態: " + batch.processing_status);
  Logger.log(
    "処理中:" + counts.processing +
    " 成功:" + counts.succeeded +
    " エラー:" + counts.errored +
    " 期限切れ:" + counts.expired
  );
  return batch;
}
// batch.results_url は処理中は null で、ended になると結果のURLが入る

// 結果を取り出してシートに書き戻す
// 結果は JSONL（1行1件のJSON）形式で返る
function fetchResults(batchId) {
  const batch = checkBatch(batchId);

  if (batch.processing_status !== "ended") {
    Logger.log("まだ処理中です。あとでもう一度確認してください。");
    return false;
  }

  // results_url にも同じ認証ヘッダーを付けて取得する
  const res = UrlFetchApp.fetch(batch.results_url, {
    method: "get",
    headers: apiHeaders(),
    muteHttpExceptions: true,
  });

  const sheet = SpreadsheetApp.getActive().getSheetByName("問い合わせ");

  // 1行ずつ JSON としてパースする（空行は無視）
  const lines = res.getContentText().split("\n").filter(function (l) {
    return l.trim() !== "";
  });

  lines.forEach(function (line) {
    const item = JSON.parse(line);
    // custom_id から行番号を復元する（結果は順不同なので必須）
    const rowNum = Number(item.custom_id.replace("row-", ""));

    if (item.result.type === "succeeded") {
      const text = item.result.message.content[0].text;
      try {
        sheet.getRange(rowNum, 2).setValue(JSON.parse(text).category);
      } catch (e) {
        sheet.getRange(rowNum, 2).setValue("解析失敗: " + text);
      }
    } else if (item.result.type === "errored") {
      // 課金されない。invalid_request ならリクエスト側の不備
      sheet.getRange(rowNum, 2).setValue("エラー: " + item.result.error.type);
    } else if (item.result.type === "expired") {
      // 24時間以内に処理されなかった。課金されないので投げ直す
      sheet.getRange(rowNum, 2).setValue("期限切れ（要再実行）");
    }
  });

  Logger.log(lines.length + "件を書き戻しました。");
  return true;
}

// 「投げっぱなし」運用：トリガーで完了を待ち受ける
// submitBatch() を実行したあと、この関数を5分おきのトリガーに登録する

function watchBatch() {
  const props = PropertiesService.getScriptProperties();
  const batchId = props.getProperty("BATCH_ID");
  if (!batchId) return; // 監視対象なし

  const finished = fetchResults(batchId);

  if (finished) {
    props.deleteProperty("BATCH_ID"); // 監視終了
    removeWatchTriggers();            // トリガーも片付ける
    Logger.log("完了しました。");
  }
}

// 5分おきのトリガーを作る（submitBatch のあとに1回だけ呼ぶ）
function startWatching() {
  removeWatchTriggers(); // 二重登録を防ぐ
  ScriptApp.newTrigger("watchBatch").timeBased().everyMinutes(5).create();
}

// watchBatch のトリガーだけを削除する
function removeWatchTriggers() {
  ScriptApp.getProjectTriggers().forEach(function (t) {
    if (t.getHandlerFunction() === "watchBatch") {
      ScriptApp.deleteTrigger(t);
    }
  });
}

// 実行の流れ：
//   1. submitBatch()   → バッチを投げてIDを保存（数秒で終わる）
//   2. startWatching() → 5分おきの監視トリガーを登録
//   3. watchBatch()    → 完了していれば書き戻してトリガーを削除
// 推論の待ち時間はAnthropic側で進むため、GASの6分制限に当たらない