環境の設定と接続

概要: 次の手順に従って、Databricks を Klaviyo 用に準備します。（カタログ内の）必須の スキーマ を作成し、Klaviyo 専用のアカウントとアクセス トークンを設定し、必要最小限の権限を割り当て、構成を確認してから、Databricks を Klaviyo に接続します。

重要：Databricks の接続では現在、Klaviyo へのデータのインポートのみがサポートされています。

• プロファイルとイベントは今すぐインポートできます。
• Databricks へのエクスポートはまだ利用できません。それまでは、S3 へのエクスポートをおすすめします。
• Unity Catalog が必要です。Hive metastore (HMS) を使用する Databricks インスタンスに接続するには、Hive metastore federation をご検討ください。

Klaviyo でのデータウェアハウスのインポートの仕組み（スキーマ構造、必要なテーブル、フィールド マッピングを含む）の詳細については、Klaviyo でのデータウェアハウスのインポートの仕組み および データウェアハウスのイベント インポートについて理解する。 を参照してください。

1) 必要なスキーマを作成

Databricks では、スキーマ（データベースと呼ばれることもあります）はカタログ内に存在します。ワークスペースで Unity Catalog を使用している場合は、デフォルトの main カタログ、または別のカタログを使用できます。

USE CATALOG main;  -- or your organization’s designated catalog
CREATE SCHEMA IF NOT EXISTS KLAVIYO_IMPORT_FROM_DWH;
CREATE SCHEMA IF NOT EXISTS KLAVIYO_TMP;

• KLAVIYO_IMPORT_FROM_DWH注：このスキーマで作成されたテーブルとビューは、新しい同期を設定する際に選択できるようになります。
• KLAVIYO_TMP: 同期中に使用される一時的なデータ/ステージング データ。

注: ワークスペースで Unity Catalog を使用していない場合、Databricks では「schema」と「database」が同等として扱われます。CREATE SCHEMA の代わりに CREATE DATABASE を使用できます。

2) Klaviyoサービスアカウントとアクセストークンを作成する

Klaviyo は、パーソナル アクセス トークン（PAT）を持つ専用アカウントを使用して Databricks に対して認証します。可能な場合は非人間（サービス）アカウントを使用し、PAT は安全に保管してください（例: パスワードマネージャーまたはシークレットストア）。初期設定時にこのトークンを Klaviyo に提供します。

2.1 アカウントを作成

この外部連携で Klaviyo のみが使用する Databricks ワークスペースユーザーまたはサービスプリンシパルを作成します。

2.2 個人用アクセストークンを生成する

• ワークスペース ユーザー アカウント: Databricks ウェブ UI でトークンを生成します（Databricks のドキュメントを参照）。ワークスペース ユーザーの個人用アクセス トークンを作成する
• サービス プリンシパル： Databricks CLI を使用してトークンを生成します（Databricks のドキュメントを参照）： Databricks CLI を使用して個人用アクセストークンを作成する

重要：PAT は機密情報として取り扱ってください。トークンを持っている人は誰でも、関連付けられたアカウントの権限で Databricks にアクセスできます。

3) 必要な権限を割り当てる

Klaviyo アカウントに、ステップ 1 で作成したスキーマに対する以下の権限を付与します。klaviyo_service_user は実際のユーザー名またはサービス プリンシパル名に置き換え、スキーマには正しいカタログをプレフィックスとして付けてください（例：main）。

-- Grant permissions on temporary schema
GRANT ALL PRIVILEGES ON SCHEMA main.KLAVIYO_TMP TO `klaviyo_service_user`;

-- OR, grant granular privileges:
GRANT USE SCHEMA, MODIFY, SELECT, CREATE TABLE ON SCHEMA main.KLAVIYO_TMP TO `klaviyo_service_user`;

-- Grant read-only access to import schema
GRANT USE SCHEMA, SELECT ON SCHEMA main.KLAVIYO_IMPORT_FROM_DWH TO `klaviyo_service_user`;

ベストプラクティス: 最小権限の原則を適用し、必要な権限のみを付与してください。

4）設定を確認（任意）

4.1 スキーマが存在することを確認する

Databricks SQL ノートブックまたはエディターで実行します:

SHOW SCHEMAS IN main;  -- replace 'main' with your catalog if different

次のように表示されます：

klaviyo_import_from_dwh
klaviyo_tmp

4.2 認証をテスト（PAT を使用）

Klaviyo に提供する予定の同じトークンで Databricks CLI を使用します：

# Set your token and host (example for AWS)
export DATABRICKS_HOST="https://<your-workspace>.cloud.databricks.com"
export DATABRICKS_TOKEN="<your-PAT>"

# Run a simple API call
databricks current-user me

想定される結果: ユーザーまたはサービス プリンシパルの詳細（例：表示名、ユーザー ID）を示す JSON 出力。HTTP 403 または認証エラーが発生した場合は、トークンとホスト URL を確認してください。

4.3 各スキーマの権限を確認する

SHOW GRANTS ON SCHEMA main.klaviyo_tmp;
SHOW GRANTS ON SCHEMA main.klaviyo_import_from_dwh;

Klaviyo アカウントが想定どおりの権限（例: USE SCHEMA、SELECT、MODIFY、CREATE TABLE）で表示されていることを確認してください。

4.4 作成/読み取り操作を検証する

-- Test create/drop in KLAVIYO_TMP
USE SCHEMA main.klaviyo_tmp;
CREATE TABLE IF NOT EXISTS test_permissions (id INT);
DROP TABLE test_permissions;

-- Test select in KLAVIYO_IMPORT_FROM_DWH
USE SCHEMA main.klaviyo_import_from_dwh;
SHOW TABLES;

ヒント:

• Klaviyo と共有するのと同じ ID と PAT を使用して、これらの検証手順を実行します。
• 監査/トラブルシューティングのために、SQL の GRANT ステートメントと検証出力を保持してください。
• PAT は定期的に、またスタッフ変更後にローテーションしてください。

5) Klaviyo を Databricks に接続する

Databricks の設定が完了したら、Klaviyo で接続を完了してください。

1. Klaviyo で 左サイドバーを開き、詳細設定 > 同期 に移動します。
2. [同期を作成] をクリックします。
3. [データウェアハウスからデータをインポート] を選択します。
4. データウェアハウスとして Databricks を選択します。
5. [Databricks に接続] をクリックします。

プロンプトが表示されたら、次の接続の詳細を入力してください：

接続後：Klaviyo は接続をテストし、Databricks 環境へのアクセスを確認します。検証が完了したら、同期を設定して、先ほど準備したスキーマからデータをインポートできます。

次の手順： 正常に接続したら、Klaviyo で最初の同期を作成し、Databricks からデータのインポートを開始します。