DokumentationExperience PlatformAnvändarhandbok om Source Connectors

[Ultimate]{class="badge positive"}

Skapa en Snowflake-basanslutning med API:t Flow Service

Last update: Mon Jul 29 2024 00:00:00 GMT+0000 (Coordinated Universal Time)
  • Ämnen:

Skapat för:

  • Utvecklare
IMPORTANT
Källan Snowflake är tillgänglig i källkatalogen för användare som har köpt Real-time Customer Data Platform Ultimate.

En basanslutning representerar den autentiserade anslutningen mellan en källa och Adobe Experience Platform.

Använd följande självstudiekurs för att lära dig hur du skapar en basanslutning för Snowflake med [Flow Service API] (https://www.adobe.io/experience-platform-apis/references/flow-service/).

Komma igång

Handboken kräver en fungerande förståelse av följande komponenter i Adobe Experience Platform:

  • Källor: Experience Platform tillåter att data kan hämtas från olika källor samtidigt som du kan strukturera, etikettera och förbättra inkommande data med Platform-tjänster.
  • Sandlådor: Experience Platform innehåller virtuella sandlådor som partitionerar en enskild Platform-instans till separata virtuella miljöer för att hjälpa till att utveckla och utveckla program för digitala upplevelser.

Använda plattforms-API:er

Mer information om hur du kan anropa plattforms-API:er finns i guiden Komma igång med plattforms-API:er.

Följande avsnitt innehåller ytterligare information som du behöver känna till för att kunna ansluta till Snowflake med API:t Flow Service.

Samla in nödvändiga inloggningsuppgifter

Du måste ange värden för följande autentiseringsegenskaper för att autentisera Snowflake-källan.

Autentisering av kontonyckel
table 0-row-2 1-row-2 2-row-2 3-row-2 4-row-2 5-row-2 6-row-2 7-row-2
Autentiseringsuppgifter Beskrivning
account Ett kontonamn identifierar unikt ett konto inom organisationen. I det här fallet måste du unikt identifiera ett konto i olika Snowflake-organisationer. Om du vill göra det måste du lägga till ditt organisationsnamn i kontonamnet. Till exempel: orgname-account_name. Läs guiden om att hämta din Snowflake kontoidentifierare om du vill ha mer information. Mer information finns i Snowflake dokumentationen.
warehouse Lagerstället Snowflake hanterar frågekörningsprocessen för programmet. Varje Snowflake-lagerställe är oberoende av varandra och måste nås individuellt när data överförs till plattformen.
database Databasen Snowflake innehåller de data som du vill ta med plattformen.
username Användarnamnet för kontot Snowflake.
password Lösenordet för användarkontot Snowflake.
role Standardrollen för åtkomstkontroll som ska användas i sessionen Snowflake. Rollen ska vara en befintlig roll som redan har tilldelats den angivna användaren. Standardrollen är PUBLIC.
connectionString Anslutningssträngen som används för att ansluta till din Snowflake-instans. Anslutningssträngsmönstret för Snowflake är jdbc:snowflake://{ACCOUNT_NAME}.snowflakecomputing.com/?user={USERNAME}&password={PASSWORD}&db={DATABASE}&warehouse={WAREHOUSE}
Autentisering med nyckelpar

Om du vill använda autentisering med nyckelpar måste du generera ett 2 048-bitars RSA-nyckelpar och sedan ange följande värden när du skapar ett konto för Snowflake-källan.

table 0-row-2 1-row-2 2-row-2 3-row-2 4-row-2 5-row-2 6-row-2
Autentiseringsuppgifter Beskrivning
account Ett kontonamn identifierar unikt ett konto inom organisationen. I det här fallet måste du unikt identifiera ett konto i olika Snowflake-organisationer. Om du vill göra det måste du lägga till ditt organisationsnamn i kontonamnet. Till exempel: orgname-account_name. Läs guiden om att hämta din Snowflake kontoidentifierare om du vill ha mer information. Mer information finns i Snowflake dokumentationen.
username Användarnamnet för ditt Snowflake-konto.
privateKey Den Base64-kodade privata nyckeln för ditt Snowflake-konto. Du kan generera antingen krypterade eller okrypterade privata nycklar. Om du använder en krypterad privat nyckel måste du även ange en lösenfras för den privata nyckeln vid autentisering mot Experience Platform. Läs guiden om att hämta din Snowflake privata nyckel om du vill ha mer information.
privateKeyPassphrase Lösenfrasen för den privata nyckeln är ett extra säkerhetslager som du måste använda när du autentiserar med en krypterad privat nyckel. Du behöver inte ange lösenfrasen om du använder en okrypterad privat nyckel.
database Databasen Snowflake som innehåller de data som du vill importera till Experience Platform.
warehouse Lagerstället Snowflake hanterar frågekörningsprocessen för programmet. Varje Snowflake-lagerställe är oberoende av varandra och måste nås individuellt när du överför data till Experience Platform.

Mer information om dessa värden finns i Snowflake autentiseringsguiden för nyckelpar.

NOTE
Du måste ange flaggan PREVENT_UNLOAD_TO_INLINE_URL till FALSE för att tillåta dataradering från din Snowflake-databas till Experience Platform.

Skapa en basanslutning

En basanslutning bevarar information mellan källan och plattformen, inklusive källans autentiseringsuppgifter, anslutningsstatus och ditt unika basanslutnings-ID. Med det grundläggande anslutnings-ID:t kan du utforska och navigera bland filer inifrån källan och identifiera de specifika objekt som du vill importera, inklusive information om deras datatyper och format.

Om du vill skapa ett grundläggande anslutnings-ID skickar du en POST till /connections-slutpunkten och anger dina Snowflake autentiseringsuppgifter som en del av begärandetexten.

API-format

POST /connections
ConnectionString
accordion
Begäran

Följande begäran skapar en basanslutning för Snowflake:

code language-shell 
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"
      }
  }'
table 0-row-2 1-row-2 2-row-2
Egenskap Beskrivning
auth.params.connectionString Anslutningssträngen som används för att ansluta till din Snowflake-instans. Anslutningssträngsmönstret för Snowflake är jdbc:snowflake://{ACCOUNT_NAME}.snowflakecomputing.com/?user={USERNAME}&password={PASSWORD}&db={DATABASE}&warehouse={WAREHOUSE}.
connectionSpec.id Anslutningsspecifikations-ID Snowflake: b2e08744-4f1a-40ce-af30-7abac3e23cf3.
accordion
svar

Ett svar returnerar den nyligen skapade anslutningen, inklusive dess unika anslutnings-ID (id). Detta ID krävs för att utforska dina data i nästa självstudiekurs.

code language-json 
{
    "id": "2fce94c1-9a93-4971-8e94-c19a93097129",
    "etag": "\"d403848a-0000-0200-0000-5e978f7b0000\""
}
Autentisering med nyckelpar med krypterad privat nyckel
accordion
Begäran
code language-shell 
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"
    }
  }'
table 0-row-2 1-row-2 2-row-2 3-row-2 4-row-2 5-row-2 6-row-2 7-row-2
Egenskap Beskrivning
auth.params.account Namnet på ditt Snowflake-konto.
auth.params.username Användarnamnet som är associerat med ditt Snowflake-konto.
auth.params.database Databasen Snowflake från vilken data hämtas.
auth.params.privateKey Den Base64-kodade krypterade privata nyckeln för ditt Snowflake-konto.
auth.params.privateKeyPassphrase Lösenfrasen som motsvarar din privata nyckel.
auth.params.warehouse Det Snowflake-lagerställe som du använder.
connectionSpec.id Anslutningsspecifikations-ID Snowflake: b2e08744-4f1a-40ce-af30-7abac3e23cf3.
accordion
svar

Ett svar returnerar den nyligen skapade anslutningen, inklusive dess unika anslutnings-ID (id). Detta ID krävs för att utforska dina data i nästa självstudiekurs.

code language-json 
{
    "id": "2fce94c1-9a93-4971-8e94-c19a93097129",
    "etag": "\"d403848a-0000-0200-0000-5e978f7b0000\""
}
Autentisering med nyckelpar med okrypterad privat nyckel
accordion
Begäran
code language-shell 
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"
    }
  }'
table 0-row-2 1-row-2 2-row-2 3-row-2 4-row-2 5-row-2 6-row-2
Egenskap Beskrivning
auth.params.account Namnet på ditt Snowflake-konto.
auth.params.username Användarnamnet som är associerat med ditt Snowflake-konto.
auth.params.database Databasen Snowflake från vilken data hämtas.
auth.params.privateKey Den Base64-kodade okrypterade privata nyckeln för ditt Snowflake-konto.
auth.params.warehouse Det Snowflake-lagerställe som du använder.
connectionSpec.id Anslutningsspecifikations-ID Snowflake: b2e08744-4f1a-40ce-af30-7abac3e23cf3.
accordion
svar

Ett svar returnerar den nyligen skapade anslutningen, inklusive dess unika anslutnings-ID (id). Detta ID krävs för att utforska dina data i nästa självstudiekurs.

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

Genom att följa den här självstudiekursen har du skapat en Snowflake-basanslutning med API:t Flow Service. Du kan använda detta grundläggande anslutnings-ID i följande självstudier:

recommendation-more-help
337b99bb-92fb-42ae-b6b7-c7042161d089