Google Search Console からデータを取り込む
ベータ版
この機能はベータ版です。ワークスペース管理者は、 プレビュー ページからこの機能へのアクセスを制御できます。Databricksのプレビューを管理するを参照してください。
このページでは、Lakeflow Connect を使用して管理された Google Search Console インジェストパイプラインを作成する方法について説明します。
要件
-
取り込みパイプラインを作成するには、まず次の要件を満たす必要があります。
-
ワークスペースでUnity Catalogが有効になっている必要があります。
-
ワークスペースで Serverless コンピュートを有効にする必要があります。See Serverless コンピュートの要件.
-
新しい接続を作成するには、メタストアに対する
CREATE CONNECTION権限が必要です。Unity Catalog での権限の管理を参照してください。コネクタが UI ベースのパイプライン オーサリングをサポートしている場合、管理者はこのページのステップを完了することで、接続とパイプラインを同時に作成できます。 ただし、パイプラインを作成するユーザーが API ベースのパイプライン オーサリングを使用している場合、または管理者以外のユーザーである場合、管理者はまずカタログ エクスプローラーで接続を作成する必要があります。 「管理対象取り込みソースへの接続」を参照してください。
-
既存の接続を使用するには、接続オブジェクトに対する
USE CONNECTION権限またはALL PRIVILEGES権限が必要です。 -
ターゲットカタログに対する
USE CATALOG権限が必要です。 -
既存のスキーマに対する
USE SCHEMA権限とCREATE TABLE権限、またはターゲットカタログに対するCREATE SCHEMA権限が必要です。
-
-
Google Search Console から取り込むには、まず Databricks からの認証を構成し、接続を作成します。Google Search Console への認証の構成およびGoogle Search Console 接続の作成を参照してください。
コネクターのオプション
パイプラインスコープのオプションを source_configurations に設定し、テーブルスコープのオプションを個々のオブジェクトに設定します。使用方法については、「Examples」を参照してください。
オプション | スコープ | 必須 | 適用対象 | 説明 |
|---|---|---|---|---|
| パイプライン | はい | すべてのテーブル | 取り込む対象の、確認済み Google サーチコンソール プロパティURL(例: |
| パイプライン | No | すべての増分テーブル ( | データを取り込む最も早い日付( |
| テーブル | No | 日次検索パフォーマンステーブルのみ ( | 日次検索パフォーマンス テーブルのデータの鮮度。 |
取り込みパイプラインを作成
サポートされているソーステーブルの一覧については、サポートされているソーステーブルをご覧ください。
- Declarative Automation Bundles
- Databricks notebook
宣言型オートメーションバンドルを使用して、Google Search Console パイプラインをコードとして管理します。バンドルにはジョブとタスクの YAML 定義を含めることができ、Databricks CLI を使用して管理され、異なるターゲット ワークスペース(開発、ステージング、本番運用など)で共有および実行できます。詳細については、「宣言型オートメーションバンドルとは?」をご覧ください。
-
Databricks CLIを使用してバンドルを作成するには:
Bashdatabricks bundle init -
バンドルに2つの新しいリソースファイルを追加します:
- パイプライン定義ファイル (例:
resources/google_search_console_pipeline.yml)。See パイプライン.ingestion_definition および 「 例 」。 - データ取り込みの頻度を制御するジョブ定義ファイル(例:
resources/google_search_console_job.yml)。
- パイプライン定義ファイル (例:
-
Databricks CLIを使用してパイプラインをデプロイします:
Bashdatabricks bundle deploy
- 次のノートブックをDatabricksワークスペースにインポートします:
-
セル1とセル2はそのままにしておきます。変更しないでください。
-
セル3を、パイプラインの構成詳細に合わせて変更します。「パイプライン.ingestion_definition」を参照してください。および 例。
-
必要に応じて、高度なパイプライン設定を構成します。管理された取り込みパイプラインの一般的なパターンを参照してください。
-
「 すべて実行 」をクリックします。
例
Google Search Console コネクタは、default ソーススキーマの下で以下のソーステーブルを利用可能にします:
テーブルタイプ | テーブル |
|---|---|
サイトテーブル |
|
日次検索パフォーマンスレポートテーブル |
|
毎時の検索パフォーマンスレポートテーブル |
|
スキーマの詳細については、サポートされているソーステーブルを参照してください。
検索パフォーマンス レポート テーブルを取り込む
以下の例ではsearch_analytics_all_fieldsを取り込みます。これは、5つのすべてのディメンション(日付、国、デバイス、ページ、クエリー)で集計された日次パフォーマンスデータを返します。
- Declarative Automation Bundles
- Databricks notebook
resources:
pipelines:
google_search_console_pipeline:
name: google_search_console_pipeline
catalog: 'main'
target: 'google_search_console_data'
ingestion_definition:
connection_name: google_search_console_connection
source_configurations:
- api_source_connector_config:
configs:
site_urls: '["<site-url>"]'
start_date: '<start-date>'
objects:
- table:
source_schema: 'default'
source_table: 'search_analytics_all_fields'
destination_catalog: 'main'
destination_schema: 'google_search_console_data'
destination_table: 'search_analytics_all_fields'
connector_options:
api_source_connector_options:
options:
data_state: 'all'
pipeline_spec = {
"name": "<pipeline-name>",
"catalog": "<catalog-name-for-event-logs>",
"schema": "<schema-name-for-event-logs>",
"ingestion_definition": {
"connection_name": "<connection-name>",
"source_configurations": [
{
"api_source_connector_config": {
"configs": {
"site_urls": "[\"<site-url>\"]",
"start_date": "<start-date>"
}
}
}
],
"objects": [
{
"table": {
"source_schema": "default",
"source_table": "search_analytics_all_fields",
"destination_catalog": "<destination-catalog>",
"destination_schema": "<destination-schema>",
"destination_table": "search_analytics_all_fields",
"connector_options": {
"api_source_connector_options": {
"options": {
"data_state": "all"
}
}
}
}
}
]
}
}
json_payload = json.dumps(pipeline_spec, indent=2)
create_pipeline(json_payload)
サイトテーブルを取り込む
次の例では sites を取り込みます。これは、検証済みの Google Search Console プロパティに関するメタデータを返します。サイトテーブルはパイプラインが実行されるたびに完全に更新されるため、start_date はそれらに影響を与えず、data_state も受け付けません。
- Declarative Automation Bundles
- Databricks notebook
resources:
pipelines:
google_search_console_pipeline:
name: google_search_console_pipeline
catalog: 'main'
target: 'google_search_console_data'
ingestion_definition:
connection_name: google_search_console_connection
source_configurations:
- api_source_connector_config:
configs:
site_urls: '["<site-url>"]'
objects:
- table:
source_schema: 'default'
source_table: 'sites'
destination_catalog: 'main'
destination_schema: 'google_search_console_data'
destination_table: 'sites'
pipeline_spec = {
"name": "<pipeline-name>",
"catalog": "<catalog-name-for-event-logs>",
"schema": "<schema-name-for-event-logs>",
"ingestion_definition": {
"connection_name": "<connection-name>",
"source_configurations": [
{
"api_source_connector_config": {
"configs": {
"site_urls": "[\"<site-url>\"]"
}
}
}
],
"objects": [
{
"table": {
"source_schema": "default",
"source_table": "sites",
"destination_catalog": "<destination-catalog>",
"destination_schema": "<destination-schema>",
"destination_table": "sites"
}
}
]
}
}
json_payload = json.dumps(pipeline_spec, indent=2)
create_pipeline(json_payload)
サイトおよび検索パフォーマンスのテーブルをまとめて取り込む
次の例では、サイトテーブルと検索パフォーマンスレポートテーブルを 1 つのパイプラインに結合します。
- Declarative Automation Bundles
- Databricks notebook
resources:
pipelines:
google_search_console_pipeline:
name: google_search_console_pipeline
catalog: 'main'
target: 'google_search_console_data'
ingestion_definition:
connection_name: google_search_console_connection
source_configurations:
- api_source_connector_config:
configs:
site_urls: '["<site-url>"]'
start_date: '<start-date>'
objects:
# sites does not accept data_state, so it has no connector_options block.
- table:
source_schema: 'default'
source_table: 'sites'
destination_catalog: 'main'
destination_schema: 'google_search_console_data'
destination_table: 'sites'
- table:
source_schema: 'default'
source_table: 'search_analytics_by_page'
destination_catalog: 'main'
destination_schema: 'google_search_console_data'
destination_table: 'search_analytics_by_page'
connector_options:
api_source_connector_options:
options:
data_state: 'final'
pipeline_spec = {
"name": "<pipeline-name>",
"catalog": "<catalog-name-for-event-logs>",
"schema": "<schema-name-for-event-logs>",
"ingestion_definition": {
"connection_name": "<connection-name>",
"source_configurations": [
{
"api_source_connector_config": {
"configs": {
"site_urls": "[\"<site-url>\"]",
"start_date": "<start-date>"
}
}
}
],
"objects": [
{
"table": {
"source_schema": "default",
"source_table": "sites",
"destination_catalog": "<destination-catalog>",
"destination_schema": "<destination-schema>",
"destination_table": "sites"
}
},
{
"table": {
"source_schema": "default",
"source_table": "search_analytics_by_page",
"destination_catalog": "<destination-catalog>",
"destination_schema": "<destination-schema>",
"destination_table": "search_analytics_by_page",
"connector_options": {
"api_source_connector_options": {
"options": {
"data_state": "final"
}
}
}
}
}
]
}
}
json_payload = json.dumps(pipeline_spec, indent=2)
create_pipeline(json_payload)
宣言型オートメーションバンドルのジョブ定義ファイル
以下は、宣言型オートメーションバンドルで使用するジョブ定義ファイルの例です。ジョブは毎日実行されます。
- Declarative Automation Bundles
resources:
jobs:
google_search_console_job:
name: google_search_console_job
schedule:
quartz_cron_expression: '0 0 0 * * ?'
timezone_id: 'UTC'
tasks:
- task_key: google_search_console_ingestion
pipeline_task:
pipeline_id: ${resources.pipelines.google_search_console_pipeline.id}
一般的なパターン
高度なパイプライン構成については、「マネージド取り込みパイプラインの一般的なパターン」を参照してください。
次のステップ
パイプラインの起動、スケジュール、アラートの設定を行います。一般的なパイプラインのメンテナンス タスクを参照してください。