[Beta]{class="badge informative"} [Ultimate]{class="badge positive"}
Snowflake Streaming-Quelle
- Die Snowflake Streaming-Quelle befindet sich in der Beta-Phase. Bitte lesen Sie die Quellen - Übersicht für weitere Informationen zur Verwendung von Beta-beschrifteten Quellen.
- Die Snowflake Streaming-Quelle ist in der API für Benutzer verfügbar, die Real-time Customer Data Platform Ultimate erworben haben.
Adobe Experience Platform ermöglicht die Aufnahme von Daten aus externen Quellen und bietet spezielle Services, mittels derer Sie eingehende Daten strukturieren, beschriften und erweitern können. Daten können aus verschiedensten Quellen aufgenommen werden, darunter etwa Adobe-Programme, Cloud-basierte Datenspeicher und Datenbanken.
Experience Platform unterstützt Streaming-Daten von einer Snowflake Datenbank.
Grundlagen zum Snowflake Streaming-Quelle
Die Snowflake Streaming-Quelle funktioniert durch das Laden von Daten, indem regelmäßig eine SQL-Abfrage ausgeführt und für jede Zeile der Ergebnismenge ein Ausgabedatensatz erstellt wird.
Durch Verwendung von Kafka Connect, die Snowflake Streaming-Quelle verfolgt den neuesten Datensatz, den sie von jeder Tabelle erhält, sodass er an der richtigen Stelle für die nächste Iteration beginnen kann. Die Quelle verwendet diese Funktion, um Daten zu filtern und bei jeder Iteration nur die aktualisierten Zeilen aus einer Tabelle zu erhalten.
Voraussetzungen
Im folgenden Abschnitt werden die erforderlichen Schritte beschrieben, die durchgeführt werden müssen, bevor Sie Daten von Ihrem Snowflake Datenbank zu Experience Platform:
Sammeln erforderlicher Anmeldeinformationen
Zur Flow Service zur Verbindung mit Snowflakemüssen Sie die folgenden Verbindungseigenschaften angeben:
account
cj12345.east-us-2.azure
. Weiterführende Informationen zu Kontonamen finden Sie in diesem [Snowflake document on account identifiers] (https://docs.snowflake.com/en/user-guide/admin-account-identifier.html).warehouse
database
username
password
role
public
.connectionSpec.id
51ae16c2-bdad-42fd-9fce-8d5dfddaf140
.Rolleneinstellungen konfigurieren configure-role-settings
Sie müssen Berechtigungen für eine Rolle konfigurieren, auch wenn die standardmäßige öffentliche Rolle zugewiesen ist, damit Ihre Quellverbindung auf die Snowflake Datenbank, Schema und Tabelle. Die verschiedenen Berechtigungen für verschiedene Snowflake -Entitäten lautet wie folgt:
Weiterführende Informationen zur Verwaltung von Rollen und Berechtigungen finden Sie im Abschnitt [Snowflake API-Referenz] (https://docs.snowflake.com/en/sql-reference/sql/grant-privilege).
Einschränkungen und häufig gestellte Fragen limitations-and-frequently-asked-questions
-
Der Datendurchsatz für die Snowflake -Quelle enthält 2000 Datensätze pro Sekunde.
-
Die Preise variieren je nach der aktiven Lagerzeit und der Lagergröße. Für Snowflake Quell-Integration, die kleinste Größe, x-kleine Warehouse ist ausreichend. Es wird empfohlen, das automatische Aussetzen zu aktivieren, damit das Warehouse selbst ausgesetzt werden kann, wenn es nicht in Verwendung ist.
-
Die Snowflake -Quelle fragt die Datenbank alle zehn Sekunden nach neuen Daten ab.
-
Konfigurationsoptionen:
-
Sie können eine
backfill
boolesches Flag für Ihre Snowflake Quelle beim Erstellen einer Quellverbindung.- Wenn die Aufstockung auf "true"festgelegt ist, wird der Wert für timestamp.initial auf 0 gesetzt. Das bedeutet, dass Daten mit einer Zeitstempelspalte abgerufen werden, die größer als 0 Epochenzeit ist.
- Wenn die Aufstockung auf "false"festgelegt ist, wird der Wert für timestamp.initial auf -1 gesetzt. Das bedeutet, dass Daten mit einer Zeitstempelspalte abgerufen werden, die größer ist als die aktuelle Zeit (der Zeitpunkt, zu dem die Quelle beginnt zu erfassen).
-
Die Spalte mit dem Zeitstempel sollte wie folgt formatiert sein:
TIMESTAMP_LTZ
oderTIMESTAMP_NTZ
. Wenn die Spalte mit dem Zeitstempel aufTIMESTAMP_NTZ
, sollte die entsprechende Zeitzone, in der die Werte gespeichert werden, über dietimezoneValue
-Parameter. Wenn nicht angegeben, wird für den Wert standardmäßig UTC verwendet.TIMESTAMP_TZ
kann nicht in einer Zeitstempelspalte oder einer Zuordnung verwendet werden.
-
Nächste Schritte
Im folgenden Tutorial erfahren Sie, wie Sie Ihre Snowflake Streaming-Quelle an Experience Platform mithilfe der API: