Snowflake のデータに連携しTalend からデータに接続

Snowflake をTalend Open Studio の標準コンポーネントおよびデータソース設定ウィザードに統合。

古川えりか
コンテンツスペシャリスト

最終更新日:2022-09-15

この記事で実現できるSnowflake 連携のシナリオ

こんにちは!ドライバー周りのヘルプドキュメントを担当している古川です。



この記事では、Talend で簡単にCData JDBC Driver for Snowflake をワークフローに統合してSnowflake のデータ連携する方法を説明します。ここではCData JDBC Driver for Snowflake を使ってTalend でSnowflake をジョブフローに転送します。

JDBC データソースとしてTalend でSnowflake に接続

下記の手順に従って、Snowflake にJDBC 接続を確立します:

  1. Snowflake を新しいデータベース接続を追加:新しく接続を追加するには、[Metadata]ノードを展開し[Db Connections]ノードを右クリックして[Create Connection]をクリックします。
  2. ウィザードが表示されたら、接続に名前を入力します。
  3. 次のページで、[DB Type]メニューから[Generic JDBC]を選択してJDBC URL を入力します。

    Snowflake データベースに接続するには、認証に加えて次のプロパティを設定します。

    • Url:自身のSnowflake URL、例えばhttps://orgname-myaccount.snowflakecomputing.com
      • Legacy URL を使用する場合:https://myaccount.region.snowflakecomputing.com
      • 自身のURL を見つけるには:
        1. Snowflake UI の左下にある自身の名前をクリックします。
        2. Account ID にカーソルを合わせます。
        3. Copy Account URL アイコンをクリックして、アカウントURL をコピーします。
    • Database(オプション):によって公開されるテーブルとビューを、特定のSnowflake データベースのものに制限します。
    • Schema(オプション):本製品によって公開されるテーブルとビューを、特定のSnowflake データベーススキーマのものに制限します。

    Snowflake への認証

    本製品は、Snowflake ユーザー認証、フェデレーション認証、およびSSL クライアント認証をサポートしています。認証するには、UserPassword を設定し、AuthScheme プロパティで認証メソッドを選択します。

    キーペア

    ユーザーアカウントに定義されたプライベートキーを使用してセキュアなトークンを作成することにより、キーペア認証を使用して認証できます。この方法で接続するには、AuthSchemePRIVATEKEY に設定し、次の値を設定します。

    • User:認証に使用するユーザーアカウント。
    • PrivateKey:プライベートキーを含む.pem ファイルへのパスなど、ユーザーに使用されるプライベートキー。
    • PrivateKeyType:プライベートキーを含むキーストアの種類(PEMKEY_FILE、PFXFILE など)。
    • PrivateKeyPassword:指定されたプライベートキーのパスワード。

    その他の認証方法は、ヘルプドキュメントの「Snowflake への認証」セクションを参照してください。

    以下は一般的なJDBC URL です:

    jdbc:snowflake:User=Admin;Password=test123;Server=localhost;Database=Northwind;Warehouse=TestWarehouse;Account=Tester1;
  4. インストールディレクトリの[lib]サブフォルダ内にあるcdata.jdbc.snowflake.jar ファイルへのパスを入力します。
  5. The connection to the JDBC data source. (QuickBooks is shown.)
  6. 接続を右クリックして[Retrieve Schema]をクリックします。
  7. デフォルトオプションで[Next]をクリックしインポートしたいテーブルを選択します。
  8. デフォルトオプションでウィザードを終了します。

Products テーブルをフラットファイルに出力

下記の手順に従って、Products テーブルをフラットファイル出力コンポーネントに転送します:

  1. [Table Schemas]ノードで、テーブルをワークスペース内にドラッグします。
  2. ダイアログが表示されたら[tJDBCInput]コンポーネントを選択します。
  3. 次に、[tFileOutputDelimited]コンポーネントをPalette の[Business Intelligence]タブからワークスペース内にドラッグします。
  4. Products tJDBCInput コンポーネントを右クリックしてベクタを出力ファイルにドラッグします。 A simple transfer to a flat file. (QuickBooks is shown.)

プロジェクトを実行してデータを転送します。

関連コンテンツ

トライアル・お問い合わせ

30日間無償トライアルで、CData のリアルタイムデータ連携をフルにお試しいただけます。記事や製品についてのご質問があればお気軽にお問い合わせください。