UIを使用して、Snowflake データベースからExperience Platformにデータをストリーミングする

このガイドでは、UIでソースワークスペースを使用して、Snowflake データベースからExperience Platformにデータをストリーミングする方法について説明します。

基本を学ぶ

このチュートリアルは、 Experience Platform の次のコンポーネントを実際に利用および理解しているユーザーを対象としています。

認証

SnowflakeからExperience Platformにストリーミングデータを取り込む前に完了する必要がある手順については、​ ストリーミングデータの前提条件の設定 Snowflake のガイドを参照してください。

Snowflake Streaming ソースを使用してSnowflake データをExperience Platformにストリーミングします

Experience Platform UIで、左側のナビゲーションから「ソース」を選択して、​ ソース ​ ワークスペースにアクセスします。 画面の左側にあるカタログから適切なカテゴリを選択することができます。 または、使用する特定のソースを検索オプションを使用して探すこともできます。

データベース」カテゴリで「Snowflake Streaming」を選択し、「セットアップ」を選択します。

TIP
ソースカタログに認証済みアカウントを持たないソースには、設定 オプションが表示されます。 認証済みアカウントが存在すると、このオプションは​ データを追加 ​に変更されます。

Experience Platform UIのソースカタログで、Snowflake ストリーミングソースカードが選択されている。

Connect Snowflake Streaming account」ページが表示されます。 このページでは、新しい資格情報または既存の資格情報を使用できます。

新しいアカウントを作成

新しいアカウントを作成するには、新しいアカウント​を選択し、アカウントの名前とオプションの説明を指定します。

​ ソースワークフローの新しいアカウント作成インターフェイス。

基本認証

基本認証を使用するには、Snowflakeの基本認証​を選択し、Snowflake アカウントに資格情報を提供します。 完了したら、ソースに接続​を選択し、接続が確立されるまでしばらく待ちます。

必要な資格情報の収集について詳しくは、Snowflake Streamingの概要を参照してください。

基本認証が選択されたソースワークフローの新しいアカウントインターフェイス。

キーペア認証

KeyPair認証を使用するには、「SnowflakeのKeyPair認証」を選択し、Snowflake アカウントの資格情報を指定します。 完了したら、ソースに接続​を選択し、接続が確立されるまでしばらく待ちます。

必要な資格情報の収集について詳しくは、Snowflake Streamingの概要を参照してください。

​ ソースワークフローの新しいアカウントインターフェイス、キーペア認証が選択されました

既存のアカウントを使用するには、既存のアカウント​を選択し、リストからアカウントを選択して、次へ​を選択します。

データの選択 select-data

IMPORTANT
  • ストリーミングデータフローを作成するには、ソーステーブルにタイムスタンプ列が存在する必要があります。 Experience Platformがデータを取り込むタイミングと増分データをストリーミングするタイミングを把握するには、タイムスタンプが必要です。 既存の接続のタイムスタンプ列を過去にさかのぼって追加し、新しいデータフローを作成できます。

  • サンプルソースデータファイル内のデータフィールドの大文字と小文字が、識別子の大文字と小文字の区別に関するSnowflakeのガイダンスに従っていることを確認します。 詳しくは、識別子ケース 🔗に関するSnowflake ドキュメントを参照してください。

「​ データを選択」ステップが表示されます。 この手順では、Experience Platformに読み込むデータを選択し、タイムスタンプとタイムゾーンを設定し、生データを取り込むためのサンプルソースデータファイルを指定する必要があります。

画面の左側にあるデータベースディレクトリを使用し、Experience Platformに読み込むテーブルを選択します。

次に、テーブルのタイムスタンプ列タイプを選択します。 2種類のタイムスタンプ列(TIMESTAMP_NTZまたはTIMESTAMP_LTZ)から選択できます。 列タイプ TIMESTAMP_NTZを選択する場合は、タイムゾーンも指定する必要があります。 列にはnull以外の制約が必要です。 詳しくは、制限とよくある質問に関する節を参照してください。

この手順でバックフィル設定を設定することもできます。 バックフィルによって、最初に取り込むデータが決まります。 バックフィルが有効になっている場合、指定したパス内のすべての現在のファイルが、最初のスケジュールされた取り込み中に取り込まれます。 そうでない場合は、最初の取り込みの実行から開始時間までの間に読み込まれたファイルのみが取り込まれます。 開始時刻より前に読み込まれたファイルは取り込まれません。

バックフィル」トグルを選択して、バックフィルを有効にします。

​ タイムスタンプ、タイムゾーン、バックフィルの設定手順。

最後に、ファイルを選択​して、マッピングセットの作成に役立つサンプルソースデータをアップロードします。このマッピングセットは、後の手順で元のデータをExperience Data Model (XDM)にマッピングするために使用されます。

完了したら、次へ​を選択して続行します。

​ ソースサンプルデータのプレビュー。

データセットとデータフローの詳細を提供 provide-dataset-and-dataflow-details

次に、データセットとデータフローに関する情報を提供する必要があります。

データセットの詳細 dataset-details

データセットは、スキーマ(列)とフィールド(行)で構成されるデータコレクション(通常はテーブル)を格納し管理するための構造です。 Experience Platformに正常に取り込まれたデータは、データセットとしてデータレイク内に保持されます。 この手順では、新しいデータセットを作成するか、既存のデータセットを使用できます。

既存のデータセットがある場合は、既存のデータセット​を選択し、詳細検索 オプションを使用して、組織内のすべてのデータセットのウィンドウを表示します。これには、リアルタイム顧客プロファイルへの取り込みが有効になっているかどうかの詳細が含まれます。

既存のデータセット選択インターフェイス。

新しいデータセットを使用するには、新しいデータセット​を選択し、データセットの名前とオプションの説明を入力します。 データセットが準拠するExperience Data Model (XDM)スキーマも選択する必要があります。

新しいデータセットの詳細
説明
出力データセット名
新しいデータセットの名前。
説明
(オプション)新しいデータセットの概要。
スキーマ
組織内に存在するスキーマのドロップダウンリスト。 ソース設定プロセスの前に、独自のスキーマを作成することもできます。 詳しくは、UIでのXDM スキーマの作成に関するガイドを参照してください。

データフローの詳細 dataflow-details

データセットを設定したら、名前、オプションの説明、アラート設定など、データフローの詳細を指定する必要があります。

​ データフローの詳細設定ステップ。

データフロー設定
説明
データフロー名
データフローの名前。 デフォルトでは、読み込まれるファイルの名前が使用されます。
説明
(オプション)データフローの簡単な説明。
アラート

Experience Platformは、ユーザーが購読できるイベントベースのアラートを生成できます。 これらのオプションをトリガーするには、実行中のデータフローが必要です。 詳しくは、​ アラートの概要を参照してください

  • ソースデータフロー実行開始:このアラートを選択すると、データフロー実行が開始されたときに通知を受け取ります。
  • ソースデータフローの実行成功:このアラートを選択すると、データフローがエラーなしで終了した場合に通知を受け取ります。
  • ソースデータフロー実行エラー: データフロー実行がエラーで終了した場合に通知を受け取るには、このアラートを選択します。

完了したら、次へ​を選択して続行します。

XDM スキーマへのフィールドのマッピング mapping

「​ マッピング ​」ステップが表示されます。 マッピングインターフェイスを使用して、ソースデータをExperience Platformに取り込む前に、ソースデータを適切なスキーマフィールドにマッピングしてから、次へ​を選択します。 マッピングインターフェイスの使用方法に関する詳細なガイドについては、​ データ準備UI ガイド ​を参照してください。

​ ソースワークフローのマッピングインターフェイス。

データフローのレビュー review

データフロー作成プロセスの最後の手順は、データフローを実行する前に確認することです。 新しいデータフローが実行される前に、レビュー​手順を使用して、新しいデータフローの詳細を確認します。 詳細は、次のカテゴリにグループ化されます。

  • 接続: ソースタイプ、選択したソースファイルの関連パス、そのソースファイル内の列数を表示します。
  • データセットの割り当てとフィールドのマッピング:ソースデータがどのデータセットに取り込まれるかを、そのデータセットが準拠するスキーマを含めて表示します。

データフローをレビューしたら、「終了」を選択し、データフローが作成されるまでしばらく待ちます。

​ ソースワークフローのレビュー手順。

次の手順

このチュートリアルに従うことで、Snowflake データのストリーミングデータフローを正常に作成しました。 その他のリソースについては、以下のドキュメントを参照してください。

データフローの監視

データフローを作成したら、そのデータフローを通じて取り込まれるデータを監視し、取り込み率、成功、エラーに関する情報を表示できます。 ストリーミングデータフローを監視する方法について詳しくは、UIでのストリーミングデータフローの監視に関するチュートリアルを参照してください。

データフローの更新

データフローのスケジュール設定、マッピングおよび一般情報の設定を更新するには、UIでのソースデータフローの更新に関するチュートリアルを参照してください。

データフローの削除

データフロー ワークスペースで使用できる​ 削除 ​関数を使用して、不要になった、または誤って作成されたデータフローを削除できます。 データフローの削除方法について詳しくは、UIでのデータフローの削除に関するチュートリアルを参照してください。

recommendation-more-help
experience-platform-help-sources