Skip to main content

Snowflake

ドライバー設定要件

インデータベース処理の場合、 データ出力ツール でデータを書き込むときのエラーを避けるために、ドライバーにウェアハウス、スキーマ、データベースを指定します。

サポートのタイプ

読み取りと書き込み、インデータベース。

検証済み

データベースバージョン: 6.8.1

ODBCクライアントバージョン: 3.0.0.1001 64ビット

接続に使用する Alteryx ツール

  • データ出力ツール (標準ワークフロー処理)

  • 接続In-DBツールおよびデータストリーム入力ツール（インデータベースのワークフロー処理）。

インデータベースのワークフロー処理

接続In-DB ツール

Blue icon with database being plugged in.

リンク

データストリーム入力ツール

Blue icon with a stream-like object flowing into a database.

リンク

データ入力ツール

  1. [ データ入力ツール ] を選択し、[ データ入力 (1) - 設定 ] ウィンドウに移動し、[ ファイルまたはデータベースを接続 ] の下の ドロップダウンアイコン を選択します。

  2. [ データ接続 ] ウィンドウ > [ すべてのデータソース ] > [ Snowflake ] > [ ODBC ] の順に選択します。

  3. [ Snowflake ODBC接続 ] ポップアップウィンドウで、 ユーザー名 と パスワード を入力します。

  4. [ テーブルの選択またはクエリの指定 ] ウィンドウで [ テーブル ] タブ > テーブル > [ OK ] の順に選択します。

クラシックモード

クラシック モード で作業する場合は、[ オプション ] > [ ユーザー設定 ] > [ ユーザー設定の編集 ] の順に移動し、[ 入力/出力ツールのメニューオプションにクラシックモードを使用する ] チェックボックスをオンにします。

  1. クエリを指定するには、[ SQLエディター ] タブを選択し、利用可能なスペースにクエリを入力し、[ クエリをテスト ] ボタン > [ OK ] の順に選択します。

  2. [ データ出力ツール ] を選択し、[ メニュー ] > [ オプション ] の順に移動します。

  3. [ ユーザー設定 ] > [ ユーザー設定の編集 ] の順に選択し、[ 入力/出力ツールメニューオプションにクラシックモードを使用する ] チェックボックスをオンにします。

  4. [ データ出力 (1) - 設定 ] ウィンドウに移動し、[ ファイルまたはデータベースへの書き込み ] の下にある ドロップダウンアイコン を選択します。

  5. [ その他のデータベース ] > [ Snowflakeバルク... ] の順に選択します。

  6. データ入力ツール(クラシックモード) を使用して、ファイルとデータソースを選択することもできます。

クラシックモード に切り替える場合は、 データ出力ツール を新しいツールに置き換えて、[ キャンバス ] を選択するか、 F5 キーを押して表示を更新します。

データ出力ツール

テーブルと列の読み書きを完全にサポートするには、Alteryx Designerの [ テーブル/フィールド名 SQL スタイル ] オプションを [ 引用符付き ] に設定する必要があります。引用符付きにするとデータベース内のテーブルの文字がそのままの状態で選択されますが、[ なし ] を選択すると結果がすべて大文字になります。

Snowflake バルク接続を設定する前に、次の点を確認してください。

  • Snowflake バルクローダーでは、データの書き込みのみ可能です。

  • 新しい出力にデータを書き込んだ後に、Snowflake バルクローダーは、書き込まれたデータを S3 バケットから削除します。

  • テキストフィールドの最大長は16,777,216バイトです。

詳細については、 Snowflakeのドキュメント を参照してください。

注記

Designerのバージョン2023.2以降では、ワークフローをローカルでキャンセルすると、未完了のデータベース内実行がすべてキャンセルされます。これにより、データパイプラインのブロックを解除できます。この機能により、データベース全体のインタラクションが向上します。

ODBC 接続の設定

  1. ODBCデータソースアドミニストレーター でSnowflakeドライバーを選択し、[ 設定 ] を選択します。

  2. 接続設定と資格情報を入力します。

  3. [ OK ] を選択して、接続を保存します。

注記

キャメルケースのテーブルと列の読み書きを完全にサポートするには、Alteryx Designerの [ テーブル/フィールド名SQLスタイル ] オプションを [ 引用符付き ] に設定する必要があります。

キーペア認証用のSnowflake JWTの設定

ODBC ドライバーを通じて Snowflake JWT を設定する方法:

  1. Snowflake の手順 (https://docs.snowflake.com/en/user-guide/key-pair-auth.html) に従って、トークンを作成します。

  2. ODBC DSN の認証方式を SNOWFLAKE_JWT に設定します。

    Snowflake JWT

  3. Alteryx では、接続文字列はファイルの場所を指す必要があります(例: odbc:DSN=Simba_Snowflake_JWT;UID=user;PRIV_KEY_FILE=G:\AlteryxDataConnectorsTeam\OAuth project\PEMkey\rsa_key.p8;PRIV_KEY_FILE_PWD=__EncPwd1__;JWT_TIMEOUT=120 )。

    詳細については、 Snowflakeのドキュメント を参照してください。

Snowflakeバルク接続を設定してデータを書き込む

バルクロードは、DSNを使用した接続とDSNレス接続でサポートされています。

DSNレス接続文字列を使用してバルクローダーを設定するには、接続文字列を手作業で作成します。文字列には、Snowflakeへの書き込みに必要なパラメーターと、ステージングに必要なパラメーターが含まれている必要があります。Snowflakeに必要なパラメーターは、 Snowflakeのドキュメント に記載されています。ステージングに必要なパラメーターについては、以下を参照してください。

  • 接続文字列の例: snowbl:Driver= {SnowflakeDSIIDriver};Server=customerinstance.snowflakecomputing.com;Database=TEST_DB; Warehouse=TEST_WAREHOUSE;schema=PUBLIC;UID=user;PWD=password;Bucket=S3Bucket; Access=IAMAccessKey;Secret=IAMSecretKey;URL=s3.amazonaws.com;Region=us-east-1

DSNを使用してバルクローダーを設定するには、UIを使用して、次の手順に従います。

  1. [ データ出力ツール ] を選択し、[ データ出力 (1) - 設定 ] ウィンドウに移動します。

  2. [ ファイルまたはデータベースへの書き込み ] の下にある ドロップダウンアイコン を選択し、[ データ接続 ] ウィンドウに移動し、[ データソース ] タブ > [ すべてのデータソース ] > [ Snowflake ] > [ バルク ] の順に選択します。

  3. [ Snowflakeバルク接続 ] ウィンドウで、[ ローカル ] タブを選択し、[ ユーザー名 (オプション) ] および [ パスワード(オプション) ] フィールドに資格情報を入力します。[ OK ] を選択すると、[ 出力テーブル ] ポップアップウィンドウが表示されます。

  4. テーブル名 、または db.schema.tablename (完全修飾テーブル)という形式で指定された出力ファイルの テーブル(またはワークシート)の名前 を入力します。

  5. [ データ出力 (1) - 設定 ] ウィンドウの [ オプション ] の下にある [ テーブル/フィールド名SQLスタイル ] ドロップダウンの [ 引用符付き ] または [ なし ] を選択します。

  6. [ フィールドからファイル/テーブル名を取得する ] の下にある [ ファイル/テーブル名に接尾辞を追加する ] ドロップダウンのチェックボックスをオンにするかどうかを決定します。チェックボックスをオンにした場合は、ドロップダウンの選択肢から以下を選択します。

    1. ファイル/テーブル名に接尾辞を追加する

    2. ファイル/テーブル名に接頭辞を追加する

    3. ファイル/テーブル名を変更する

    4. ファイルパス全体を変更する

  7. [ ファイル/テーブル名に接尾辞を追加する ] を選択した場合、[ ファイル名またはファイル名の一部を含むフィールド ] の下で次のいずれかを選択します。

    1. SEQUENCE_CATALOG

    2. SEQUENCE_SCHEMA

    3. SEQUENCE_NAME

    4. SEQUENCE_OWNER

    5. DATA_TYPE

    6. NUMERIC_PRECISION

    7. NUMERIC_PRECISION_RADIX

    8. NUMERIC_SCALE

    9. START_VALUE

    10. MINIMUM_VALUE

    11. MAXIMUM_VALUE

    12. NEXT_VALUE

    13. INCREMENT

    14. CYCLE_OPTION

    15. CREATED

    16. LAST_ALTERED

    17. コメント

  8. テーブルのデータで使用するためにドロップダウンから選択したオプションに対して、[ 出力でフィールドを保持する ] チェックボックスをオンにするかどうかを決定します。

Snowflake バルク接続を使用してデータをステージングする方法

Snowflake バルク接続を Amazon S3 に書き込むように設定する

  1. [ データ出力 - 設定 ] ウィンドウの [ ファイルまたはデータベースへの書き込み ] を選択し、[ その他のデータベース] > [Snowflakeバルク ] の順に選択し、[ Snowflakeバルク接続 ] ウィンドウを表示します。

  2. [ データソース名 ]、または [ ODBC管理者 ] を選択して、いずれかを作成します。ODBCとOLEDBのデータベース接続を参照してください。

  3. 必要に応じて、 ユーザー名 と パスワード を入力します。

  4. Amazon S3 で、 AWS アクセスキー と AWS シークレットキー を入力します。

  5. [ シークレットキー暗号化 ] から、次の暗号化オプションを選択します。

    • 非表示 : 最小限の暗号化を使用してパスワードを非表示にします。

    • マシンに対して暗号化 : コンピューター上のユーザーであれば接続にフルアクセスできます。

    • ユーザーに対して暗号化 : ログインしているユーザーはどのコンピューターでも接続にフルアクセスできます。

  6. [ エンドポイント ] から、次のいずれかのオプションを選択します。

    • 既定 : 選択したバケットに基づいてAmazonがエンドポイントを決定します。

    • 特定のエンドポイント : バケットが存在する S3 地域を指定するには、カスタムエンドポイントを指定するか、以前に入力したエンドポイントから選択します。

      • S3 バケットは指定された S3 リージョン内にある必要があります。ない場合は、「 アクセスしようとしているバケットは、指定されたエンドポイントを使用してアドレス指定をする必要があります 」というエラーが表示されます。 今後のリクエストはすべてこのエンドポイントに送信してください。

      • [ 既定 ] を選択して、エラーウィンドウを閉じます。

  7. (オプション)既定の署名V2を上回るセキュリティにする場合は、[ 認証に署名V4を使用する ] を選択します。このオプションは、署名 V4 が必要なリージョンでは自動的に有効になります。2014 年 1 月 30 日より後に作成されたリージョンでは、署名 V4 のみがサポートされます。次のリージョンでは、署名 V4 認証が必要です。

    • アメリカ東部 (オハイオ) 地域

    • カナダ (中央) 地域

    • アジア太平洋 (ムンバイ) 地域

    • アジア太平洋 (ソウル) 地域

    • EU (フランクフルト) 地域

    • EU (ロンドン) 地域

    • 中国 (北京) 地域

  8. 暗号化された Amazon S3 バケットにアップロードする場合は、 サーバーサイド暗号化メソッド を選択します。『Amazon Simple Storage Service 開発者ガイド』を参照してください。

    • None (Default) : 暗号化方式は使用されません。

    • SSE-KMS : AWS KMS で管理されたキーでサーバーサイドの暗号化を使用します。 KMSキーID を指定することもできます。この方法を選択すると、 認証にSignature V4 を使用する ことが既定で有効になります。

  9. データオブジェクトが格納されているAWSバケットの [ バケット名 ] を入力します。

  10. [ データ出力 (1) - 設定 ] ウィンドウで、追加の [ ファイル形式オプション ] を設定します。ファイル形式オプションを参照してください。

Snowflakeバルク接続を設定してローカルストレージに書き込む

ローカルドライブにデータをステージングするときに、3 つの拡張オプションから選択できるようになりました。

[ データ出力ツール ] を選択し、[ データ出力 (1) - 設定 ] ウィンドウに移動し、[ ファイルまたはデータベースへの書き込み ] の下の [ データ接続 ] ウィンドウへ移動し、[ データソース ] タブ > [ すべてのデータソース ] > [ Snowflake ] > [ バルク ] の順に選択します。[ Snowflake バルク接続 ] ウィンドウで、[ ローカル ] タブを選択します。

  1. ユーザーステージ : ユーザーに関連付けられた、Snowflakeが提供する内部ステージ。

    1. [ ユーザー ] > [ OK ] の順に選択します。[ テーブル出力 ] ポップアップウィンドウで、 テーブル名 、または db.schema.tablename (完全修飾テーブル)という形式で指定された出力ファイル形式の テーブル(またはワークシート)の名前 を入力します。 OK を選択します。[ データ出力 (1) - 設定 ] ウィンドウの [ オプション ] の下にある [ テーブル/フィールド名SQLスタイル ] ドロップダウンの [ 引用符付き ] または [ なし ] を選択します。

  2. テーブルステージ : テーブルに関連付けられた、Snowflakeが提供する内部ステージ。

    1. [ テーブルステージ ] > [ OK ] の順に選択します。[ テーブル出力 ] ポップアップウィンドウで、 テーブル名 、または db.schema.tablename (完全修飾テーブル)という形式で指定された出力ファイル形式の テーブル(またはワークシート)の名前 を入力します。 OK を選択します。[ データ出力 (1) - 設定 ] ウィンドウの [ オプション ] の下にある [ テーブル/フィールド名SQLスタイル ] ドロップダウンの [ 引用符付き ] または [ なし ] を選択します。

      1. 内部名前付きステージ : Snowflakeデータベース で CREATE STAGE コマンドを作成して実行し、 ステージ名 をツール設定に提供します。

        注記

        最大フィールドサイズは 16 MB です。フィールドサイズの閾値を超えると、エラーがスローされ、データが書き込まれなくなります。

  3. 圧縮タイプ : 選択肢は「圧縮なし」と「Gzipで圧縮」です。

    1. 圧縮なし: ファイルはステージングされ、CSVとしてアップロードされます。

    2. GZIP で圧縮: CSV ファイルが GZIP で圧縮されます。

  4. MB単位のチャンクサイズ(1-999) : このオプションを使用すると、ローカルにステージングされる各CSVのサイズを選択できます。

    注記

    実際のファイルサイズは、もとになるフォーマットと圧縮により、選択したチャンクサイズとは異なる場合があります。

  5. スレッドの数 (1-99) : Snowflake にファイルをアップロードする際に使用するスレッドの数を指定します。この値が大きくなると、より大きなファイルのパフォーマンスが向上する場合があります。0 を入力すると、Snowflake の既定 (4) が使用されます。

ステージから、テーブルへの各 copy into には、最大 1000 個のファイルを含めることができます。ステージに 1000 個を超えるファイルがある場合、複数の copy into ステートメントが表示される場合があります。これは、ファイルを使用している copy into ステートメントへの Snowflake の要件です。詳細については、 Snowflakeのポータル を参照してください。

圧縮タイプ、MB単位でのチャンクサイズ、スレッド数オプションの詳細については、 Snowflakeのポータル を参照してください。

このセクションの内容: