高级 KDP 不包含在 Klaviyo 的标准营销应用程序中，需要订阅才能访问相关功能。请参阅我们的计费指南，了解如何购买此计划。 # 环境设置和连接

概述： 按照以下步骤为 Klaviyo 准备 Databricks。您将创建所需的架构（在目录中），为 Klaviyo 设置专用帐户和访问令牌，分配所需的最低权限，验证配置并将 Databricks 连接到 Klaviyo。 重要提示： Databricks 连接当前仅支持将数据导入到 Klaviyo。 – 配置文件和事件现在可以导入。 – 导出到 Databricks 尚不可用。在此之前，建议导出到 S3。 – Unity 目录 是必需的。要连接到使用 Hive 元存储 (HMS) 的 Databricks 实例，请考虑 Hive 元存储联合。有关数据仓库导入如何在 Klaviyo 中工作的详细信息（包括架构结构、所需的表和字段映射），请参阅数据仓库导入如何在 Klaviyo 中工作 和 了解数据仓库事件导入。

—

1) 创建所需的模式

在 Databricks 中，模式（有时称为数据库）位于目录内。如果您的工作区使用 Unity Catalog，则可以使用默认的“main”目录或其他目录。 ““ 使用目录主； — 或您组织的指定目录 如果不存在则创建架构 KLAVIYO_IMPORT_FROM_DWH； 如果不存在则创建架构 KLAVIYO_TMP；

- `KLAVIYO_IMPORT_FROM_DWH`：配置新同步时，在此架构中创建的表和视图将可供选择。 - `KLAVIYO_TMP`：同步期间使用的临时/暂存数据。 **注意：** 如果您的工作区不使用 Unity Catalog，Databricks 会将“架构”和“数据库”视为等效。您可以使用“CREATE DATABASE”而不是“CREATE SCHEMA”。 ---

## 2) 创建 Klaviyo 服务帐户和访问令牌

Klaviyo 使用带有**个人访问令牌 (PAT)** 的专用帐户对 Databricks 进行身份验证。尽可能使用非人类（服务）帐户并安全地存储 PAT（例如密码管理器或秘密存储）。您将在初始设置期间向 Klaviyo 提供此令牌。

### 2.1 创建账户

创建 Klaviyo 将专门用于此集成的 Databricks 工作区用户或服务主体。

### 2.2 生成个人访问令牌

- **工作区用户帐户：** 通过 Databricks Web UI 生成令牌（请参阅 Databricks 文档）：[为工作区用户创建个人访问令牌](https://docs.databricks.com/aws/en/dev-tools/auth/pat#create-personal-access-tokens-for-workspace-users)
- **服务主体：** 使用 Databricks CLI 生成令牌（请参阅 Databricks 文档）：[通过 Databricks CLI 创建个人访问令牌](https://docs.databricks.com/aws/en/dev-tools/auth/pat#create-personal-access-tokens-for-service-principals)

**重要：** 将 PAT 视为秘密。拥有令牌的任何人都可以使用关联帐户的权限访问 Databricks。 ---

## 3) 分配所需的权限

授予 Klaviyo 帐户对步骤 1 中创建的架构的以下权限。将 `klaviyo_service_user` 替换为您的实际用户名或服务主体名称，并使用正确的目录为架构添加前缀（例如，`main`）。 |架构|所需的最低权限 |目的|
| --- | --- | --- |
| `KLAVIYO_TMP` | `所有权限` **或** `USE SCHEMA`、`MODIFY`、`SELECT` 和 `CREATE TABLE` 的组合 |允许 Klaviyo 在同步期间创建和管理临时表。 |
| `KLAVIYO_IMPORT_FROM_DWH` | `使用模式`、`选择` |允许 Klaviyo 读取您的表和视图。 |

— 授予临时模式的权限 将 SCHEMA main.KLAVIYO_TMP 上的所有权限授予 klaviyo_service_user；

— 或者，授予细化权限： 将架构 main.KLAVIYO_TMP 上的使用架构、修改、选择、创建表授予 klaviyo_service_user；

— 授予导入模式的只读访问权限 授予使用架构，选择架构 main.KLAVIYO_IMPORT_FROM_DWH 到 klaviyo_service_user；

**最佳实践：** 应用最小权限原则——仅授予所需的权限。 ---

## 4) 验证您的设置（可选）

### 4.1 确认模式存在

在 Databricks SQL 笔记本或编辑器中运行：

在主文件中显示架构； — 如果不同，请将“main”替换为您的目录

你应该看到：

klaviyo_import_from_dwh 克拉维约_tmp

### 4.2 测试身份验证（使用您的 PAT）

使用 Databricks CLI 和您计划提供给 Klaviyo 的相同令牌：

设置您的令牌和主机（以 AWS 为例）

导出 DATABRICKS_HOST=”https://<your-workspace&gt;.cloud.databricks.com” 导出 DATABRICKS_TOKEN=”<您的 PAT>”

运行一个简单的 API 调用

databricks 当前用户我

**预期结果：** JSON 输出显示用户或服务主体详细信息（例如，显示名称、用户 ID）。如果收到 HTTP 403 或身份验证错误，请验证令牌和主机 URL。

### 4.3 检查每个模式的权限

在架构 main.klaviyo_tmp 上显示补助金； 在架构上显示补助金 main.klaviyo_import_from_dwh;

确认您的 Klaviyo 帐户显示具有预期的权限（例如“USE SCHEMA”、“SELECT”、“MODIFY”、“CREATE TABLE”）。

### 4.4 验证创建/读取操作

— 在 KLAVIYO_TMP 中测试创建/删除 使用架构 main.klaviyo_tmp； 如果不存在则创建表 test_permissions (id INT); 删除表 test_permissions；

— 在 KLAVIYO_IMPORT_FROM_DWH 中测试选择 使用架构 main.klaviyo_import_from_dwh; 显示表格；

**提示：**

- 使用您将与 Klaviyo 共享的相同身份和 PAT 运行这些验证步骤。 - 保留 SQL 授予语句和验证输出以供审核/故障排除。 - 在人员变动后定期轮换 PAT。 ---

## 5) 将 Klaviyo 连接到 Databricks

配置 Databricks 后，在 Klaviyo 中完成连接。
1. 在 Klaviyo 中，打开**左侧边栏**并导航至**高级 > 同步**。
2. 单击**创建同步**。
3. 选择**从数据仓库导入数据**。
4. 选择**Databricks** 作为您的数据仓库。
5. 单击**连接到Databricks**。出现提示时，请提供以下连接详细信息：

|领域 |描述 |哪里可以找到它 |
| --- | --- | --- |
| **主机名** | Databricks 工作区的 URL 中指示的主机。 |登录 Databricks 后可在浏览器地址栏中找到：`https://<your-workspace>.cloud.databricks.com` 示例：`abc-12345678.cloud.databricks.com` |
| **HTTP 路径** |用于查询的 SQL 仓库的 HTTP 路径。 |在 Databricks UI 中：
1. 转到**SQL 仓库**。
2. 选择您计划使用的仓库。
3. 复制**连接详细信息**下的**HTTP 路径**。示例：`/sql/1.0/warehouses/1234abcd5678efgh` |
| **目录** |包含您的 Klaviyo 模式的目录（例如“main”）。 |使用以下方法验证：显示目录； |
| **访问令牌** |您在步骤 2 中创建的个人访问令牌 (PAT)。在设置过程中安全地存储和粘贴令牌。 |

**连接后：** Klaviyo 将测试连接并确认对 Databricks 环境的访问。验证后，您可以配置同步以从您之前准备的架构导入数据。 ---

**下一步：** 连接成功后，继续在 Klaviyo 中创建您的第一个同步并开始从 Databricks 导入数据。