Snowflakeデータの書き込みと読み取りを行うジョブを作成する
Snowflakeに接続するジョブを作成し、Snowflakeテーブルを作成し、テーブルにデータを書き込み、テーブルからデータを読み取り、最後にSnowflakeへの接続を閉じます。
始める前に
-
使うSnowflake Data Warehouseは起動していますが、停止状態ではありません。
-
割り当てられたSnowflakeロールには、接続するデータベースへの読み取りおよび書き込み権限があります。
これらの要件が不明な場合は、Snowflakeシステムの管理者にお問い合わせください。
手順
- Talend StudioのIntegrationパースペクティブで、[Repository] (リポジトリー)ツリービューの[Job Designs] (ジョブ設計)ノードから新規ジョブを1つ作成します。
- tSnowflakeConnectionコンポーネント、tSnowflakeRowコンポーネント、tFixedFlowInputコンポーネント、tSnowflakeOutputコンポーネント、tSnowflakeInputコンポーネント、tLogRowコンポーネント、tSnowflakeCloseコンポーネントをジョブに追加します。
- 接続を使って、tFixedFlowInputコンポーネントをtSnowflakeOutputコンポーネントに接続させます。
- 同じようにして、tSnowflakeInputコンポーネントをtLogRowコンポーネントに接続させます。
- 接続を使って、tSnowflakeConnectionコンポーネントをtSnowflakeRowコンポーネントに接続させます。
- 同じようにして、tSnowflakeRowコンポーネントをtFixedFlowInputコンポーネントに、tFixedFlowInputコンポーネントをtSnowflakeInputコンポーネントに、tSnowflakeInputコンポーネントをtSnowflakeCloseコンポーネントに接続させます。