Snowflakeをデータパイプラインの宛先として設定 ​

Snowflakeをデータパイプラインの宛先として設定します。 このコネクションにより、Workatoはソーススキーマを使用してソースアプリケーションからSnowflakeにデータをレプリケートできます。

サポートされている機能 ​

Snowflakeをパイプラインの宛先として使用する場合、次の機能がサポートされます:

• ソーススキーマに基づく宛先テーブルの自動作成
• フルデータロードおよび増分データロードのサポート
• 明示的なフィールドマッピングを使用しないフィールドレベルのデータレプリケーション
• スキーマドリフトの処理および更新操作
• データ整合性のためのステージングテーブルおよび一時テーブルの使用

前提条件 ​

次の設定とアクセス権が必要です:

• データベース、ウェアハウス、スキーマにアクセスできるSnowflakeアカウント
• テーブルを作成し、データをロードする権限を持つユーザーロール
• サポートされている認証方法: OAuth 2.0、キーペア認証、またはユーザー名/パスワード

Snowflakeへの接続 ​

Snowflakeをデータパイプラインの宛先として接続するには、次の手順を実行します。 このコネクションにより、パイプラインでデータをSnowflakeにレプリケートしてロードできます。

宛先アクションの設定 ​

パイプラインを開始する前に、Snowflakeのスキーマが新しく作成され、空であることを確認してください。 これにより、初回同期中のエラーを防ぎ、パイプラインが競合なく宛先テーブルを作成できるようになります。

識別子の処理 ​

Workatoは、データをSnowflakeにレプリケートする際に、オブジェクト名とフィールド名に次の変換を適用します:

• カラム名は大文字に変換されます
• $、スペース、ダッシュなどの特殊文字はアンダースコア（_）に置き換えられます
• 識別子は、特殊文字および予約語をサポートするために二重引用符で囲まれます

これらの変換により、SnowflakeのSQL構文および予約キーワードとの互換性が確保されます。

例 ​

次のソーステーブル構造:

Snowflakeに作成される次のテーブルになります:

CREATE TABLE "ACCOUNT" ("_NAME_", "CREATEDDATE", "LIMIT")

Snowflakeは引用符で囲まれていない識別子を大文字小文字を区別せずに扱うため、次のようなクエリを実行できます:

SELECT createddate FROM account;
SELECT "LIMIT" FROM ACCOUNT;

引用符で囲まれたクエリは、識別子の正確な大文字小文字と一致している必要があります。