Apps Script の Gemini 自動化が月末に必ず止まる — UrlFetch 日次上限を溶かさない予算ガバナー設計

// After: 日次予算ガバナー（token-bucket / TZ境界リセット）
const DAILY_QUOTA    = 20000;  // consumer。Workspace は 100000
const MARGIN         = 0.15;   // 安全マージン
const RESERVE        = 500;    // 予約枠
const CALLS_PER_ITEM = 1.08;   // リトライ増幅の見込み（実測に合わせる）
const TZ = 'Asia/Tokyo';
 
function usableBudget() {
  return Math.floor(DAILY_QUOTA * (1 - MARGIN)) - RESERVE;  // 16500
}
 
// 今日の日付キー（TZ境界でロールオーバー）
function todayKey() {
  return Utilities.formatDate(new Date(), TZ, 'yyyy-MM-dd');
}
 
// 残り予算を返す。日付が変わっていれば使用量を0にリセット
function remainingBudget() {
  const props = PropertiesService.getScriptProperties();
  const ledger = JSON.parse(props.getProperty('urlfetch_ledger') || '{}');
  if (ledger.date !== todayKey()) {
    ledger.date = todayKey();
    ledger.used = 0;
    props.setProperty('urlfetch_ledger', JSON.stringify(ledger));
  }
  return usableBudget() - (ledger.used || 0);
}
 
// 実際に使った回数を記録（LockServiceで競合を畳む）
function chargeBudget(calls) {
  const lock = LockService.getScriptLock();
  lock.waitLock(10000);
  try {
    const props = PropertiesService.getScriptProperties();
    const ledger = JSON.parse(props.getProperty('urlfetch_ledger') || '{}');
    if (ledger.date !== todayKey()) { ledger.date = todayKey(); ledger.used = 0; }
    ledger.used = (ledger.used || 0) + calls;
    props.setProperty('urlfetch_ledger', JSON.stringify(ledger));
  } finally {
    lock.releaseLock();
  }
}

// After: 残り予算の範囲でだけ処理し、残りは翌日へ
function enrichWithinBudget() {
  const sheet = SpreadsheetApp.getActiveSpreadsheet().getSheetByName('reviews');
  const rows = sheet.getDataRange().getValues();
 
  let remaining = remainingBudget();
  if (remaining <= 0) {
    console.log('今日の UrlFetch 予算を使い切りました。翌日へ繰り越します。');
    return;
  }
  // 残り予算を「件数」に換算（リトライ増幅を織り込む）
  let itemsAllowed = Math.floor(remaining / CALLS_PER_ITEM);
 
  for (let i = 1; i < rows.length && itemsAllowed > 0; i++) {
    if (rows[i][STATUS_COL]) continue;
    const { draft, calls } = callGeminiWithRetry(rows[i][TEXT_COL]);
    sheet.getRange(i + 1, STATUS_COL + 1).setValue('done');
    sheet.getRange(i + 1, DRAFT_COL + 1).setValue(draft);
    chargeBudget(calls);          // 実際に使った回数を台帳へ
    itemsAllowed -= 1;
  }
}
 
// リトライした回数も返すことで、台帳を実測に寄せる
function callGeminiWithRetry(text) {
  let calls = 0;
  for (let attempt = 0; attempt < 3; attempt++) {
    calls += 1;
    const res = UrlFetchApp.fetch(GEMINI_ENDPOINT, {
      method: 'post', contentType: 'application/json',
      headers: { 'x-goog-api-key': 'YOUR_API_KEY' },
      payload: JSON.stringify({ contents: [{ parts: [{ text: text }] }] }),
      muteHttpExceptions: true,
    });
    if (res.getResponseCode() === 200) {
      const draft = JSON.parse(res.getContentText()).candidates[0].content.parts[0].text;
      return { draft, calls };
    }
    Utilities.sleep(Math.pow(2, attempt) * 1000);  // 指数バックオフ
  }
  return { draft: '', calls };  // 失敗行は空のまま次回へ
}

import math
DAILY_QUOTA, MARGIN, RESERVE, CALLS_PER_ITEM = 20000, 0.15, 500, 1.08
UB = int(DAILY_QUOTA * (1 - MARGIN)) - RESERVE          # 16500
CAP = math.floor(UB / CALLS_PER_ITEM)                   # 15277 件/日
 
arrivals = [3000]*14
arrivals[4] += 40000                                    # 5日目にスパイク
 
backlog = 0
for d in range(14):
    pend = backlog + arrivals[d]
    proc = min(pend, CAP)               # 予算内でだけ処理
    backlog = pend - proc               # 残りは翌日へ
    naive = math.ceil(arrivals[d] * CALLS_PER_ITEM)     # 素朴実装の呼び出し数
    status = "OK" if naive <= DAILY_QUOTA else "THROW"
    print(d+1, arrivals[d], proc, backlog, naive, status)