パイプラインの編集

このページでは、Cloud Data Fusion でデプロイされたバッチ パイプラインを編集する方法について説明します。

パイプラインを編集すると、次のことが可能になります。

  • 重複の発生なしで、デプロイされたパイプラインに機能を段階的に追加します。たとえば、プラグインを追加、削除、変更してから、パイプラインを再デプロイできます。パイプラインを編集すると、同じパイプラインの新しいバージョンが作成され、それがパイプラインの急増を防ぎ、より適切に編成できます。パイプラインを複製すると、別の名前の新しいパイプラインが作成されます。
  • 編集したバージョンの履歴を保持します。
  • 古いバージョンのパイプラインを表示して復元します。
  • パイプラインの構造、構成、メタデータ、設定、コメントなど、パイプラインの任意の部分を編集します。
  • デプロイされたパイプライン用の編集された JSON ファイルをエクスポートします。

パイプラインを編集すると、Cloud Data Fusion によって新しい下書きが作成され、これが最新バージョンになります。パイプラインの名前は同じままです。パイプラインを反復的に開発します。一意の名前で重複するパイプラインは作成しません。最新バージョンでは、以前のバージョンのトリガー、パイプライン構成、ランタイム引数、メタデータ、コメント、スケジュールが保持されます。最新バージョンはパイプラインのアクティブなバージョンで、実行することも、実行をスケジュールすることもできます。

準備

  • Cloud Data Fusion では、バージョン 6.9.1 以降のデプロイされたバッチ パイプラインの編集をサポートします。最新バージョンにアップグレードするには、Cloud Data Fusion 環境をアップグレードするをご覧ください。
  • Cloud Data Fusion は、デプロイされたリアルタイム パイプラインまたはレプリケーション ジョブの編集をサポートしていません。

パイプラインを編集する

Cloud Data Fusion でデプロイされたバッチ パイプラインを編集するには、次の手順に従います。

  1. インスタンスに移動します:
    1. Google Cloud コンソールで、Cloud Data Fusion のページに移動します。

    2. Cloud Data Fusion ウェブ インターフェースでインスタンスを開くには、[Instances] をクリックしてから、[View instance] をクリックします。

      [インスタンス] に移動

  2. [List] > [Deployed] をクリックします。
  3. 編集するパイプラインに移動し、 [その他] > [編集] をクリックします。

    パイプラインの新しい下書きが [スタジオ] ページに表示されます。

  4. パイプラインを編集します。たとえば、新しい分析ノードの追加、またはソースのプロパティの編集を行います。

  5. 省略可: 後でパイプラインの編集を終了するには、[保存] をクリックします。

  6. パイプラインの編集が完了したら、[デプロイ] をクリックします。

  7. [変更の概要を入力する] ダイアログで、パイプラインに対して行った変更の説明を入力し、[デプロイ] をクリックします。デプロイされたパイプラインが [パイプライン] ページで開きます。

以前のバージョンのパイプラインを表示または復元する

以前のバージョンのバッチ パイプラインを表示またはデプロイするには、以下の手順に従います。

  1. Cloud Data Fusion インターフェースでインスタンスを開きます。
  2. [List] > [Deployed] をクリックします。
  3. パイプラインを選択します。パイプラインが [パイプライン] ページに表示されます。
  4. [履歴] をクリックします。

    バージョン履歴リストが表示されます。

  5. 省略可: 以前のバージョンのパイプラインを表示するには、[表示] をクリックします。

  6. 省略可: 古いバージョンのパイプラインを最新バージョンに復元するには、[復元] をクリックします。

    Cloud Data Fusion が新しいバージョンのパイプラインを作成し、[パイプライン] ページで開きます。最新バージョンになりました。

デプロイされたパイプラインの編集済みバージョンをエクスポートする

デプロイされたパイプラインの編集済みバージョンを JSON ファイルとしてエクスポートして、他のデベロッパーと共有したり、バージョン管理に追加したり、開発環境からテスト環境または本番環境に移動したりできます。たとえば、開発とデバッグのフェーズでパイプラインを編集した後、JSON ファイルをエクスポートし、本番環境にインポートしてデプロイします。

最新バージョンをエクスポートする

パイプラインの最新バージョンをエクスポートするには、次の手順に従います。

  1. Cloud Data Fusion インターフェースでインスタンスを開きます。
  2. [List] > [Deployed] をクリックします。
  3. エクスポートするパイプラインを選択し、 [その他] > [エクスポート] の順にクリックします。

    最新バージョンのパイプライン構成を含む JSON ファイルは、ローカルに保存されます。

以前のバージョンをエクスポートする

以前のバージョンのパイプラインをエクスポートするには、次の手順に従います。

  1. Cloud Data Fusion インターフェースでインスタンスを開きます。
  2. [List] > [Deployed] をクリックします。
  3. パイプラインを選択します。最新バージョンが [パイプライン] ページで開きます。
  4. [履歴] をクリックします。
  5. エクスポートするパイプラインのバージョンを選択して、[表示] > [操作] > [エクスポート] の順にクリックします。

デプロイされたパイプラインの編集済みバージョンをインポートする

すべてのパイプラインは Draft 状態でエクスポートされます。デプロイされたパイプラインの編集済みバージョンも Draft 状態でインポートされます。詳細については、パイプラインをインポートするをご覧ください。

編集したバージョンのパイプラインを削除する

デプロイされたパイプラインの最新バージョンを削除すると、デプロイされたパイプラインのすべてのバージョンが削除されます。下書きバージョンは削除されません。

代わりに、下書きパイプラインのバージョンは [Orphaned] ステータスになります。このステータスを解消するには、下書きパイプラインをデプロイします。Cloud Data Fusion によって、新しいパイプラインが作成されます。これが最新バージョンです。

編集済みのパイプラインのステータス

パイプラインを編集すると、[パイプラインの下書き] ページに次のステータスが表示される場合があります。

ステータス 説明
進行中 パイプラインの編集を保存しました。
親のない パイプラインの最新バージョンが削除され、関連する下書きが既存のパイプラインにもう属しなくなりました。このステータスは、誰かがエンドポイント DELETE/v3/namespaces/NAMESPACE_ID/apps/APP_ID を使用してパイプラインを削除すると発生します。
廃止 編集の進行中に、新しいバージョンがデプロイされています。このステータスは、編集が終了する前に別のデベロッパーがパイプラインをデプロイした場合に表示されます。これは、パイプライン ページに表示される [下書きが期限切れ] と同じです。

パイプラインを編集すると、[スタジオ] ページに次のステータスが表示される場合があります。

ステータス 説明
編集が進行中です 下書きパイプラインを編集しています。
孤立した下書き パイプラインの編集中に誰かが新しいバージョンをデプロイしました。

次のステップ