Beta Ultimate

Snowflake ストリーミングソース

Adobe Experience Platform を使用すると、外部ソースからデータを取り込みながら、Platform サービスを使用して受信データの構造化、ラベル付けおよび拡張を行うことができます。アドビのアプリケーション、クラウドベースのストレージ、データベースなど、様々なソースからデータを取り込むことができます。

Experience Platformは、 Snowflake データベース。

について Snowflake ストリーミングソース

この Snowflake ストリーミングソースは、SQL クエリを定期的に実行し、結果セットの各行の出力レコードを作成することで、データを読み込むことで機能します。

次を使用： Kafka Connect、 Snowflake ストリーミングソースは、各テーブルから受け取った最新のレコードをトラッキングし、次の反復の正しい場所で開始できるようにします。 ソースは、この機能を使用してデータをフィルタリングし、各反復でテーブルから更新された行のみを取得します。

前提条件

次の節では、データを Snowflake データベースからExperience Platformへ：

必要な資格情報の収集

次のために Flow Service ～とつながる Snowflakeに値を入力する場合は、次の接続プロパティを指定する必要があります。

認証について詳しくは、 [Snowflake 文書] (https://docs.snowflake.com/en/user-guide/key-pair-auth.html).

役割の設定を構成

デフォルトのパブリックロールが割り当てられている場合でも、ソース接続が関連する Snowflake データベース、スキーマ、テーブル。 様々な権限 Snowflake エンティティは次のようになります。

役割と権限の管理の詳細については、 [Snowflake API リファレンス] (https://docs.snowflake.com/en/sql-reference/sql/grant-privilege).

制限事項とよくある質問

• のデータスループット Snowflake ソースは、1 秒あたり 2,000 レコードです。
• 価格は、ウェアハウスがアクティブな時間とウェアハウスのサイズに応じて異なる場合があります。 の Snowflake 最小サイズの x-small ウェアハウスで十分なソース統合。 非使用時にウェアハウスを単独で休止できるように、自動休止を有効にすることをお勧めします。
• この Snowflake ソースは、10 秒ごとに新しいデータに対してデータベースをポーリングします。
• 設定オプション：
  • 以下を有効にすると、 backfill のブール型フラグ Snowflake ソース接続を作成する際のソース。
    • backfill が true に設定されている場合、timestamp.initial の値は 0 に設定されます。 つまり、タイムスタンプ列が 0 エポック時間を超えるデータが取得されます。
    • backfill が false に設定されている場合、timestamp.initial の値は —1 に設定されます。 つまり、タイムスタンプ列が現在の時刻（ソースの取り込みが開始される時刻）より大きいデータが取得されます。
  • timestamp 列は、次の形式にする必要があります。 TIMESTAMP_LTZ または TIMESTAMP_NTZ. timestamp 列が TIMESTAMP_NTZに値を指定しない場合、タイプは UTC 時間にデータベースに保存されます。

次の手順

次のチュートリアルでは、 Snowflake ストリーミングソースからExperience Platformへの変換（API を使用）:

• からのデータのストリーミング Snowflake フローサービス API を使用してExperience Platformにデータベースを送信する

Business.Adobe.com リソース