Notion×他ツール連携で業務効率化を実現 - Zapier・IFTTT・API活用ガイド【2026年版】

// Notion API認証の基本設定
const { Client } = require('@notionhq/client');

const notion = new Client({
  auth: process.env.NOTION_TOKEN,
});

// Zapierフィルター設定例
const filter = {
  condition: 'only_continue_if',
  field: 'email_subject',
  contains: '【重要】'
};

// 週次レポート自動作成
async function createWeeklyReport() {
  const response = await notion.databases.query({
    database_id: process.env.TASKS_DATABASE_ID,
    filter: {
      and: [
        {
          property: 'Status',
          select: {
            equals: '完了'
          }
        },
        {
          property: 'Date',
          date: {
            this_week: {}
          }
        }
      ]
    }
  });

  // レポートページを作成
  await notion.pages.create({
    parent: { database_id: process.env.REPORTS_DATABASE_ID },
    properties: {
      'Title': {
        title: [{
          text: { content: `週次レポート ${new Date().toISOString().slice(0, 10)}` }
        }]
      },
      'Completed Tasks': {
        number: response.results.length
      }
    }
  });
}

// Slackメッセージを Notionに保存
const SlackWebApi = require('@slack/web-api');

async function saveSlackMessage(message) {
  await notion.pages.create({
    parent: { database_id: process.env.MESSAGES_DATABASE_ID },
    properties: {
      'Content': {
        rich_text: [{
          text: { content: message.text }
        }]
      },
      'User': {
        rich_text: [{
          text: { content: message.user }
        }]
      },
      'Channel': {
        select: { name: message.channel }
      }
    }
  });
}

// Google SheetsデータをNotionに同期
const { GoogleSpreadsheet } = require('google-spreadsheet');

async function syncGoogleSheets() {
  const doc = new GoogleSpreadsheet(process.env.SHEET_ID);
  await doc.useServiceAccountAuth(credentials);

  const sheet = doc.sheetsByIndex[0];
  const rows = await sheet.getRows();

  for (const row of rows) {
    await notion.pages.create({
      parent: { database_id: process.env.DATABASE_ID },
      properties: {
        'Name': {
          title: [{ text: { content: row.name } }]
        },
        'Value': {
          number: parseInt(row.value)
        }
      }
    });
  }
}

// GitHub Issueを自動でNotionに同期
async function syncGitHubIssues() {
  const { data: issues } = await octokit.issues.listForRepo({
    owner: 'your-org',
    repo: 'your-repo',
    state: 'open'
  });

  for (const issue of issues) {
    await notion.pages.create({
      parent: { database_id: process.env.ISSUES_DATABASE_ID },
      properties: {
        'Title': {
          title: [{ text: { content: issue.title } }]
        },
        'Status': {
          select: { name: issue.state }
        },
        'Assignee': {
          rich_text: [{ text: { content: issue.assignee?.login || 'Unassigned' } }]
        }
      }
    });
  }
}

// 堅牢なエラーハンドリング例
async function robustNotionUpdate(pageId, properties) {
  const maxRetries = 3;

  for (let i = 0; i < maxRetries; i++) {
    try {
      return await notion.pages.update({
        page_id: pageId,
        properties: properties
      });
    } catch (error) {
      if (i === maxRetries - 1) throw error;

      console.log(`リトライ ${i + 1}/${maxRetries}: ${error.message}`);
      await new Promise(resolve => setTimeout(resolve, 1000 * (i + 1)));
    }
  }
}

// Notion APIレート制限対策
const rateLimit = {
  requestsPerSecond: 3,
  lastRequestTime: 0
};

async function throttledRequest(requestFn) {
  const now = Date.now();
  const timeSinceLastRequest = now - rateLimit.lastRequestTime;
  const minInterval = 1000 / rateLimit.requestsPerSecond;

  if (timeSinceLastRequest < minInterval) {
    await new Promise(resolve =>
      setTimeout(resolve, minInterval - timeSinceLastRequest)
    );
  }

  rateLimit.lastRequestTime = Date.now();
  return await requestFn();
}

// Webhook受信サーバーの実装例
const express = require('express');
const app = express();

app.post('/webhook/notion', async (req, res) => {
  const { event, data } = req.body;

  switch (event) {
    case 'page.updated':
      await handlePageUpdate(data);
      break;
    case 'database.updated':
      await handleDatabaseUpdate(data);
      break;
  }

  res.status(200).json({ success: true });
});

// バッチ処理による効率化
async function batchUpdatePages(updates) {
  const batchSize = 10;
  const batches = [];

  for (let i = 0; i < updates.length; i += batchSize) {
    batches.push(updates.slice(i, i + batchSize));
  }

  for (const batch of batches) {
    await Promise.all(
      batch.map(update => throttledRequest(() =>
        notion.pages.update(update)
      ))
    );
  }
}

// 接続状態の確認
async function checkNotionConnection() {
  try {
    await notion.users.me();
    return { status: 'connected' };
  } catch (error) {
    return {
      status: 'error',
      message: error.message
    };
  }
}

// 自動化による時間削減の計算
const automationMetrics = {
  tasksPerDay: 50,
  timePerTaskMinutes: 5,
  workingDaysPerMonth: 20,
  hourlyRate: 3000,

  calculateMonthlySavings() {
    const dailyTimeSaved = this.tasksPerDay * this.timePerTaskMinutes;
    const monthlyTimeSaved = dailyTimeSaved * this.workingDaysPerMonth;
    const monthlyHoursSaved = monthlyTimeSaved / 60;
    return monthlyHoursSaved * this.hourlyRate;
  }
};

// OpenAI API とNotionの連携例
const openai = new OpenAI({
  apiKey: process.env.OPENAI_API_KEY
});

async function generateNotionContent(prompt) {
  const completion = await openai.chat.completions.create({
    model: "gpt-4",
    messages: [
      {
        role: "user",
        content: prompt
      }
    ]
  });

  const content = completion.choices[0].message.content;

  await notion.pages.create({
    parent: { database_id: process.env.AI_CONTENT_DB_ID },
    properties: {
      'Title': {
        title: [{ text: { content: `AI生成コンテンツ: ${new Date().toISOString()}` } }]
      },
      'Content': {
        rich_text: [{ text: { content: content } }]
      }
    }
  });
}