メイン コンテンツをスキップする 補完的コンテンツへスキップ

Snowflakeテーブルを作成して生成されたデータを入力

以下の手順で作成されるパイプラインの例。

手順

  1. [Connections] (接続) > [Add connection] (接続を追加)をクリックします。
  2. 開いたパネルで、作成する接続のタイプを選択します。
    ここでは、Snowflakeを選択します。
  3. [Engine] (エンジン)リストでエンジンを選択します。
  4. Snowflakeプロパティの説明に従ってSnowflake接続のプロパティ(認証タイプ)を入力し、接続をオンにして[Next] (次へ)をクリックします。
  5. データジェネレーター接続の説明(オプション)と表示名(必須)を入力し、[Validate] (検証)をクリックします。
  6. [Add dataset] (データセットを追加)をクリックし、対応するSnowflakeデータセットを作成します。
  7. [Add a new dataset] (新しいデータセットを追加)パネルで、データセットに名前を付けます。
  8. 必要なプロパティを入力し、Snowflakeテーブルをオンザフライで作成します。データベースにまだ存在しないテーブル名を入力します。
    新しいSnowflakeデータセットの設定。
  9. [Validate] (検証)をクリックしてデータセットを保存します。
  10. [Connections] (接続) > [Add connection] (接続を追加)をクリックします。
  11. データジェネレーター接続を作成します。
  12. [Add dataset] (データセットを追加)をクリックし、対応するデータセットを作成します。
  13. データセットに名前を付け、3つのフィールド(IDNAMEAGE)がある行を100行生成するために必要なプロパティを入力します。
    新しいデータセットの設定。
    1. [Rows] (行): レコードを100件生成したい場合は100と入力します。
    2. フィールドを追加:
      [Name] (名前): ID、[Type] (タイプ): 増分数値、[Min] (最小値): 1、[Increment] (増分): 1
    3. 別のフィールドを追加:
      [Name] (名前): 名前、[Type] (タイプ): ファーストネーム
    4. 別のフィールドを追加:
      [Name] (名前): 年齢、[Type] (タイプ): ランダム数値範囲、[Min] (最小値): 18、[Max] (最大値): 54
  14. [Validate] (検証)をクリックしてデータセットを保存します。
  15. [Pipelines] (パイプライン)ページで[Add pipeline] (パイプラインを追加)をクリックします。新しいパイプラインが開きます。
  16. パイプラインに意味のある名前を付けます。

    Create Snowflake table and populate it
  17. [ADD SOURCE] (ソースを追加)をクリックし、開いたパネルでData generator datasetというソースデータセットを選択します。
  18. [ADD DESTINATION] (デスティネーションを追加)項目をクリックし、開いたパネルで、デスティネーションデータセットであるSnowflakeデータセットを選択します。
  19. Snowflakeの[Configuration] (設定)パネルにある[Main] (メイン)タブで:
    1. 生成されたデータをテーブルに挿入する場合は、[Action] (アクション)リストで[Insert] (挿入)を選択します。
    2. オンザフライでテーブルを作成する場合は、[Create table if not exists] (テーブルが存在しない場合は作成)オプションを有効にします。
    3. 変更を保存します。
  20. Talend Cloud Pipeline Designerの上部ツールバーで[Run] (実行)ボタンをクリックするとパネルが開き、実行プロファイルを選択できるようになります。
  21. リストで実行プロファイルを選択し(詳細は実行プロファイルをご覧ください)、[Run] (実行)をクリックしてパイプラインを実行します。

タスクの結果

パイプラインは実行中となり、Snowflakeテーブルがオンザフライで作成され、100件の生成レコードが入力されます。

このページは役に立ちましたか?

このページまたはコンテンツにタイポ、ステップの省略、技術的エラーなどの問題が見つかった場合はお知らせください。