DokumentationExperience PlatformAnvändarhandbok om Source Connectors

[Ultimate]{class="badge positive"}

Snowflake direktuppspelningskälla

Last update: Wed Oct 01 2025 00:00:00 GMT+0000 (Coordinated Universal Time)
  • Ämnen:

Skapat för:

  • Utvecklare
IMPORTANT

  • Direktuppspelningskällan Snowflake är tillgänglig i API:t för användare som har köpt Real-Time CDP Ultimate.

  • Du kan nu använda strömningskällan Snowflake när du kör Adobe Experience Platform på Amazon Web Services (AWS). Experience Platform som körs på AWS är för närvarande tillgängligt för ett begränsat antal kunder. Mer information om den Experience Platform-infrastruktur som stöds finns i Experience Platform översikt över flera moln.

Med Adobe Experience Platform kan data hämtas från externa källor samtidigt som du kan strukturera, etikettera och förbättra inkommande data med hjälp av Experience Platform tjänster. Du kan importera data från en mängd olika källor, till exempel Adobe-program, molnbaserad lagring, databaser och många andra.

Experience Platform har stöd för strömning av data från en Snowflake-databas.

Förstå den strömmande källan Snowflake

Strömmande Snowflake-källa fungerar genom att data läses in genom att en SQL-fråga körs regelbundet och en utdatapost skapas för varje rad i den resulterande uppsättningen.

Genom att använda Kafka Connect spårar den Snowflake-direktuppspelningskällan den senaste posten som den tar emot från varje tabell, så att den kan börja på rätt plats för nästa iteration. Källan använder den här funktionen för att filtrera data och bara hämta uppdaterade rader från en tabell i varje iteration.

Förhandskrav

I följande avsnitt beskrivs de nödvändiga stegen som måste utföras innan du kan strömma data från din Snowflake-databas till Experience Platform:

IP-adress tillåtelselista

Du måste lägga till regionspecifika IP-adresser i tillåtelselista innan du kan ansluta dina källor till Experience Platform. Mer information finns i guiden om att tillåtslista IP-adresser för att ansluta till Experience Platform.

Dokumentationen nedan innehåller information om hur du ansluter Amazon Redshift till Experience Platform med API:er eller användargränssnittet:

Samla in nödvändiga inloggningsuppgifter

För att Flow Service ska kunna ansluta till Snowflake måste du ange följande anslutningsegenskaper:

Grundläggande autentisering
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

Fullständig kontoidentifierare (kontonamn eller kontopositionerare) för ditt Snowflake-konto har lagts till med suffixet snowflakecomputing.com. Kontots identifierare kan ha olika format:

  • {ORG_NAME}-{ACCOUNT_NAME}.snowflakecomputing.com (t.ex. acme-abc12345.snowflakecomputing.com)
  • {ACCOUNT_LOCATOR}.{CLOUD_REGION_ID}.snowflakecomputing.com (t.ex. acme12345.ap-southeast-1.snowflakecomputing.com)
  • {ACCOUNT_LOCATOR}.{CLOUD_REGION_ID}.{CLOUD}.snowflakecomputing.com (t.ex. acme12345.east-us-2.azure.snowflakecomputing.com)

Mer information finns i Snowflake document on account identifiers.
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 Experience Platform.
database Databasen Snowflake innehåller de data som du vill hämta Experience Platform.
username Användarnamnet för kontot Snowflake.
password Lösenordet för användarkontot Snowflake.
role (Valfritt) En anpassad definierad roll som kan anges för en användare för en viss anslutning. Om det inte anges används standardvärdet public.
connectionSpec.id Anslutningsspecifikationen returnerar en källas kopplingsegenskaper, inklusive autentiseringsspecifikationer för att skapa bas- och källanslutningarna. Anslutningsspecifikations-ID för Snowflake är 51ae16c2-bdad-42fd-9fce-8d5dfddaf140.
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.
passphrase Lösenfrasen ä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 data överförs till Experience Platform.

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

Hämta din kontoidentifierare retrieve-your-account-identifier

Om du vill autentisera din Snowflake-instans med Experience Platform måste du hämta din kontoidentifierare från Snowflake UI-instrumentpanelen.

Följ de här stegen för att hitta din kontoidentifierare:

  • Navigera till ditt konto på Snowflake programmets gränssnittspanel.
  • I den vänstra navigeringen väljer du Accounts följt av Active Accounts i sidhuvudet.
  • Välj sedan informationsikonen och markera och kopiera domännamnet för den aktuella URL:en.

Hämta din privata nyckel retrieve-your-private-key

Om du tänker använda nyckelpars-autentisering för din Snowflake-anslutning måste du generera en privat nyckel innan du ansluter till Experience Platform.

Skapa en krypterad privat nyckel

Kör följande kommando på terminalen för att generera din krypterade privata nyckel Snowflake:

code language-shell 
openssl genrsa 2048 | openssl pkcs8 -topk8 -v2 des3 -inform PEM -out rsa_key.p8

Om det lyckas bör du få din privata nyckel i PEM-format.

code language-shell 
-----BEGIN ENCRYPTED PRIVATE KEY-----
MIIE6T...
-----END ENCRYPTED PRIVATE KEY-----
Skapa en okrypterad privat nyckel

Om du vill generera din okrypterade privata Snowflake-nyckel kör du följande kommando på terminalen:

code language-shell 
openssl genrsa 2048 | openssl pkcs8 -topk8 -inform PEM -out rsa_key.p8 -nocrypt

Om det lyckas bör du få din privata nyckel i PEM-format.

code language-shell 
-----BEGIN PRIVATE KEY-----
MIIE6T...
-----END PRIVATE KEY-----

När du har genererat din privata nyckel kodar du den direkt i Base64 utan att göra några ändringar i dess format eller innehåll. Kontrollera att det inte finns några extra blanksteg eller tomma rader (inklusive efterföljande radmatningar) i slutet av den privata nyckeln innan du kodar.

Verifiera konfigurationer

Innan du kan skapa en källanslutning för dina Snowflake-data måste du också se till att följande konfigurationer uppfylls:

  • Det standardlagerställe som tilldelats en viss användare måste vara samma som det lagerställe som du angav vid autentisering till Experience Platform.
  • Den standardroll som tilldelats en viss användare måste ha tillgång till samma databas som du anger när du autentiserar dig för Experience Platform.

Så här verifierar du din roll och ditt lager:

  • Välj Admin till vänster och välj sedan Users & Roles.
  • Välj lämplig användare och markera sedan ellipserna (...) i det övre högra hörnet.
  • Navigera till Edit user i fönstret Default Role som visas för att visa rollen som är associerad med den angivna användaren.
  • I samma fönster går du till Default Warehouse för att visa det lagerställe som är associerat med den angivna användaren.

När kodningen är klar kan du sedan använda den Base64-kodade privata nyckeln på Experience Platform för att autentisera ditt Snowflake-konto.

Konfigurera rollinställningar configure-role-settings

Du måste konfigurera behörigheter för en roll, även om den allmänna standardrollen har tilldelats, så att källanslutningen kan komma åt den relevanta Snowflake-databasen, det aktuella -schemat och den aktuella tabellen. De olika behörigheterna för olika Snowflake-entiteter är följande:

Snowflake-entitet
Kräv rollprivilegium
Lagerställe
ANVÄNDA
Databas
ANVÄNDNING
Schema
ANVÄNDNING
Tabell
MARKERA
NOTE
Automatiskt återupptagande och automatiskt uppehåll måste vara aktiverat i den avancerade inställningskonfigurationen för ditt lagerställe.

Mer information om roll- och behörighetshantering finns i Snowflake API-referensen.

Begränsningar och vanliga frågor limitations-and-frequently-asked-questions

  • Datagenomströmningen för källan Snowflake är 2 000 poster per sekund.

  • Priset kan variera beroende på hur lång tid ett lagerställe är aktivt och storleken på lagerstället. För Snowflake-källintegreringen räcker det med det minsta lagret med x-small. Det rekommenderas att du aktiverar automatisk uppehåll så att lagerstället kan göra uppehåll när det inte används.

  • Snowflake-källan avsöker databasen efter nya data var 10:e sekund.

  • Konfigurationsalternativ:

    • Du kan aktivera en backfill boolesk flagga för Snowflake-källan när du skapar en källanslutning.

      • Om backfill är true anges värdet för timestamp.initial till 0. Detta innebär att data med en tidsstämpelkolumn som är större än 0 epok-tid hämtas.
      • Om backfill är inställd på false anges värdet för timestamp.initial till -1. Detta innebär att data med en tidsstämpelkolumn som är större än den aktuella tiden (den tid då källan börjar inhämta) hämtas.

    • Tidsstämpelkolumnen ska formateras som typen: TIMESTAMP_LTZ eller TIMESTAMP_NTZ. Om tidsstämpelkolumnen är inställd på TIMESTAMP_NTZ, ska motsvarande tidszon som värdena lagras i skickas via parametern timezoneValue. Om det inte anges används UTC som standard.

      • TIMESTAMP_TZ kan inte användas som en tidsstämpelkolumn eller i en mappning.

Nästa steg

NOTE
När du har skapat eller uppdaterat ett dataflöde för direktuppspelning krävs en kort 5-minuters paus i datainmatningen för att förhindra eventuella fall av dataförlust eller dataförlust.

I följande självstudie beskrivs hur du ansluter Snowflake-strömningskällan till Experience Platform med API

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