Snowflakeデータソースの管理 | スノーフレークデータソース

Tealiumが選択したSnowflakeテーブルまたはビューからのみデータをポーリングできるようにするには、データベース、スキーマ、ウェアハウス、および接続したいテーブルまたはビューに対するUSAGE権限を持つカスタムSnowflakeロールを作成します。詳細については、Snowflake: カスタムロールおよび Snowflake: アクセス制御権限を参照してください。

Snowflakeデータソースを作成するには、以下の手順を完了してください：

Tealiumで Sources > Data Sources に移動します。
+Add Data Source をクリックします。
Categories の下で Data Warehouse をクリックし、Snowflake を選択します。
Name フィールドに、使用事例に関連するデータソースの一意の名前を入力します。
Continue をクリックします。

ステップ1: Snowflake接続の確立

Snowflakeデータソースでは、他のSnowflakeデータソースで再利用できるSnowflakeへの接続を作成できます。

開始する前に、以下のSnowflakeアカウント情報を確認してください：

アカウント識別子
アカウント識別子の形式を確認するには、Snowflakeワークスペースに移動し、一意のアカウントURLをコピーします。例えば、SnowflakeアカウントURLが xy12345.us-east-2.aws.snowflakecomputing.com/console#/internal/worksheet の場合、xy12345.us-east-2.aws.snowflakecomputing.com部分をアカウント識別子として使用します。詳細については、Snowflake: アカウント識別子を参照してください。
接続ウェアハウス
データベース名
データベーススキーマ
接続ロール
Snowflakeユーザー名とパスワード

Connection Configuration 画面で、データソースの名前を確認します。
ドロップダウンリストから既存の接続構成を選択するか、+ アイコンをクリックして新しい接続を作成します。新しい接続を作成するには、New Snowflake Connection Configuration 画面で次のアカウント詳細を入力します。Snowflakeアカウントの構成によっては、接続情報が大文字と小文字を区別する場合があります。
- Snowflake Connection Configuration Name: 再利用可能な接続構成の名前を提供します。
- Account Identifier: http://プレフィックスなしの次の形式でSnowflakeアカウント識別子を提供します：
  - Snowflakeアカウント名を使用する場合: ACCOUNT_NAME.snowflakecomputing.com。
  - リージョン内のSnowflakeアカウントロケータを使用する場合: ACCOUNT_LOCATOR.CLOUD_REGION_ID.CLOUD.snowflakecomputing.com。
- Connection Warehouse: この接続に使用するSnowflakeウェアハウスの名前。
- Database Name: 接続するSnowflakeデータベースの名前。
- Database Schema: 接続するSnowflakeデータベーススキーマの名前。
- Connection Role: Snowflakeでユーザーに割り当てられたロール。このロールはUSAGE権限を持っている必要があります。詳細については、Snowflake: カスタムロールおよび Snowflake: アクセス制御権限を参照してください。
- Username と Password: Snowflakeデータベース、スキーマ、ウェアハウス、およびテーブルまたはビューに接続するために使用するユーザー名とパスワード。
Save をクリックします。
Connection Configuration 画面で Establish Connection をクリックします。
Snowflakeに正常に接続した後、Table Selection ドロップダウンリストからデータソーステーブルを選択します。複数のSnowflakeテーブルからデータをインポートする場合は、Snowflakeでビューを作成し、ドロップダウンリストから選択します。詳細については、Snowflake: ビューの概要を参照してください。
Continue をクリックします。

ステップ2: 処理の有効化

プロファイルを保存して公開した直後にSnowflakeデータソースの処理を開始したい場合は、Enable Processing をオンに切り替えます。

完了したら、Continue をクリックします。

ステップ3: クエリの構成

Query Mode and Configuration 画面で、Snowflakeテーブルまたはビューに適したクエリモードを選択し、必要に応じてSQL WHERE 句を含めて、カスタム条件に一致するレコードのみを処理します。

クエリモードを選択します。クエリモードは、Snowflakeテーブルまたはビューのどの列を使用して新規または変更された行を検出するかを決定します。
- Timestamp + Incrementing（推奨）を選択した場合、新規および変更された行を検出するために、タイムスタンプ列と厳密に増加する列の2つの列をリストする必要があります。
- Timestamp または Incrementing を選択した場合、新規行のみまたは新規および変更された行のいずれかを検出するために使用する列の名前をリストする必要があります。詳細については、About Snowflake data source > Query modesを参照してください。
クエリを構成します。
1. Query > Select Columns セクションで、Tealiumにインポートするテーブルまたはビューの列を選択します。Snowflakeテーブルまたはビューを変更するには、Previous をクリックしてステップ1: Snowflake接続の確立に戻ります。
2. (オプション) カスタム条件または追加のフィルターを追加するには、SQL WHERE 句を含めます。
  WHERE 句は複数のテーブルからのサブクエリをサポートしていません。複数のSnowflakeテーブルからデータをインポートするには、Snowflakeでビューを作成し、データソース構成でビューを選択します。詳細については、Snowflake: ビューの概要を参照してください。
3. Test Query をクリックしてSQLクエリを検証し、結果をプレビューします。
Continue をクリックします。

ステップ4: 列のマッピング

列マッピングテーブルを使用して、事前に構成された列ラベルをイベント属性にマッピングするか、手動で列ラベルを入力してマッピングします。Snowflakeからの各行はイベントとして処理されます。イベント属性にマッピングされていない列は無視されます。

各列ラベルに対して、ドロップダウンリストから対応するイベント属性を選択します。

完了したら、Continue をクリックします。

ステップ5: 訪問ID属性のマッピング

SnowflakeデータをAudienceStreamで使用するには、データを訪問ID属性にマッピングします。訪問IDを表すマップされたイベント属性を選択し、それを対応する訪問ID属性にマッピングします。

AudienceStreamでの訪問IDマッピングはデフォルトで有効になっています。訪問IDマッピングを無効にすると、訪問のスティッチングにエラーが発生する可能性があります。詳細については、Visitor Identification using Tealium Data Sourcesを参照してください。

完了したら、Continue をクリックします。

ステップ6: 概要

この最終ステップでは、概要を表示し、必要に応じて修正を加えてからプロファイルを保存して公開します。構成を編集するには、変更を加えたいステップに戻るためにPrevious をクリックします。

イベント属性と訪問IDマッピングを表示します。
Finish をクリックしてデータソースを作成し、構成画面を終了します。新しいデータソースは Data Sources ダッシュボードにリストされます。
Save/Publish をクリックして変更を保存して公開します。

インポート活動の状況を確認するには、Data Sources ダッシュボードに移動し、データソースを展開します。

Snowflakeデータソースの編集

Snowflakeデータソースを変更するには、Data Sources ダッシュボードに移動し、変更したい構成の編集アイコンをクリックします。Edit Connection 画面から、Snowflake接続、処理構成、クエリ、およびマッピング構成を編集できます。