Ultimate

Snowflake ストリーミングソース

最終更新日： 2025年4月4日
  • トピック：

作成対象：

  • 開発者
IMPORTANT

  • Real-Time CDP Ultimateを購入したユーザーは、API で Snowflake ストリーミングソースを利用できます。

  • Amazon Web Services（AWS）でAdobe Experience Platformを実行するときに、Snowflake ストリーミングソースを使用できるようになりました。 AWS上で動作するExperience Platformは、現在、限られた数のお客様が利用できます。 サポートされるExperience Platform インフラストラクチャについて詳しくは、Experience Platform multi-cloud overview を参照してください。

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

Experience Platformは、Snowflake データベースからのストリーミングデータをサポートしています。

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

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

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

前提条件

次の節では、Snowflake データベースからExperience Platformにデータをストリーミングする前に実行する必要がある前提条件の手順について説明します。

IP アドレス許可リストの更新

ソースコネクタを操作する前に、IP アドレスのリストを許可リストに追加する必要があります。 地域固有の IP アドレスを許可リストに追加しないと、ソースを使用する際にエラーが発生したり、パフォーマンスが低下する場合があります。 詳しくは、IP アドレスの許可リストページを参照してください。

以下のドキュメントでは、API やユーザーインターフェイスを使用して Amazon Redshift をExperience Platformに接続する方法について説明しています。

必要な資格情報の収集

Flow Service を Snowflake に接続するには、次の接続プロパティを指定する必要があります。

資格情報説明
account

サフィックス snowflakecomputing.com が付いた Snowflake アカウントの完全なアカウント識別子（アカウント名またはアカウントロケーター）。 アカウント識別子は、次のように異なる形式にすることができます。

  • {ORG_NAME}-{ACCOUNT_NAME}.snowflakecomputing.com （例：acme-abc12345.snowflakecomputing.com）
  • {ACCOUNT_LOCATOR}。{CLOUD_REGION_ID}.snowflakecomputing.com （例：acme12345.ap-southeast-1.snowflakecomputing.com）
  • {ACCOUNT_LOCATOR}。{CLOUD_REGION_ID}。{CLOUD}.snowflakecomputing.com （例：acme12345.east-us-2.azure.snowflakecomputing.com）

詳しくは、Snowflake document on account identifiers を参照してください。

warehouseSnowflake ウェアハウスは、アプリケーションのクエリ実行プロセスを管理します。 各 Snowflake ウェアハウスは互いに独立しており、データをExperience Platformに取り込む際は個別にアクセスする必要があります。
databaseSnowflake データベースには、Experience Platformに取り込むデータが含まれています。
usernameSnowflake アカウントのユーザー名。
passwordSnowflake ユーザーアカウントのパスワード。
role（オプション）特定の接続に対してユーザーに提供できる、カスタム定義の役割。 指定しない場合、この値はデフォルトで public になります。
connectionSpec.id接続仕様は、ベース接続とソース接続の作成に関連する認証仕様などの、ソースのコネクタプロパティを返します。Snowflake の接続仕様 ID は 51ae16c2-bdad-42fd-9fce-8d5dfddaf140 です。

役割の設定

デフォルトのパブリックロールが割り当てられている場合でも、ソース接続が関連する Snowflake データベース、スキーマおよびテーブルにアクセスできるようにするには、ロールへの権限を設定する必要があります。 様々な Snowflake エンティティに対する様々な権限は次のとおりです。

Snowflake エンティティ役割権限を必要とする
ウェアハウス操作、使用
データベース使用方法
スキーマ使用方法
テーブルを選択
NOTE
ウェアハウスの詳細設定コンフィギュレーションで、自動レジュームと自動休止を有効にする必要があります。

役割および権限の管理について詳しくは、Snowflake API リファレンスを参照してください。