CData SSIS Components を使用して Azure Data Lake Storage のデータを Snowflake にマイグレーション

Snowflake は、エンタープライズ BI、分析、データ管理、ガバナンスの取り組みで広く利用されている先進的なクラウドデータウェアハウスです。Snowflake は、データ共有、リアルタイムデータ処理、安全なデータストレージなどの機能を提供しており、クラウドデータ統合の一般的な選択肢となっています。

CData SSIS Components は、SQL Server Integration Services を拡張し、さまざまなソースやデスティネーションからデータを簡単にインポート・エクスポートできるようにします。

この記事では、Snowflake へのエクスポート時のデータ型マッピングの考慮事項を確認し、CData SSIS Components for Azure Data Lake Storage と Snowflake を使用してAzure Data Lake Storage のデータを Snowflake にマイグレーションする方法を説明します。

データ型マッピング

特別な考慮事項

• 大文字小文字の区別: Snowflake はデフォルトで識別子の大文字小文字を厳密に一致させるため、大文字小文字の不一致に起因する問題が発生することがよくあります。これらの問題を解決するには、CData SSIS Components for Snowflake 接続で IgnoreCase プロパティを True に設定します。このプロパティは、Snowflake の QUOTED_IDENTIFIERS_IGNORE_CASE プロパティに直接マッピングされ、Snowflake が識別子を大文字小文字を区別するかどうかを指定します。

• タイムスタンプ: Snowflake は 3 つのタイムスタンプ型をサポートしています：

  • TIMESTAMP_NTZ: このタイムスタンプは、指定された精度で UTC 時刻を格納します。ただし、すべての操作は、TIMEZONE セッションパラメータで制御される現在のセッションのタイムゾーンで実行されます。
  • TIMESTAMP_LTZ: このタイムスタンプは、指定された精度で「壁時計」時刻を格納します。すべての操作は、タイムゾーンを考慮せずに実行されます。
  • TIMESTAMP_TZ: このタイムスタンプは、関連するタイムゾーンオフセットとともに UTC 時刻を格納します。タイムゾーンが指定されていない場合、セッションのタイムゾーンオフセットが使用されます。

  デフォルトでは、CData SSIS Components は手動で設定しない限り、タイムスタンプを TIMESTAMP_NTZ として Snowflake に書き込みます。

前提条件

• Visual Studio 2022
• Visual Studio 2022 用 SQL Server Integration Services Projects 拡張機能
• CData SSIS Components for Snowflake
• CData SSIS Components for Azure Data Lake Storage

プロジェクトの作成とコンポーネントの追加

1. Visual Studio を開き、新しい Integration Services プロジェクトを作成します。
2. Control Flow 画面に新しい Data Flow Task を追加し、Data Flow Task を開きます。
3. Data Flow Task に CData Azure Data Lake Storage Source コントロールと CData Snowflake Destination コントロールを追加します。

Azure Data Lake Storage ソースの設定

以下の手順に従って、Azure Data Lake Storage への接続に必要なプロパティを指定します。

1. CData Azure Data Lake Storage Source をダブルクリックしてソースコンポーネントエディタを開き、新しい接続を追加します。
2. CData Azure Data Lake Storage Connection Manager で接続プロパティを設定し、接続をテストして保存します。

   Azure Data Lake Storage 接続プロパティの取得・設定方法

   Azure Data Lake Storage Gen2 への接続

   それでは、Gen2 Data Lake Storage アカウントに接続していきましょう。接続するには、以下のプロパティを設定します。

   • Account：ストレージアカウントの名前
   • FileSystem：このアカウントに使用されるファイルシステム名。例えば、Azure Blob コンテナの名前
   • Directory（オプション）：レプリケートされたファイルが保存される場所へのパス。パスが指定されない場合、ファイルはルートディレクトリに保存されます

   Azure Data Lake Storage Gen2への認証

   続いて、認証方法を設定しましょう。CData 製品では、5つの認証方法をサポートしています：アクセスキー（AccessKey）の使用、共有アクセス署名（SAS）の使用、Azure Active Directory OAuth（AzureAD）経由、Azure サービスプリンシパル（AzureServicePrincipal またはAzureServicePrincipalCert）経由、およびManaged Service Identity（AzureMSI）経由です。

   アクセスキー

   アクセスキーを使用して接続するには、まずADLS Gen2ストレージアカウントで利用可能なアクセスキーを取得する必要があります。

   Azure ポータルでの手順は以下のとおりです：

   1. ADLS Gen2ストレージアカウントにアクセスします
   2. 設定でアクセスキーを選択します
   3. 利用可能なアクセスキーの1つの値をAccessKey 接続プロパティにコピーします

   接続の準備ができたら、以下のプロパティを設定してください。

   • AuthScheme：AccessKey
   • AccessKey：先ほどAzure ポータルで取得したアクセスキーの値

   共有アクセス署名（SAS）

   共有アクセス署名を使用して接続するには、まずAzure Storage Explorer ツールを使用して署名を生成する必要があります。

   接続の準備ができたら、以下のプロパティを設定してください。

   • AuthScheme：SAS
   • SharedAccessSignature：先ほど生成した共有アクセス署名の値

   その他の認証方法については、 href="/kb/help/" target="_blank">ヘルプドキュメントの「Azure Data Lake Storage Gen2への認証」セクションをご確認ください。

   
3. 接続を保存後、「Table or view」を選択し、Snowflake にエクスポートするテーブルまたはビューを選択して、CData Azure Data Lake Storage Source Editor を閉じます。

Snowflake デスティネーションの設定

Azure Data Lake Storage Source を設定したら、Snowflake 接続を設定してカラムをマッピングします。

1. CData Snowflake Destination をダブルクリックしてデスティネーションコンポーネントエディタを開き、新しい接続を追加します。
2. CData Snowflake Connection Manager で接続プロパティを設定し、接続をテストして保存します。
   • コンポーネントは、Snowflake ユーザー認証、フェデレーション認証、SSL クライアント認証をサポートしています。認証するには、User と Password を設定し、AuthScheme プロパティで認証方法を選択します。Snowflake の bundle 2024_08（2024 年 10 月）を使用して作成されたアカウントからは、セキュリティ上の懸念からパスワードベースの認証がサポートされなくなりました。代わりに、OAuth や秘密鍵認証などの代替認証方法を使用してください。

   その他の便利な接続プロパティ

   • QueryPassthrough: True に設定すると、クエリは Snowflake に直接渡されます。
   • ConvertDateTimetoGMT: True に設定すると、コンポーネントはローカルマシンの時刻ではなく、日時値を GMT に変換します。
   • IgnoreCase: Snowflake が識別子を大文字小文字を区別するかどうかを指定するセッションパラメータです。デフォルト：false（大文字小文字を区別する）。
   • BindingType: DEFAULT と TEXT の 2 種類のバインディングタイプがあります。DEFAULT は、Date 型に DATE、Time 型に TIME、Timestamp_* 型に TIMESTAMP_* のバインディングタイプを使用します。TEXT は、Date、Time、Timestamp_* 型に TEXT のバインディングタイプを使用します。
   
3. 接続を保存後、Use a Table メニューでテーブルを選択し、Action メニューで Insert を選択します。
4. Column Mappings タブで、入力カラムからデスティネーションカラムへのマッピングを設定します。

プロジェクトの実行

これでプロジェクトを実行できます。SSIS Task の実行が完了すると、SQL テーブルのデータが選択したテーブルにエクスポートされます。