Snowflakeデータソースの管理

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

Snowflakeデータソースを作成するには、以下の手順を完了します：

1. Tealiumで、Sources > Data Sourcesに移動します。
2. +Add Data Sourceをクリックします。
3. Categoriesの下で、Data Warehouseをクリックし、Snowflakeを選択します。
4. Nameフィールドに、使用事例に関連するデータソースのユニークな名前を入力します。
5. 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画面で、データソースの名前を確認し、ドロップダウンリストから既存の接続を選択するか、**+**アイコンをクリックして新しい接続を作成します。

新しい接続を構成するには、次の接続詳細を入力します。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: アクセス制御権限を参照してください。
• Authentication Method:
  • Key-Pair:
    1. Snowflakeデータベース、スキーマ、ウェアハウス、テーブルまたはビューにアクセスするユーザーのユーザー名を入力します。
    2. RSA-2048、RSA-3072、RSA-4096のいずれかの暗号化アルゴリズムを使用してキーペアを生成します。
    3. 公開キーファイルをダウンロードします。キーは-----BEGIN PUBLIC KEY-----と-----END PUBLIC KEY-----の間のテキストのみです。
    4. 次のコマンドを使用して、ユーザーに公開キーを割り当てます：

       ALTER USER example_user
       SET RSA_PUBLIC_KEY='your_public_key';
       

       詳細については、Snowflake: Snowflakeユーザーに公開キーを割り当てるを参照してください。
    5. キーがユーザーに正しく割り当てられたことを確認するために、キーフィンガープリントをコピーします。詳細については、Snowflake: ユーザーの公開キーフィンガープリントを確認するの指示に従ってください。
  • Username and Password (legacy): Snowflakeデータベース、スキーマ、ウェアハウス、テーブルまたはビューにアクセスするサービスユーザーのユーザー名とパスワード。このオプションは既存の接続にのみ対応しています。詳細については、Snowflakeデータソースについてを参照してください。

SaveをクリックしてConnection Configuration画面に戻り、Establish Connectionをクリックします。

Snowflakeに正常に接続した後、Table Selectionドロップダウンリストからデータソーステーブルを選択します。複数のSnowflakeテーブルからデータをインポートする場合は、Snowflakeでビューを作成し、ドロップダウンリストから選択します。詳細については、Snowflake: ビューの概要を参照してください。

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

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

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

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

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

1. クエリモードを選択します。 クエリモードは、新規および/または変更された行を検出するために使用されるSnowflakeテーブルまたはビューの列を決定します。
   • Timestamp + Incrementing（推奨）を選択した場合、新規および変更された行を検出するために、タイムスタンプ列と厳密に増加する列の2つの列を選択する必要があります。
   • TimestampまたはIncrementingを選択した場合、新規および変更された行、または新規行のみを検出するために使用する列を選択する必要があります。 詳細については、About Snowflake data source > Query modesを参照してください。 Timestamp + IncrementingおよびTimestampモードの場合、選択されたタイムスタンプ列は、TIMESTAMP_LTZ、TIMESTAMP_TZ、またはTIMESTAMP_NTZのいずれかのSnowflakeデータ型である必要があります。詳細については、Snowflake: 日付＆時間データ型を参照してください。
2. クエリを構成します。

   1. Query > Select Columnsセクションで、Tealiumにインポートするテーブルまたはビューの列を選択します。Snowflakeテーブルまたはビューを変更するには、Previousをクリックしてステップ1: Snowflake接続の確立に戻ります。

   2. （オプション）カスタム条件または追加のフィルターを追加するには、SQL WHERE句を含めます。

      WHERE句は複数のテーブルからのサブクエリをサポートしていません。複数のSnowflakeテーブルからデータをインポートする場合は、Snowflakeでビューを作成し、データソース構成でビューを選択します。詳細については、Snowflake: ビューの概要を参照してください。

   3. Test QueryをクリックしてSQLクエリを検証し、結果をプレビューします。

3. Continueをクリックします。

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

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

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

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

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

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

AudienceStreamでの訪問IDマッピングはデフォルトで有効です。訪問IDマッピングを無効にすると、訪問のスティッチングにエラーが発生する可能性があります。詳細については、Tealiumデータソースを使用した訪問識別を参照してください。

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

ステップ6: 概要

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

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

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

Snowflakeデータソースの編集

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