Looker StudioからNotionデータベースを直接覗いてみる

Posted at 2025-02-28

こんにちは。

テックリードのTerukiです。

皆さんはLooker Studioを使っていますか？
Oh my teethでは会社のありとあらゆる場所で使われているのでそのうち紹介できたらなと思います。

今回はNotionデータベースにLooker Studioからアクセス方法を紹介。

Looker Studioとは

本題の前に。

Googleが出している無料のBIツールです。

BIツールといえばTableauやPower BI等高価なツールがありますが、Looker Studioなら無料である程度のことができます。

ダッシュボードを作るならまずは最初に使ってみても良いんじゃないかなと。

コミュニティコネクタ

Looker Studioはデータ接続に必要なコネクタを自作できます。

自作してしまえば理論的にはLooker Studioで連携できないデータはないのでこれを使ってNotionデータベースのデータを連携させるという算段です。

「Notion」でコミュニティコネクタを検索するといくつか引っかかるのですが、正直怪しい雰囲気があり機密データを受け渡すにはちょっと怖いところがあります。

開発者向けのドキュメントもしっかり整っていて非常に好印象です。

Notion API

NotionデータベースをAPIでアクセスするためにNotionのインテグレーションを作成します。

Workspace Ownerでないと出来ないので権限が足りない人はオーナーに依頼する必要ありです。

私は「Looker Studio Integraion」という名前で作ってみました。

やってみる

最低限Notionに接続できるくらいのところまでをゴールとしてやってみます。

GASのプロジェクトを作成しますが、このコミュニティコネクタを社内に公開する場合はこのGASのプロジェクトを社内の人が見れる必要があるので共有ドライブなどにプロジェクトを作成するのが良いかなと思います。

プロジェクトを作ったら実際に動くGASを書いていきます。

事細かく解説するのもアレなのでもったいぶらずに私が書いたものをそのまま貼ります。
利用は自己責任でお願いできれば。
一部の型が未対応なので必要な方は実装お願いします

main.gs

const connector = DataStudioApp.createCommunityConnector();
const types = connector.FieldType;
const token = PropertiesService.getScriptProperties().getProperty("NOTION_INTEGRATION_TOKEN");

function getAuthType() {
  return connector.newAuthTypeResponse().setAuthType(connector.AuthType.NONE).build();
}

function getConfig(request) {
  const config = connector.getConfig();

  config
    .newTextInput()
    .setId('database_id')
    .setName('データベースIDを入力');

  return config.build();
}

function getRecords(databaseId) {
    const url = `https://api.notion.com/v1/databases/${databaseId}/query`;

    let records = [];

    let result = null;
    let payload = '{}';
    do {
      result = JSON.parse(UrlFetchApp.fetch(url, {
        'headers': {
          'Authorization': `Bearer ${token}`,
          'Notion-Version': '2022-06-28',
          'Content-Type': 'application/json',
        },
        'method': 'post',
        'payload': payload,
      }).getContentText());
      payload = JSON.stringify({
        start_cursor: result.next_cursor
      });

      records = records.concat(result.results);
    } while (result.has_more);

    return records;
}

function getNotionSchema(databaseId) {
    const url = `https://api.notion.com/v1/databases/${databaseId}`;
    
    const result = UrlFetchApp.fetch(url, {
      'headers': {
        'Authorization': `Bearer ${token}`,
        'Notion-Version': '2022-06-28'
      }
    });

    const json = JSON.parse(result.getContentText());

    const schema = [];

    for (const key in json.properties) {
      const value = json.properties[key];

      schema[value.id.replace(/\%/g, "Z").replace(/\~/g, "Y")] = value;
    }

    return schema;
}

function getUser(userId) {
    const url = `https://api.notion.com/v1/users/${userId}`;

    const result = UrlFetchApp.fetch(url, {
      'headers': {
        'Authorization': `Bearer ${token}`,
        'Notion-Version': '2022-06-28'
      }
    });

    return JSON.parse(result.getContentText()).people[0];
}


function getSchema(request) {
  return {
    schema: getFields(request).build(),
  };
}

function getFields(request) {
  const fields = connector.getFields();
  const types = connector.FieldType;

  const typeMap = {
    'number': types.NUMBER,
    'checkbox': types.BOOLEAN,
    'status': types.TEXT,
    'rich_text': types.TEXT,
    'url': types.URL,
    'formula': types.NUMBER,
    'title': types.TEXT,
    'multi_select': types.TEXT,
    'select': types.TEXT,
    'date': types.YEAR_MONTH_DAY,
    'people': types.TEXT,
    'files': types.TEXT,
  };

  const databaseId = request.configParams['database_id'];
  const schema = getNotionSchema(databaseId);

  if (request.fields) {
    // フィールドが指定されている時
    for (const field of request.fields) {
      const column = schema[field.name];

      fields.newDimension()
        .setId(field.name)
        .setName(column.name)
        .setType(typeMap[column.type]);
    }
  } else {
    // フィールドを指定されていない時
    for (const key in schema) {
      fields.newDimension()
        .setId(key)
        .setName(schema[key].name)
        .setType(typeMap[schema[key].type]);
    }
  }

  return fields;
}

function getPropertyValue(record) {

  switch (record.type) {
    case 'number':
      return record.number;
    case 'checkbox':
      return record.checkbox;
    case 'status':
      return record.status.name;
    case 'rich_text':
      let value = '';
      for (const text of record.rich_text) {
        value += text.plain_text;
      }
      return value;
    case 'url':
      return record.url;
    case 'formula':
      return record.formula.number;
    case 'title':
      let title = '';
      for (const text of record.title) {
        title += text.plain_text;
      }
      return title;
    case 'select':
      return record.select?.name;
    case 'select':
      return record.select?.name;
    case 'people':
      if (record.people.length === 0) return '';
      return record.people[0].name;
    case 'date':
      throw new Error()
  }

  return '何かがおかしいようです';
}

function getData(request) {
  const databaseId = request.configParams['database_id'];

  const records = getRecords(databaseId);

  const fields = request.fields.map((m) => m.name);

  const rows = [];

  for (const record of records) {
    const row = [];
    const properties = [];
    for (const key in record.properties) {
      const value = record.properties[key];

      properties[value.id.replace(/\%/g, "Z").replace(/\~/g, "Y")] = value;
    }

    for (const field of fields) {
      row.push(getPropertyValue(properties[field]));
    }

    rows.push({
      'values': row
    })
  }

  return {
    schema: getFields(request).build(),
    rows: rows,
  };
}

function isAdminUser() {
  return true;
}