YouTubeに動画が投稿されたらDiscordに通知する。

2026.04.04 の修正では、時間トリガー実行中の一時的な基盤不安定や外部呼び出し時の異常終了を修正しました。このスクリプトは、時間トリガーで動き、YouTube API・Discord Webhook・Spreadsheet の3系統に触るので、失敗点を細かく分けて再試行できるように変更しました。時間主導トリガーは installable trigger として動作し、LockService は同時実行の衝突回避に使用。

修正はこの3点です。
1. 外部呼び出しに再試行を入れる
2. getActiveSpreadsheet() 依存をやめて openById() にする
3. 実行の最後の到達地点が必ず分かるログを増やす
SpreadsheetApp.openById(id) は公式に用意されていて、スプレッドシートIDで明示的に開けます。時間トリガーのようなヘッドレス実行では、こちらの方が安定した切り分けがしやすいため採用しました。

1. Activities.list をやめて playlistItems.list に変える

YouTube 公式の実装ガイドにその流れを案内しているため。

2. LockService を使って二重起動を防ぐ

時間トリガーが重なると、同じシートへ同時アクセスしたり、同じ通知を二重送信したりして不安定になるため。

3. PropertiesService で upload playlist ID をキャッシュする

毎回 channels.list しても良いですが、初回取得後に保存しておくと無駄なAPI呼び出しが減ることを知ったため。

4. 例外箇所を細かく分ける

今は大枠でしか失敗原因が見えないので、

• YouTube取得

• シート読込

• Discord送信

• シート書込
  を分けてログに出すと切り分けしやすくした。

5. Utilities.sleep(1000) は必要最小限に

1件ずつ送るなら残しても良いですが、件数が多いと実行時間を無駄に使うため。Discord Webhook は通常そこまで厳しくないので、まずは 300ms 程度でもよいです。

修正・改善点

eventType: "none" は無効なパラメータ

eventType は completed, live, upcoming のいずれかです。"none" を指定すると意図しない挙動になるか、パラメータが無視されます。通常の動画のみを取得したい場合はフィルタリングロジックをJS側で行うのが安全のため。

スプレッドシートの範囲取得の効率化

sheet.getRange("A2:A").getValues() はシートの最終行（デフォルトで1000行以上）まで空白を含めて読み込むため、処理が重くなります。データがある行まで (getLastRow) に限定するよう変更。

Discordへの連続投稿制限

複数の動画が同時に見つかった場合、ループで一瞬でPOSTするとDiscord側でレート制限（Rate Limit）にかかる可能性があります。Utilities.sleep(1000) などで少し待機時間を挟むのがマナーのために変更。

通知の順序

APIは「新しい順」で返ってきますが、ループでそのまま処理すると「最新の動画」が先に通知され、その後に「その前の動画」が通知されます。Discord上では時系列順（古い→新しい）に並んだほうが自然なため、配列を逆順にするか、後ろから処理することをお勧めします。

function checkYouTubeAndNotify() {

  const lock = LockService.getScriptLock();

  if (!lock.tryLock(10000)) {

    console.warn("Another execution is already running. Skipped.");

    return;

  }

  const startedAt = new Date();

  console.log("========================================");

  console.log(`Start: ${startedAt.toISOString()}`);

  try {

    const config = getConfig_();

    validateConfig_(config);

    console.log("Checkpoint: config loaded");

    const sheet = getOrSetupSheet_(config.spreadsheetId, config.sheetName);

    console.log("Checkpoint: sheet opened");

    const sentVideoIds = getSentVideoIds_(sheet);

    console.log(`Known video IDs: ${sentVideoIds.size}`);

    const uploadPlaylistId = getUploadPlaylistId_(config.channelId);

    console.log(`Upload playlist ID: ${uploadPlaylistId}`);

    const items = fetchLatestUploads_(uploadPlaylistId, config.maxResults);

    console.log(`Fetched items: ${items.length}`);

    console.log("Checkpoint: latest uploads fetched");

    processVideos_(items, sheet, sentVideoIds, config);

    console.log("Checkpoint: processVideos end");

    console.log(`Finished successfully. Duration(ms): ${new Date() - startedAt}`);

  } catch (err) {

    console.error(`Fatal error: ${err && err.stack ? err.stack : err}`);

    throw err;

  } finally {

    lock.releaseLock();

    console.log("End.");

    console.log("========================================");

  }

}

/* =========================

   CONFIG

========================= */

function getConfig_() {

  const props = PropertiesService.getScriptProperties();

  return {

    channelId: (props.getProperty("CHANNEL_ID") || "").trim(),

    webhookUrls: (props.getProperty("WEBHOOK_URLS") || "")

      .split(/\r?\n|,/)

      .map(s => s.trim())

      .filter(Boolean),

    spreadsheetId: (props.getProperty("SPREADSHEET_ID") || "").trim(),

    botName: (props.getProperty("BOT_NAME") || "YouTube通知").trim(),

    sheetName: (props.getProperty("SHEET_NAME") || "SentVideos_001").trim(),

    maxResults: parseInt(props.getProperty("MAX_RESULTS") || "10", 10),

    sleepMs: parseInt(props.getProperty("SLEEP_MS") || "300", 10),

  };

}

function validateConfig_(config) {

  if (!config.channelId) throw new Error("CHANNEL_ID 未設定");

  if (!config.webhookUrls.length) throw new Error("WEBHOOK_URLS 未設定");

  if (!config.spreadsheetId) throw new Error("SPREADSHEET_ID 未設定");

}

/* =========================

   RETRY CORE

========================= */

function withRetries_(fn, label, maxAttempts = 3, baseSleep = 1000) {

  let lastError;

  for (let i = 1; i <= maxAttempts; i++) {

    try {

      console.log(`[TRY ${i}] ${label}`);

      return fn();

    } catch (err) {

      lastError = err;

      console.error(`[FAIL ${i}] ${label}: ${err.message}`);

      if (i < maxAttempts) {

        Utilities.sleep(baseSleep * i);

      }

    }

  }

  throw lastError;

}

/* =========================

   YOUTUBE

========================= */

function getUploadPlaylistId_(channelId) {

  const props = PropertiesService.getScriptProperties();

  const key = `UPLOAD_PLAYLIST_ID__${channelId}`;

  let id = props.getProperty(key);

  if (id) return id;

  const res = withRetries_(() =>

    YouTube.Channels.list("contentDetails", { id: channelId })

  , "YouTube.Channels.list");

  id = res.items[0].contentDetails.relatedPlaylists.uploads;

  props.setProperty(key, id);

  return id;

}

function fetchLatestUploads_(playlistId, max) {

  const res = withRetries_(() =>

    YouTube.PlaylistItems.list("snippet,contentDetails", {

      playlistId: playlistId,

      maxResults: max

    })

  , "YouTube.PlaylistItems.list");

  return res.items || [];

}

/* =========================

   PROCESS

========================= */

function processVideos_(items, sheet, sent, config) {

  const ordered = items.slice().reverse();

  for (const item of ordered) {

    try {

      const videoId = item?.contentDetails?.videoId;

      if (!videoId || sent.has(videoId)) continue;

      const title = item.snippet.title;

      const url = `https://youtu.be/${videoId}`;

      const payload = {

        username: config.botName,

        content:

`📺 新しい動画が投稿されました！

🎬 ${title}

🔗 ${url}`

      };

      const ok = postDiscord_(payload, config.webhookUrls);

      if (ok) {

        sheet.appendRow([videoId, title, url, new Date()]);

        sent.add(videoId);

        console.log(`Sent: ${title}`);

        Utilities.sleep(config.sleepMs);

      }

    } catch (e) {

      console.error("Item error:", e);

    }

  }

}

/* =========================

   DISCORD

========================= */

function postDiscord_(payload, urls) {

  let success = true;

  for (const url of urls) {

    try {

      const res = withRetries_(() =>

        UrlFetchApp.fetch(url, {

          method: "post",

          contentType: "application/json",

          payload: JSON.stringify(payload),

          muteHttpExceptions: true

        })

      , "Discord fetch");

      if (res.getResponseCode() >= 300) {

        success = false;

      }

    } catch (e) {

      success = false;

    }

  }

  return success;

}

/* =========================

   SHEET

========================= */

function getOrSetupSheet_(spreadsheetId, sheetName) {

  const ss = withRetries_(() =>

    SpreadsheetApp.openById(spreadsheetId)

  , "Spreadsheet open");

  let sheet = ss.getSheetByName(sheetName);

  if (!sheet) {

    sheet = ss.insertSheet(sheetName);

    sheet.appendRow(["VideoID", "Title", "URL", "Date"]);

  }

  return sheet;

}

function getSentVideoIds_(sheet) {

  const lastRow = sheet.getLastRow();

  if (lastRow <= 1) return new Set();

  const values = sheet.getRange(2, 1, lastRow - 1, 1).getValues().flat();

  return new Set(values);

}

/**

 * 初期設定を一括で入れたい場合だけ手動実行してください。

 * 必要に応じて値を書き換えてから実行。

 */

function setupScriptProperties() {

  const props = PropertiesService.getScriptProperties();

  props.setProperties({

    CHANNEL_ID: "チャンネルIDを記載",

    WEBHOOK_URLS: "Discordのウェブフックを指定",

    BOT_NAME: "DiscordのBOT名を記載",

    SPREADSHEET_ID: "あなたのスプレッドシートID",

    SHEET_NAME: "スプレッドシート名を指定",

    MAX_RESULTS: "10",

    SLEEP_MS: "300",

    SKIP_OLD_ON_FIRST_RUN: "false"

  }, true);

  console.log("Script Properties have been set.");

}