UIを使用して、Snowflake データベースからExperience Platformにデータをストリーミングする
このガイドでは、UIでソースワークスペースを使用して、Snowflake データベースからExperience Platformにデータをストリーミングする方法について説明します。
基本を学ぶ
このチュートリアルは、 Experience Platform の次のコンポーネントを実際に利用および理解しているユーザーを対象としています。
-
Experience Data Model (XDM) システム:Experience Platform が顧客体験データの整理に使用する標準化されたフレームワーク。
- スキーマ構成の基本:スキーマ構成の主要な原則やベストプラクティスなど、XDM スキーマの基本的な構成要素について学びます。
- スキーマエディターのチュートリアル:スキーマエディター UI を使用してカスタムスキーマを作成する方法を説明します。
-
Real-Time Customer Profile:複数のソースからの集計データに基づいて、統合されたリアルタイムの顧客プロファイルを提供します。
認証
SnowflakeからExperience Platformにストリーミングデータを取り込む前に完了する必要がある手順については、 ストリーミングデータの前提条件の設定 Snowflake のガイドを参照してください。
Snowflake Streaming ソースを使用してSnowflake データをExperience Platformにストリーミングします
Experience Platform UIで、左側のナビゲーションから「ソース」を選択して、 ソース ワークスペースにアクセスします。 画面の左側にあるカタログから適切なカテゴリを選択することができます。 または、使用する特定のソースを検索オプションを使用して探すこともできます。
「データベース」カテゴリで「Snowflake Streaming」を選択し、「セットアップ」を選択します。
「Connect Snowflake Streaming account」ページが表示されます。 このページでは、新しい資格情報または既存の資格情報を使用できます。
新しいアカウントを作成
新しいアカウントを作成するには、新しいアカウントを選択し、アカウントの名前とオプションの説明を指定します。
基本認証を使用するには、Snowflakeの基本認証を選択し、Snowflake アカウントに資格情報を提供します。 完了したら、ソースに接続を選択し、接続が確立されるまでしばらく待ちます。
必要な資格情報の収集について詳しくは、Snowflake Streamingの概要を参照してください。
KeyPair認証を使用するには、「SnowflakeのKeyPair認証」を選択し、Snowflake アカウントの資格情報を指定します。 完了したら、ソースに接続を選択し、接続が確立されるまでしばらく待ちます。
必要な資格情報の収集について詳しくは、Snowflake Streamingの概要を参照してください。
既存のアカウントを使用するには、既存のアカウントを選択し、リストからアカウントを選択して、次へを選択します。
データの選択 select-data
-
ストリーミングデータフローを作成するには、ソーステーブルにタイムスタンプ列が存在する必要があります。 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)スキーマも選択する必要があります。
データフローの詳細 dataflow-details
データセットを設定したら、名前、オプションの説明、アラート設定など、データフローの詳細を指定する必要があります。
Experience Platformは、ユーザーが購読できるイベントベースのアラートを生成できます。 これらのオプションをトリガーするには、実行中のデータフローが必要です。 詳しくは、 アラートの概要を参照してください
- ソースデータフロー実行開始:このアラートを選択すると、データフロー実行が開始されたときに通知を受け取ります。
- ソースデータフローの実行成功:このアラートを選択すると、データフローがエラーなしで終了した場合に通知を受け取ります。
- ソースデータフロー実行エラー: データフロー実行がエラーで終了した場合に通知を受け取るには、このアラートを選択します。
完了したら、次へを選択して続行します。
XDM スキーマへのフィールドのマッピング mapping
「 マッピング 」ステップが表示されます。 マッピングインターフェイスを使用して、ソースデータをExperience Platformに取り込む前に、ソースデータを適切なスキーマフィールドにマッピングしてから、次へを選択します。 マッピングインターフェイスの使用方法に関する詳細なガイドについては、 データ準備UI ガイド を参照してください。
データフローのレビュー review
データフロー作成プロセスの最後の手順は、データフローを実行する前に確認することです。 新しいデータフローが実行される前に、レビュー手順を使用して、新しいデータフローの詳細を確認します。 詳細は、次のカテゴリにグループ化されます。
- 接続: ソースタイプ、選択したソースファイルの関連パス、そのソースファイル内の列数を表示します。
- データセットの割り当てとフィールドのマッピング:ソースデータがどのデータセットに取り込まれるかを、そのデータセットが準拠するスキーマを含めて表示します。
データフローをレビューしたら、「終了」を選択し、データフローが作成されるまでしばらく待ちます。
次の手順
このチュートリアルに従うことで、Snowflake データのストリーミングデータフローを正常に作成しました。 その他のリソースについては、以下のドキュメントを参照してください。
データフローの監視
データフローを作成したら、そのデータフローを通じて取り込まれるデータを監視し、取り込み率、成功、エラーに関する情報を表示できます。 ストリーミングデータフローを監視する方法について詳しくは、UIでのストリーミングデータフローの監視に関するチュートリアルを参照してください。
データフローの更新
データフローのスケジュール設定、マッピングおよび一般情報の設定を更新するには、UIでのソースデータフローの更新に関するチュートリアルを参照してください。
データフローの削除
データフロー ワークスペースで使用できる 削除 関数を使用して、不要になった、または誤って作成されたデータフローを削除できます。 データフローの削除方法について詳しくは、UIでのデータフローの削除に関するチュートリアルを参照してください。