Node.jsでGoogle Search Console APIをローカルで実行して特定キーワードの検索順位データをCSV化する

require('dotenv').config(); // .envファイルを環境変数として読み込み
const fs = require('fs');
// Google APIs Node.js Client 読み込み
const { google } = require('googleapis');

// 保存ファイル名
const fileName = 'position.csv';
// 対象サイトのURL
const siteUrl = 'https://www.example.com/';
// 検索キーワード
const query = 'example';

async function runPosition() {
  // Google認証の初期化
  const auth = new google.auth.GoogleAuth({
    keyFile: process.env.GOOGLE_APPLICATION_CREDENTIALS,
    scopes: ['https://www.googleapis.com/auth/webmasters.readonly'],
  });
  const authClient = await auth.getClient();
  google.options({ auth: authClient });
  // Search Consoleライブラリの読み込み
  const searchConsole = google.searchconsole('v1');

  // 3日前までしか取れないので、終了日は3日前に設定する
  // 文字列化する際にtoISOStringを使用するため、JSTのタイムゾーンオフセット分ずらす
  const endDateDate = new Date(Date.now() + 9 * 60 * 60 * 1000 - 3 * 24 * 60 * 60 * 1000);
  const endDate = endDateDate.toISOString().substring(0, 10);
  // 開始日は7日前に設定しておく（終了日の4日前）
  const startDate = new Date(endDateDate - 4 * 24 * 60 * 60 * 1000).toISOString().substring(0, 10);

  // データ取得
  const response = await searchConsole.searchanalytics
    .query({
      siteUrl,
      requestBody: {
        startDate,
        endDate,
        dimensions: ['date'],
        dimensionFilterGroups: [
          {
            groupType: 'and',
            filters: [
              {
                dimension: 'query',
                operator: 'contains',
                expression: query,
              },
            ],
          },
        ],
        metrics: ['position'],
        rowLimit: 25000,
      },
    });

  const positionData = [];
  // ステータスチェック
  if (response.statusText == 'OK' && response.data.rows.length) {
    for (const row of response.data.rows) {
      const date = row.keys[0];
      positionData.push({
        date,
        position: row.position,
        impressions: row.impressions,
      });
    }
  } else {
    // 失敗時
    console.log('error', response.statusText, response);
    return;
  }

  // 保存済みのファイルがあれば読み込む
  const text = fs.existsSync(fileName) ? fs.readFileSync(fileName).toString() : '';
  // 保存済みの最新日の取得
  let lastDate = '0000-00-00';
  if (text) {
    const lastLine = text.trim().split('\r\n').pop();
    const dateStr = lastLine.split(',')[0];
    if (!isNaN(dateStr.replace(/-/g, ''))) {
      lastDate = dateStr;
    }
  }
  if (!text) {
    // 保存済みファイルがない場合はヘッダーを書き込み
    const header = Object.keys(positionData[0]).join(',');
    fs.writeFileSync(fileName, header);
  }
  // 書き込み用データ
  const appendLines = /\n$/.test(text) ? [] : [''];
  for (const data of positionData) {
    const dateValue = data.date;
    // 保存済みの最新日より新しい日付のみ追記する
    if (dateValue > lastDate) {
      appendLines.push(Object.values(data).join(','));
    }
  }
  const appendText = appendLines.join('\r\n');
  if (appendText) {
    fs.appendFileSync(fileName, appendText);
  }
}

runPosition();