Snowflakeストリーミングコネクタ構成ガイド(早期アクセス)
この記事では、Snowflakeストリーミングコネクタの構成方法について説明します。
アクション
アクション名 | AudienceStream | EventStream |
---|---|---|
カスタムイベントデータを送信 | ✗ | ✓ |
全イベントデータを送信 | ✗ | ✓ |
カスタムビジターデータを送信 | ✓ | ✗ |
全ビジターデータを送信 | ✓ | ✗ |
ベストプラクティス
Snowflakeストリーミングコネクタに対して、以下のSnowflakeテーブル構成を推奨します:
- テーブルごとに1つのイベントフィード
- テーブルごとに1つのオーディエンス
複数のフィードやオーディエンスによるテーブルの同時書き込みは、パフォーマンスエラーを引き起こす可能性があります。
構成
コネクタマーケットプレイスに移動し、新しいコネクタを追加します。コネクタの追加方法については、コネクタについてを参照してください。
コネクタを追加した後、以下の構成を行います:
- ユーザー名
Snowflakeアカウントのユーザー名。 - ロール
セッションで使用するアクセス制御ロール。 - URL
以下の形式のSnowflakeアカウントURL:<account_identifier>.snowflakecomputing.com
- プライベートキー
顧客が生成したプライベートキー。Snowflakeプライベートキーの生成方法については、Snowflake > キーペア認証とキーペアのローテーションを参照してください。
コネクタ認証を完了するために、以下の手順を使用して、上記のユーザーに公開キーの詳細をSnowflakeで変更します:
- Snowflakeで公開キーを生成します。詳細については、公開キーの生成を参照してください。
- Snowflakeで
ALTER USER
コマンドを使用して、公開キーを上記のユーザーに割り当てます。ユーザーの所有者またはSECURITYADMINロール以上のユーザーのみがユーザーを変更できます。詳細については、公開キーをSnowflakeユーザーに割り当てるを参照してください。
公開キーをユーザーに正常に割り当てるためには、以下を確認してください:- Snowflakeのユーザー名を二重引用符(
"
)で入力します。例えば、"SNOWFLAKE.USER"
。 - 改行なしで公開キーをコピーして貼り付けます。
- Snowflakeのユーザー名を二重引用符(
- 新しい公開キーでユーザーを更新するクエリを実行します。
Snowflakeは公開キーとプライベートキーのローテーションをサポートしています。詳細については、キーペアローテーションの構成を参照してください。
アクション
以下のセクションでは、各アクションでサポートされているパラメータをリストします。
カスタムイベントデータを送信
パラメータ
パラメータ | 説明 |
---|---|
データベース名 | 必要なテーブルを含むSnowflakeデータベース。 |
スキーマ名 | テーブルで使用されるスキーマの名前。 |
テーブル名 | データを挿入したいテーブルの名前。 |
イベントパラメータ | イベントパラメータをSnowflakeテーブルの列にマッピングします。 |
全イベントデータを送信
パラメータ
パラメータ | 説明 |
---|---|
データベース名 | 必要なテーブルを含むSnowflakeデータベース。 |
スキーマ名 | テーブルで使用されるスキーマの名前。 |
テーブル名 | データを挿入したいテーブルの名前。 |
ペイロードを記録する列 | イベントデータを記録するVARIANT列を選択します。 |
カスタムビジターデータを送信
パラメータ
パラメータ | 説明 |
---|---|
データベース名 | 必要なテーブルを含むSnowflakeデータベース。 |
スキーマ名 | テーブルで使用されるスキーマの名前。 |
テーブル名 | データを挿入したいテーブルの名前。 |
ビジターパラメータ | ビジターパラメータをSnowflakeテーブルの列にマッピングします。 |
全ビジターデータを送信
パラメータ
パラメータ | 説明 |
---|---|
データベース名 | 必要なテーブルを含むSnowflakeデータベース。 |
スキーマ名 | テーブルで使用されるスキーマの名前。 |
テーブル名 | データを挿入したいテーブルの名前。 |
ビジターデータを記録する列 | ビジターデータを記録するVARIANT列を選択します。 |
現在の訪問データを含める | このオプションを選択すると、ビジターデータと現在の訪問データの両方がSnowflakeに送信されるデータに含まれます。 |
最終更新日 :: 2024年March月29日