この記事では、パイプラインでコピー アクティビティを使用して Snowflake との間でデータをコピーする方法について説明します。
サポートされている構成
Copy アクティビティの下の各タブの構成については、それぞれ次のセクションを参照してください。
全般
[全般設定] タブを構成するには、全般設定のガイダンスを参照してください。
ソース
コピー アクティビティの [ソース] タブの Snowflake では、次のプロパティがサポートされています。
次のプロパティは必須です。
[接続]: 接続リストから [Snowflake] 接続を選択します。 接続が存在しない場合は、新しい Snowflake 接続を作成します。
-
追加の接続プロパティ: Snowflake 接続で使用される追加の接続プロパティを指定して、詳細オプションを設定します。 追加の接続プロパティは、キーと値のペアのディクショナリとして提供されます。
ロール: 接続後にセッションに使用される既定のセキュリティ ロール。 詳細については、こちらの記事を参照してください。
-
追加の接続プロパティ: Snowflake 接続で使用される追加の接続プロパティを指定して、詳細オプションを設定します。 追加の接続プロパティは、キーと値のペアのディクショナリとして提供されます。
データベース: 接続後に使用する既定のデータベース。 指定したロールが特権を持っている既存のデータベースである必要があります。
[クエリの使用]: 使用クエリとして [テーブル] または [クエリ] を選択できます。 次の一覧で、各設定の構成について説明します。
- テーブル: ドロップダウン リストからデータベース内のテーブルを選択します。 または、[ 編集] をオンにして、テーブル名を手動で入力します。
-
クエリ: Snowflake からデータを読み取る SQL クエリを指定します。 スキーマ、テーブル、および列の名前に小文字が含まれている場合は、クエリでオブジェクト識別子を引用符で囲みます (例:
select * from "schema"."myTable")。
バージョン: バージョンを指定します。 最新の拡張機能を利用するには、最新バージョンにアップグレードすることをお勧めします。 さまざまなバージョンの違いについては、この セクションを参照してください。
[詳細設定] では、次のフィールドを指定できます。
ストレージ統合: Snowflake で作成したストレージ統合の名前を指定します。 ストレージ統合を使用するための前提となる手順については、「Snowflake ストレージ統合の構成」を参照してください。 ストレージ統合は、 Snowflake からの直接コピー または Snowflake からのステージング コピーに使用できます。
追加の Snowflake コピー オプション: データを読み込むために、Snowflake COPY ステートメントで使用される追加の Snowflake コピー オプションを指定します。 追加のコピー オプションは、キーと値のペアのディクショナリとして指定されます。 例 :MAX_FILE_SIZE、OVERWRITE。 詳細については、「Snowflake コピー オプション」を参照してください。
追加の Snowflake 形式オプション: データを読み込むために、Snowflake COPY ステートメントで使用される追加の Snowflake 形式オプションを指定します。 COPY コマンドに提供される追加のファイル形式オプションは、キーと値のペアの辞書形式で表されます。 例 :DATE_FORMAT、TIME_FORMAT、TIMESTAMP_FORMAT。 詳細については、「Snowflake 形式の種類のオプション」を参照してください。
Snowflake から直接コピーする
コピー先のデータ ストアと形式がこのセクションで説明されている条件を満たしている場合は、Copy アクティビティを使用して Snowflake からコピー先に直接コピーできます。 サービスは設定をチェックし、次の条件が満たされていない場合、Copy アクティビティの実行に失敗します。
ソースで Storage integration を指定する場合: 移行先データ ストアは、Snowflake の外部ステージで参照したAzure Blob Storageです。 データをコピーする前に、次の手順を完了する必要があります。
サポートされている認証の種類を使用して、宛先のAzure Blob StorageのAzure Blob Storage接続を、組織アカウント認証を除いて作成します。
少なくとも Storage BLOB データ共同作成者 ロールを、宛先 Azure Blob Storage Access Control (IAM) の Snowflake サービス プリンシパルに付与します。
ソースにストレージ統合を指定しない場合:
destination 接続は、Azure Blob Storage共有アクセス署名認証です。 サポートされている次の形式でデータをAzure Data Lake Storage Gen2に直接コピーする場合は、Azure Data Lake Storage Gen2 アカウントに対して SAS 認証を使用するAzure Blob Storage接続を作成して、Snowflake から staged コピーを使用しないようにすることができます.
コピー先データ形式が、次のように構成された Parquet、DelimitedText、または JSON です。
- Parquet 形式の場合は、圧縮コーデックが None、Snappy、または Lzo です。
-
DelimitedText 形式の場合:
- 行区切り記号は、\r\n、または任意の 1 文字です。
- 圧縮の種類は、None、gzip、 bzip2、または deflate にできます。
- エンコードは既定値のままか、UTF-8 に設定します。
- 引用符文字は、Double quote、Single quote、または No quote character (引用符なし) です。
-
JSON 形式の場合、直接コピーでは、ソースの Snowflake テーブルまたはクエリ結果に 1 つの列しかなく、この列のデータ型が VARIANT、OBJECT、または ARRAY であるケースのみがサポートされます。
- 圧縮の種類は、None、gzip、 bzip2、または deflate にできます。
- エンコードは既定値のままか、UTF-8 に設定します。
- コピー アクティビティのコピー先のファイル パターンは、既定値のままにするか、オブジェクトのセットに設定します。
コピー アクティビティ ソースでは、追加の列は指定しません。
列マッピングが指定されていません。
Snowflake からの準備されたコピー
コピー先のデータ ストアまたは形式が Snowflake COPY コマンドとネイティブに互換性がない場合は、ステージング コピーを使用します。 ワークスペースのステージング コピー、または中間Azure BLOB ストレージ インスタンスを使用した外部ステージング コピーを選択できます。 ステージング コピー機能はスループットも優れています。 Snowflake のデータをステージング ストレージにエクスポートしてから、データを宛先にコピーし、最後にステージング ストレージの一時データをクリーンアップします。 ステージングコピーの詳細については、こちらの記事をご参照ください。
ワークスペースのステージング コピー
この機能を使用するには、[ 設定] タブに移動し、ステージング データ ストアの種類として [ワークスペース ] を選択します。 ステージング ストレージは、Fabric内の組み込みストレージです。 ソースでストレージ統合を指定するかどうかに基づいて、追加の構成を完了する必要があります。
ソースで ストレージ統合 を指定する場合は、次の手順を実行します。
-
Snowflake クラウド ストレージ統合を作成し、STORAGE_ALLOWED_LOCATIONSとして次のいずれかの OneLake URL を設定します:
azure://onelake.blob.fabric.microsoft.com/<Workspace ID>/<Pipeline/Copy job ID>/Stagingまたはazure://onelake.blob.fabric.microsoft.com/<Workspace ID>。 - 「 ストレージの場所に Snowflake アクセスを許可する 」の最初の 3 つの手順に従って Snowflake サービス プリンシパルを取得し、ワークスペースで少なくとも 共同作成者 のアクセス許可を付与します。
-
Snowflake クラウド ストレージ統合を作成し、STORAGE_ALLOWED_LOCATIONSとして次のいずれかの OneLake URL を設定します:
ソースで Storage integration を指定しない場合は、Fabric内で組み込みのステージング ストレージを直接使用できます。
外部ステージング用コピー
この機能を使用するには、Azure ストレージ アカウントを中間ステージングとして参照する Azure Blob Storage 接続 を作成します。 次に、[設定] タブに移動してステージング設定を構成します。 Azure Blob Storageステージング接続を構成するには、External を選択する必要があります。
ソースで Storage integration を指定する場合、中間ステージング用の Azure Blob Storage は、Snowflake の外部ステージで参照されているものと一致している必要があります。 組織アカウント認証を除き、サポートされている認証でAzure Blob Storageの接続を作成し、ステージング用の Azure Blob Storage のアクセス制御 (IAM)で、Snowflake サービスプリンシパルにストレージ ブロブ データ共同作成者ロールを必ず付与します。 [設定] タブにある [ステージング設定] の [ストレージ パス] が必要です。
ソースで Storage integration を指定しない場合、ステージング Azure Blob Storage接続では Snowflake COPY コマンドの必要に応じて、Shared Access Signature 認証を使用する必要があります。 ステージング Azure Blob Storageで Snowflake に適切なアクセス許可を付与していることを確認します。 この詳細については、こちらの記事を参照してください。
宛先
コピー アクティビティの [コピー先] タブの Snowflake では、次のプロパティがサポートされています。
[宛先] タブを示す
次のプロパティは必須です。
[接続]: 接続リストから [Snowflake] 接続を選択します。 接続が存在しない場合は、新しい Snowflake 接続を作成します。
追加の接続プロパティ: Snowflake 接続で使用される追加の接続プロパティを指定して、詳細オプションを設定します。 追加の接続プロパティは、キーと値のペア (Role など) のディクショナリとして提供されます。 詳細については、こちらの記事を参照してください。
データベース: 接続後に使用する既定のデータベース。 指定したロールが特権を持っている既存のデータベースである必要があります。
テーブル: ドロップダウン リストからデータベース内のテーブルを選択します。 または、[ 編集] をオンにして、テーブル名を手動で入力します。 変換先テーブルが存在しない場合は、ソース データに基づいて自動的に作成されます。 テーブルの自動作成は、バージョン 1.1 以降でサポートされています。 自動作成テーブルのマッピングの詳細については、「Snowflake の自動作成テーブルの 変換先データ型の編集 」と 「既定のデータ型マッピング」を参照してください。
バージョン: バージョンを指定します。 最新の拡張機能を利用するには、最新バージョンにアップグレードすることをお勧めします。 さまざまなバージョンの違いについては、この セクションを参照してください。
書き込み動作: Snowflake にデータを書き込む方法について説明します。 バージョン 1.1 以降でのみ使用できます。 使用できる値は Insert (既定値) と Upsert です。
- 挿入: ソース データに挿入がある場合は、このオプションを選択します。
-
Upsert: 既存のテーブルに新しい値を挿入し、既存の値を更新します。
- キー列: ソースの行がコピー先の行と一致するかどうかを判断するために使用する列を選択します。 キー列として扱う 1 つ以上の列を指定できます。 キー列が指定されていない場合は、コピー先テーブルの主キーがキー列として使用されます。
[詳細設定] では、次のフィールドを指定できます。
事前コピー スクリプト: 各実行でコピー先テーブルにデータを書き込む前に、コピー アクティビティを実行するスクリプトを指定します。 このプロパティを使用して、事前に読み込まれたデータをクリーンアップできます。
ストレージ統合: Snowflake で作成したストレージ統合の名前を指定します。 ストレージ統合を使用するための前提となる手順については、「Snowflake ストレージ統合の構成」を参照してください。 Snowflake への直接コピーまたは Snowflake へのステージング コピーには、ストレージ統合を使用できます。
追加の Snowflake コピー オプション: データを読み込むために、Snowflake COPY ステートメントで使用される追加の Snowflake コピー オプションを指定します。 追加のコピー オプションは、キーと値のペアのディクショナリとして指定されます。 例 :ON_ERROR、FORCE、LOAD_UNCERTAIN_FILES。 詳細については、「Snowflake コピー オプション」を参照してください。
追加の Snowflake 形式オプション: データを読み込むために、Snowflake COPY ステートメントで使用される追加の Snowflake 形式オプションを指定します。 COPY コマンドに提供される追加のファイル形式オプションは、キーと値のペアの辞書形式で表されます。 例 :DATE_FORMAT、TIME_FORMAT、TIMESTAMP_FORMAT。 詳細については、「Snowflake 形式の種類のオプション」を参照してください。
Snowflake に直接コピーする
ソース データ ストアと形式がこのセクションで説明されている条件を満たしている場合は、Copy アクティビティを使用してソースから Snowflake に直接コピーできます。 サービスは設定をチェックし、次の条件が満たされていない場合、Copy アクティビティの実行に失敗します。
宛先に ストレージ統合を指定する場合:
ソース データ ストアは、Snowflake の外部ステージで参照したAzure Blob Storageです。 データをコピーする前に、次の手順を完了する必要があります。
組織アカウント認証を除く、サポートされている認証の種類を使用して、ソース Azure Blob Storageの Azure Blob Storage 接続を作成します。
少なくとも Storage Blob Data Reader ロールをソース Azure Blob Storage Access Control (IAM) の Snowflake サービス プリンシパルに付与します。
宛先に ストレージ統合を指定しない場合:
source 接続は、Azure Blob Storageでの共有アクセス署名認証です。 サポートされている次の形式でAzure Data Lake Storage Gen2からデータを直接コピーする場合は、Azure Data Lake Storage Gen2 アカウントに対して SAS 認証を使用するAzure Blob Storage接続を作成して、snowflake へのstaged コピーを使用しないようにすることができます.
ソース データ形式が、次のように構成された Parquet、DelimitedText、または JSON です。
Parquet 形式の場合は、圧縮コーデックが None またはSnappyです。
DelimitedText 形式の場合:
- 行区切り記号は、\r\n、または任意の 1 文字です。 行区切り記号が "\r\n" でない場合、[先頭の行を見出しとして使用] は選択されず、[スキップ行数] は指定されません。
- 圧縮の種類は、None、gzip、 bzip2、または deflate にできます。
- エンコードは既定値のままにするか、あるいは "UTF-8"、"UTF-16"、"UTF-16BE"、"UTF-32"、"UTF-32BE"、"BIG5"、"EUC-JP"、"EUC-KR"、"GB18030"、"ISO-2022-JP"、"ISO-2022-KR"、"ISO-8859-1"、"ISO-8859-2"、"ISO-8859-5"、"ISO-8859-6"、"ISO-8859-7"、"ISO-8859-8"、"ISO-8859-9"、"WINDOWS-1250"、"WINDOWS-1251"、"WINDOWS-1252"、"WINDOWS-1253"、"WINDOWS-1254"、"WINDOWS-1255" に設定されます。
- 引用符文字は、Double quote、Single quote、または No quote character (引用符なし) です。
JSON 形式の場合、直接コピーでは、コピー先の Snowflake テーブルに 1 つの列しかなく、この列のデータ型が VARIANT、OBJECT、または ARRAY であるケースのみがサポートされます。
- 圧縮の種類は、None、gzip、 bzip2、または deflate にできます。
- エンコードは既定値のままか、UTF-8 に設定します。
- 列マッピングが指定されていません。
Copy アクティビティ ソースで次の手順を実行します。
- 追加の列は指定されません。
- ソースがフォルダーの場合は、Recursively が選択されます。
- [最終変更でフィルター] および [パーティション検出を有効にする] では、プレフィックス、開始時間 (UTC)、および終了時間 (UTC) は指定されません。
Snowflake へのステージング コピー
前のセクションで説明したように、ソース データ ストアまたは形式が Snowflake COPY コマンドとネイティブに互換性がない場合は、ステージング コピーを使用します。 ワークスペースのステージング コピー、または中間Azure BLOB ストレージ インスタンスを使用した外部ステージング コピーを選択できます。 ステージング コピー機能はスループットも優れています。 Snowflake のデータ形式要件を満たすようにデータを自動的に変換します。 次に、COPY コマンドを呼び出して、Snowflake にデータを読み込みます。 最後に、BLOB ストレージから一時データをクリーンアップします。 ステージングコピーの詳細については、こちらの記事をご参照ください。
ワークスペースのステージング コピー
この機能を使用するには、[ 設定] タブに移動し、ステージング データ ストアの種類として [ワークスペース ] を選択します。 ステージング ストレージは、Fabric内の組み込みストレージです。 宛先でストレージ統合を指定するかどうかに基づいて、追加の構成を完了する必要があります。
宛先で ストレージ統合 を指定する場合は、次の手順を実行します。
-
Snowflake クラウド ストレージ統合を作成し、STORAGE_ALLOWED_LOCATIONSとして次のいずれかの OneLake URL を設定します:
azure://onelake.blob.fabric.microsoft.com/<Workspace ID>/<Pipeline/Copy job ID>/Stagingまたはazure://onelake.blob.fabric.microsoft.com/<Workspace ID>。 - 「 ストレージの場所に Snowflake アクセスを許可する 」の最初の 3 つの手順に従って Snowflake サービス プリンシパルを取得し、ワークスペースで少なくとも 共同作成者 のアクセス許可を付与します。
-
Snowflake クラウド ストレージ統合を作成し、STORAGE_ALLOWED_LOCATIONSとして次のいずれかの OneLake URL を設定します:
宛先で Storage integration を指定しない場合は、Fabric内で組み込みのステージング ストレージを直接使用できます。
外部ステージング用コピー
この機能を使用するには、Azure ストレージ アカウントを中間ステージングとして参照する Azure Blob Storage 接続 を作成します。 次に、[設定] タブに移動してステージング設定を構成します。 Azure Blob Storageステージング接続を構成するには、External を選択する必要があります。
宛先で Storage integration を指定する場合、中間ステージングAzure Blob Storageは Snowflake の外部ステージで参照した値である必要があります。 使用可能な認証のうち、組織アカウント認証を除くもので Azure Blob Storage 接続を作成し、Azure Blob Storage の Access Control (IAM) で、Snowflake サービス プリンシパルに Storage Blob Data Reader ロールを付与してください。 [設定] タブにある [ステージング設定] の [ストレージ パス] が必要です。
宛先で Storage 統合を指定しない場合、ステージングAzure Blob Storage接続では、Snowflake COPY コマンドの必要に応じて Shared Access Signature 認証を使用する必要があります。
マッピング
[マッピング] タブの構成については、「[マッピング] タブでマッピングを構成する」を参照してください。
コピー先のデータ型を編集する
[ マッピング ] タブの構成では、Snowflake が変換先として使用され、コピー先テーブルが自動的に作成されるときに、[ マッピング] の構成を除き、変換先の列の種類を編集できます。 インポート スキーマを選択した後、変換先で列の種類を指定できます。 マッピング ルールの詳細については、「 Snowflake のデータ型マッピング」を参照してください。
たとえば、 10 進 列の型を NUMBER に設定し、変換先にマッピングするときに必要に応じて精度と小数点以下桁数を調整できます。
[設定]
設定 タブの構成については、設定タブのの下で他の設定を構成するに移動します。
Snowflake のデータ型マッピング
Snowflake からデータをコピーする場合、Snowflake データ型からサービスによって内部的に使用される中間データ型への次のマッピングが使用されます。
| Snowflake のデータ型 | 中間データ型 |
|---|---|
| NUMBER(p,0) | Decimal |
| NUMBER(p,s ここで s >0) | Decimal |
| FLOAT | Double |
| VARCHAR | 糸 |
| CHAR | 糸 |
| バイナリ | バイト配列 |
| BOOLEAN | ブール値 |
| DATE | DateTime |
| TIME | TimeSpan |
| TIMESTAMP_LTZ | DateTimeOffset |
| TIMESTAMP_NTZ | DateTimeOffset |
| TIMESTAMP_TZ | DateTimeOffset |
| VARIANT | 糸 |
| OBJECT | 糸 |
| ARRAY | 糸 |
Snowflake にデータをコピーする場合、サービスによって内部的に使用される中間データ型から Snowflake データ型への次のマッピングが使用されます。
| 中間データ型 | Snowflake のデータ型 |
|---|---|
| Decimal | 数 (0 < s < p 38 < 38) |
| Byte、SByte、Int16、UInt16、Int32、UInt32、Int64、UInt64 | 数 (S = 0, 0 << 38) |
| Double、Single | FLOAT |
| 文字列、GUID | Varchar ( 0 < 長さ <= 16777216) |
| バイト配列 | バイナリ (0 < 長さ <= 8388608) |
| ブール値 | BOOLEAN |
| 日付 | DATE |
| 時間 | TIME |
| DateTime | TIMESTAMP_NTZ |
| DateTimeOffset | TIMESTAMP_TZ、TIMESTAMP_LTZ (0 <= p <= 9) |
コピー アクティビティでソース スキーマとデータ型を変換先にマップする方法については、「 スキーマとデータ型のマッピング」を参照してください。
Snowflake の自動作成テーブルの既定のデータ型マッピング
次の表では、転送先テーブルが自動的に作成されるときに、サービスによって内部的に使用される中間データ型から Snowflake データ型への既定のマッピングについて説明します。
| 中間データ型 | Snowflake のデータ型 |
|---|---|
| 文字列、GUID | VARCHAR(16777216) |
| Byte、SByte、Int16、UInt16、Int32、UInt32、Int64、UInt64 | NUMBER(38,0) |
| Decimal | NUMBER(38,18) |
| シングル、ダブル | FLOAT |
| ブール値 | BOOLEAN |
| 日付 | DATE |
| 時間 | TIME |
| DateTime | TIMESTAMP_NTZ |
| DateTimeOffset | TIMESTAMP_TZ(9) |
| バイト配列 | BINARY(8388608) |
Snowflake バージョンの違い
次の表は、さまざまなバージョンの機能の違いを示しています。
| バージョン 1.1 | バージョン 1.0 |
|---|---|
| 書き込み動作をサポートします。 | 書き込み動作 はサポートされていません。 |
| 変換先テーブルが存在しない場合の自動テーブル作成をサポートします。 | テーブルの自動作成はサポートされていません。 |
テーブルの概要
次の表に、Snowflake でのコピー アクティビティの詳細を示します。
ソース
| 名前 | 説明 | 値 | 必須 | JSON スクリプト プロパティ |
|---|---|---|---|---|
| 接続 | ソース データ ストアへの接続。 | < 使用している接続 > | はい | 接続 |
| その他の接続プロパティ | キーと値のペアのディクショナリとして提供される追加の接続プロパティ (Role など)。 詳細については、こちらの記事を参照してください。 | • 名前 • 値 |
いいえ | 接続プロパティ |
| データベース | ソースとして使用するデータベース。 | < あなたのデータベース > | はい | typeProperties ( typeProperties ->source の下)-データベース |
| クエリ を使用する | Snowflake からデータを読み取る方法。 | / | はい | / |
| テーブル | データを読み取るテーブルの名前。 | < ソース テーブルの名前> | はい | typeProperties ( typeProperties ->source の下)- スキーマ -テーブル |
| クエリ | Snowflake からデータを読み取る SQL クエリ。 | < ソース クエリの名前> | はい | クエリ |
| バージョン | 指定するバージョン。 最新の拡張機能を利用するには、最新バージョンにアップグレードすることをお勧めします。 | • 1.1 • 1.0 |
いいえ | バージョン |
| ストレージ統合 | Snowflake で作成したストレージ統合の名前を指定します。 ストレージ統合を使用するための前提となる手順については、「Snowflake ストレージ統合の構成」を参照してください。 | < あなたのストレージ統合 > | いいえ | ストレージ統合 |
| Snowflake の追加コピーオプション | 追加のコピー オプションは、キーと値の組み合わせとしてディクショナリで提供されます。 例 :MAX_FILE_SIZE、OVERWRITE。 詳細については、「Snowflake コピー オプション」を参照してください。 | • 名前 • 値 |
いいえ | 追加コピーオプション |
| 追加の Snowflake 形式のオプション | キーと値のペアのディクショナリとして COPY コマンドに指定される、追加のファイル形式オプション。 例 :DATE_FORMAT、TIME_FORMAT、TIMESTAMP_FORMAT。 詳細については、「Snowflake 形式の種類のオプション」を参照してください。 | • 名前 • 値 |
いいえ | 追加フォーマットオプション |
宛先
注記
Azure以外の Snowflake インスタンスはソースでサポートされていますが、現在、Snowflake 変換先 (Azure Data Factory のシンクとも呼ばれます) では、Azure Snowflake インスタンスのみがサポートされています。
| 名前 | 説明 | 値 | 必須 | JSON スクリプト プロパティ |
|---|---|---|---|---|
| 接続 | 宛先データストアへの接続。 | < 使用している接続 > | はい | 接続 |
| その他の接続プロパティ | キーと値のペアのディクショナリとして提供される追加の接続プロパティ (Role など)。 詳細については、こちらの記事を参照してください。 | • 名前 • 値 |
いいえ | 接続プロパティ |
| データベース | 使用先として利用するあなたのデータベース。 | < あなたのデータベース> | はい | typeProperties ( typeProperties ->sink の下)-データベース |
| テーブル | 目的のデータ テーブル。 | <宛先テーブルの名前> | はい | typeProperties ( typeProperties ->sink の下)- スキーマ -テーブル |
| バージョン | 指定するバージョン。 最新の拡張機能を利用するには、最新バージョンにアップグレードすることをお勧めします。 | • 1.1 • 1.0 |
いいえ | バージョン |
| 書き込み動作 | Snowflake にデータを書き込む方法について説明します (バージョン 1.1 以降でのみ使用できます)。 | • 挿入 (既定) • アップサート (upsert) |
いいえ | writeBehavior |
| キー列 | この列は、ソースの行がコピー先の行と一致するかどうかを判断するために使用されます。 キー列として扱う 1 つ以上の列を指定できます。 キー列が指定されていない場合は、コピー先テーブルの主キーがキー列として使用されます。 | < キー列 > | いいえ | キー ( upsertSettingsの下) |
| コピー前スクリプト | 各実行で Snowflake にデータを書き込む前に実行するCopy アクティビティの SQL クエリ。 前に読み込まれたデータをクリーンアップするには、このプロパティを使います。 | < コピー前スクリプト> | いいえ | preCopyScript |
| ストレージ統合 | Snowflake で作成したストレージ統合の名前を指定します。 ストレージ統合を使用するための前提となる手順については、「Snowflake ストレージ統合の構成」を参照してください。 | < あなたのストレージ統合 > | いいえ | ストレージ統合 |
| Snowflake の追加コピーオプション | 追加のコピー オプションは、キーと値の組み合わせとしてディクショナリで提供されます。 例 :ON_ERROR、FORCE、LOAD_UNCERTAIN_FILES。 詳細については、「Snowflake コピー オプション」を参照してください。 | • 名前 • 値 |
いいえ | 追加コピーオプション |
| 追加の Snowflake 形式のオプション | COPY コマンドに指定される追加のファイル形式オプションは、キーと値のペアを持つディクショナリとして提供されます。 例 :DATE_FORMAT、TIME_FORMAT、TIMESTAMP_FORMAT。 詳細については、「Snowflake 形式の種類のオプション」を参照してください。 | • 名前 • 値 |
いいえ | 追加フォーマットオプション |