Snowflake

接続に使用する Alteryx ツール

• データ出力ツール (標準ワークフロー処理)
• 接続 In-DB ツール および データストリーム入力ツール (インデータベースワークフロー処理)

データ入力ツール

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 バケットから削除します。

ODBC 接続の設定

1. ODBC データソースアドミニストレーター で Snowflake ドライバーを選択し、構成 を選択します。
2. 接続設定と資格情報を入力します。
3. OK を選択して、接続を保存します。

Snowflake JWT の設定

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

1. Snowflake の手順 (https://docs.snowflake.com/en/user-guide/key-pair-auth.html) に従って、トークンを作成します。
2. ODBC DSN の認証方式を 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 バルク接続を設定してデータを書き込む

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 Admin を選択して、いずれかを作成します。参照: ODBC / OLEDB データベース接続
3. 必要に応じて、ユーザー名 と パスワード を入力します。
4. Amazon S3 で、AWS アクセスキー と AWS シークレットキー を入力します。
5. 秘密キー暗号化 から、次の暗号化オプションを選択します。
   • 非表示: 最小限の暗号化を使用してパスワードを非表示にします。
   • マシンに対して暗号化: コンピューター上のユーザーであれば接続にフルアクセスできます。
   • ユーザーに対して暗号化: ログインしているユーザーはどのコンピューターでも接続にフルアクセスできます。
6. エンドポイント から次のいずれか 1 つのオプションを選択します。
   • 既定: 選択したバケットに基づいて Amazon がエンドポイントを決定します。
   • 特定のエンドポイント: バケットが存在する S3 地域を指定するには、カスタムエンドポイントを指定するか、以前に入力したエンドポイントから選択します。
     • S3 バケットは指定された S3 リージョン内にある必要があります。ない場合には、次のエラーメッセージが表示されます。アクセスしようとしているバケットは、指定されたエンドポイントを使用してアドレス指定をする必要があります。 というエラーが表示されます。今後のリクエストはすべてこのエンドポイントに送信してください。
     • Default を選択して、エラーウィンドウを閉じます。
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 を指定することもできます。この方式を選択すると、認証に署名 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 ポータル を参照してください。