Ultimate

使用Flow Service API将Snowflake连接到Experience Platform

最近更新： 2025年6月12日

主题：

创建对象：

开发人员

重要

Snowflake源在源目录中可供已购买Real-Time Customer Data Platform Ultimate的用户使用。

阅读本指南，了解如何使用Flow Service API将您的Snowflake源帐户连接到Adobe Experience Platform。

快速入门

本指南要求您对 Adobe Experience Platform 的以下组件有一定了解：

源： Experience Platform允许从各种源摄取数据，同时允许您使用Experience Platform服务来构建、标记和增强传入数据。
沙盒： Experience Platform提供将单个Experience Platform实例划分为单独虚拟环境的虚拟沙盒，以帮助开发和改进数字体验应用程序。

使用Experience Platform API

有关如何成功调用Experience Platform API的信息，请参阅Experience Platform API快速入门指南。

以下部分提供了使用Flow Service API成功连接到Snowflake时需要了解的其他信息。

将Snowflake连接到Azure上的Experience Platform

有关如何将Snowflake源连接到Azure上的Experience Platform的信息，请阅读以下步骤。

收集所需的凭据

警告

Snowflake源的基本身份验证（或帐户密钥身份验证）将于2025年11月被弃用。您必须迁移到基于密钥对的身份验证，才能继续使用源并从数据库中摄取数据到Experience Platform。有关弃用的详细信息，请阅读关于降低凭据泄露风险的Snowflake 最佳实践指南。

必须提供以下凭据属性的值才能对您的Snowflake源进行身份验证。

帐户密钥身份验证

凭据

描述

account

帐户名称可唯一标识组织内的帐户。在这种情况下，您必须跨不同的Snowflake组织唯一标识帐户。要实现此目的，您必须在帐户名称前添加组织名称。例如： orgname-account_name。请阅读有关检索 Snowflake 帐户标识符的指南，以获取其他指导。有关更多信息，请参阅Snowflake 文档。

warehouse

Snowflake仓库管理应用程序的查询执行过程。每个Snowflake仓库彼此独立，在将数据传送到Experience Platform时必须单独访问。

database

Snowflake数据库包含要带Experience Platform的数据。

username

Snowflake帐户的用户名。

password

Snowflake用户帐户的密码。

role

在Snowflake会话中使用的默认访问控制角色。该角色应为已分配给指定用户的现有角色。默认角色为PUBLIC。

connectionString

用于连接到Snowflake实例的连接字符串。 Snowflake的连接字符串模式为

jdbc:snowflake://{ACCOUNT_NAME}.snowflakecomputing.com/?user={USERNAME}&password={PASSWORD}&db={DATABASE}&warehouse={WAREHOUSE}

密钥对身份验证

要使用密钥对身份验证，您必须生成一个2048位RSA密钥对，然后在为Snowflake源创建帐户时提供以下值。

凭据

描述

account

帐户名称可唯一标识组织内的帐户。在这种情况下，您必须跨不同的Snowflake组织唯一标识帐户。要实现此目的，您必须在帐户名称前添加组织名称。例如： orgname-account_name。请阅读有关检索 Snowflake 帐户标识符的指南，以获取其他指导。有关更多信息，请参阅Snowflake 文档。

username

Snowflake帐户的用户名。

privateKey

Snowflake帐户的Base64-编码私钥。您可以生成加密或未加密的私钥。如果您使用的是加密的私钥，那么在针对Experience Platform进行身份验证时，还必须提供私钥密码。有关详细信息，请阅读检索 Snowflake 私钥的指南。

privateKeyPassphrase

私钥密码是附加的安全层，在使用加密的私钥进行身份验证时必须使用该安全层。如果您使用未加密的私钥，则无需提供密码。

database

包含要摄取到Experience Platform的数据的Snowflake数据库。

warehouse

Snowflake仓库管理应用程序的查询执行过程。每个Snowflake仓库彼此独立，在将数据传送到Experience Platform时必须单独访问。

有关这些值的详细信息，请参阅Snowflake 密钥对身份验证指南。

NOTE

必须将PREVENT_UNLOAD_TO_INLINE_URL标志设置为FALSE，以允许将数据从Snowflake数据库卸载到Experience Platform。

在Azure上的Experience Platform上为Snowflake创建基础连接

基本连接会保留源与Experience Platform之间的信息，包括源的身份验证凭据、连接的当前状态以及唯一的基本连接ID。基本连接ID允许您浏览和浏览源中的文件，并标识要摄取的特定项目，包括有关其数据类型和格式的信息。

要创建基本连接ID，请在提供您的Snowflake身份验证凭据作为请求正文的一部分时，向/connections端点发出POST请求。

API格式

POST /connections

连接字符串

请求

以下请求为Snowflake创建基本连接：

curl -X POST \
  'https://platform.adobe.io/data/foundation/flowservice/connections' \
  -H 'Authorization: Bearer {ACCESS_TOKEN}' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {ORG_ID}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -H 'Content-Type: application/json' \
  -d '{
      "name": "Snowflake base connection",
      "description": "Snowflake base connection",
      "auth": {
          "specName": "ConnectionString",
          "params": {
              "connectionString": "jdbc:snowflake://{ACCOUNT_NAME}.snowflakecomputing.com/?user={USERNAME}&password={PASSWORD}&db={DATABASE}&warehouse={WAREHOUSE}"
          }
      },
      "connectionSpec": {
          "id": "b2e08744-4f1a-40ce-af30-7abac3e23cf3",
          "version": "1.0"
      }
  }'

属性

描述

auth.params.connectionString

用于连接到Snowflake实例的连接字符串。 Snowflake的连接字符串模式为

jdbc:snowflake://{ACCOUNT_NAME}.snowflakecomputing.com/?user={USERNAME}&password={PASSWORD}&db={DATABASE}&warehouse={WAREHOUSE}

。

connectionSpec.id

Snowflake连接规范ID： b2e08744-4f1a-40ce-af30-7abac3e23cf3。

响应

成功的响应返回新创建的连接，包括其唯一连接标识符(id)。在下个教程中，需要此ID才能浏览您的数据。

{
    "id": "2fce94c1-9a93-4971-8e94-c19a93097129",
    "etag": "\"d403848a-0000-0200-0000-5e978f7b0000\""
}

使用加密私钥的密钥对身份验证

请求

curl -X POST \
  'https://platform.adobe.io/data/foundation/flowservice/connections' \
  -H 'Authorization: Bearer {ACCESS_TOKEN}' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {ORG_ID}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -H 'Content-Type: application/json' \
  -d '{
      "name": "Snowflake base connection with encrypted private key",
      "description": "Snowflake base connection with encrypted private key",
      "auth": {
        "specName": "KeyPair Authentication",
        "params": {
            "account": "acme-snowflake123",
            "username": "acme-cj123",
            "database": "ACME_DB",
            "privateKey": "{BASE_64_ENCODED_PRIVATE_KEY}",
            "privateKeyPassphrase": "abcd1234",
            "warehouse": "COMPUTE_WH"
        }
    },
    "connectionSpec": {
        "id": "b2e08744-4f1a-40ce-af30-7abac3e23cf3",
        "version": "1.0"
    }
  }'

属性

描述

auth.params.account

Snowflake帐户的名称。

auth.params.username

与您的Snowflake帐户关联的用户名。

auth.params.database

将从其中提取数据的Snowflake数据库。

auth.params.privateKey

Snowflake帐户的Base64-编码加密私钥。

auth.params.privateKeyPassphrase

与您的私钥对应的密码。

auth.params.warehouse

您正在使用的Snowflake仓库。

connectionSpec.id

Snowflake连接规范ID： b2e08744-4f1a-40ce-af30-7abac3e23cf3。

响应

成功的响应返回新创建的连接，包括其唯一连接标识符(id)。在下个教程中，需要此ID才能浏览您的数据。

{
    "id": "2fce94c1-9a93-4971-8e94-c19a93097129",
    "etag": "\"d403848a-0000-0200-0000-5e978f7b0000\""
}

使用未加密私钥的密钥对身份验证

请求

curl -X POST \
  'https://platform.adobe.io/data/foundation/flowservice/connections' \
  -H 'Authorization: Bearer {ACCESS_TOKEN}' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {ORG_ID}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -H 'Content-Type: application/json' \
  -d '{
      "name": "Snowflake base connection with encrypted private key",
      "description": "Snowflake base connection with encrypted private key",
      "auth": {
        "specName": "KeyPair Authentication",
        "params": {
            "account": "acme-snowflake123",
            "username": "acme-cj123",
            "database": "ACME_DB",
            "privateKey": "{BASE_64_ENCODED_PRIVATE_KEY}",
            "warehouse": "COMPUTE_WH"
        }
    },
    "connectionSpec": {
        "id": "b2e08744-4f1a-40ce-af30-7abac3e23cf3",
        "version": "1.0"
    }
  }'

属性

描述

auth.params.account

Snowflake帐户的名称。

auth.params.username

与您的Snowflake帐户关联的用户名。

auth.params.database

将从其中提取数据的Snowflake数据库。

auth.params.privateKey

Snowflake帐户的Base64-编码未加密私钥。

auth.params.warehouse

您正在使用的Snowflake仓库。

connectionSpec.id

Snowflake连接规范ID： b2e08744-4f1a-40ce-af30-7abac3e23cf3。

响应

成功的响应返回新创建的连接，包括其唯一连接标识符(id)。在下个教程中，需要此ID才能浏览您的数据。

{
    "id": "2fce94c1-9a93-4971-8e94-c19a93097129",
    "etag": "\"d403848a-0000-0200-0000-5e978f7b0000\""
}

将Snowflake连接到Amazon Web Services (AWS)上的Experience Platform

AVAILABILITY

本节适用于在Amazon Web Services (AWS)上运行的Experience Platform的实施。在AWS上运行的Experience Platform当前仅对有限数量的客户可用。要了解有关支持的Experience Platform基础架构的更多信息，请参阅Experience Platform multi-cloud概述。

有关如何将Snowflake源连接到AWS上的Experience Platform的信息，请阅读以下步骤。

在AWS的Experience Platform上为Snowflake创建基本连接

API格式

POST /connections

请求

以下请求为Snowflake创建一个基础连接，以便在AWS上将日期摄取到Experience Platform：

选择以查看示例

curl -X POST \
  'https://platform.adobe.io/data/foundation/flowservice/connections' \
  -H 'Authorization: Bearer {ACCESS_TOKEN}' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {ORG_ID}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -H 'Content-Type: application/json' \
  -d '{
      "name": "Snowflake base connection for Experience Platform on AWS",
      "description": "Snowflake base connection for Experience Platform on AWS",
      "auth": {
          "specName": "Basic Authentication",
          "params": {
              "host": "acme.snowflakecomputing.com",
              "port": "443",
              "username": "acme-cj123",
              "password": "{PASSWORD}",
              "database": "ACME_DB",
              "warehouse": "COMPUTE_WH",
              "schema": "{SCHEMA}"
          }
      },
      "connectionSpec": {
          "id": "b2e08744-4f1a-40ce-af30-7abac3e23cf3",
          "version": "1.0"
      }
  }'

属性

描述

auth.params.host

您的Snowflake帐户连接到的主机URL。

auth.params.port

Snowflake通过Internet连接到服务器时使用的端口号。

auth.params.username

与您的Snowflake帐户关联的用户名。

auth.params.database

将从其中提取数据的Snowflake数据库。

auth.params.password

与您的Snowflake帐户关联的密码。

auth.params.warehouse

您正在使用的Snowflake仓库。

auth.params.schema

与您的Snowflake数据库关联的架构的名称。您必须确保要为其授予数据库访问权限的用户也具有此架构的访问权限。

响应

成功的响应返回新创建的连接的详细信息，包括其唯一标识符(id)。在下一个教程中，需要此ID来浏览您的存储。

选择以查看示例

{
    "id": "4cb0c374-d3bb-4557-b139-5712880adc55",
    "etag": "\"1700d77b-0000-0200-0000-5e3b41a10000\""
}

通过完成本教程，您已使用Flow Service API创建了Snowflake基本连接。您可以在下列教程中使用此基本连接ID：

recommendation-more-help