レプリケーション ジョブをアップグレードする

このページでは、Cloud Data Fusion インスタンスをアップグレードした後にレプリケーション ジョブをアップグレードする方法について説明します。

レプリケーション ジョブをバージョン 6.7.0 以降にアップグレードする

バージョン 6.7.0 以降の場合、アップグレードは自動的に行われます。レプリケーション ジョブのアップグレードは、バッチ パイプラインのアップグレードと同じ手順で行います。

レプリケーション ジョブをバックアップしてバージョン 6.6.0 以前にアップグレードする

ジョブをバックアップしてアップグレードを完了するには、次の手順を行います。

  1. レプリケーション ジョブを停止します。

  2. 世代 ID を取得するには、Cloud Data Fusion ウェブ インターフェースまたは REST API で HTTP GET() リクエストを実行します。パスは次のようになります。

    namespaces/NAMESPACE_ID/apps/REPLICATION_JOB_ID</workers/DeltaWorker

    以下を置き換えます。

    • NAMESPACE_ID: レプリケーション ジョブの名前空間の文字列名。パイプラインが Basic エディション インスタンスに属している場合、ID は常に default です。

    • REPLICATION_JOB_ID: レプリケーション ジョブの文字列名。

    インターフェース

    Cloud Data Fusion インターフェースで HTTP GET() リクエストを行うには、次の手順に従います。

    1. インスタンスに移動します:

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

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

        [インスタンス] に移動

    2. [システム管理者] > [構成] をクリックします。
    3. [Make HTTP Calls] をクリックします。
    4. [GET] を選択し、手順 2 で説明したパスを入力します。
    5. [送信] をクリックし、呼び出しレスポンスで世代 ID を確認します。

    REST API

    API で GET() リクエストを行うには、CDAP API リファレンスをご覧ください。

  3. 既存の Cloud Storage ディレクトリをバックアップします。

    1. Google Cloud コンソールでディレクトリを編集するには、[バケット] ページに移動します。

      [バケット] に移動

    2. バケット名をクリックして、[バケットの詳細] ページを開きます。バケット名は世代 ID 番号です。

    Google Cloud コンソールの Cloud Storage バケットパスは、次のような形式です。

    バケット > OFFSET_BASE_PATH > NAMESPACE_ID > REPLICATION_JOB_ID

    ジョブの offsetBasePath 値でバケットを確認できます。値を取得するには、次のパスで Cloud Data Fusion に GET() リクエストを行います。

    namespaces/NAMESPACE_ID/apps/REPLICATION_JOB_ID

  4. バッチ パイプラインをアップグレードする場合と同じ手順でアップグレードを実行します。

  5. アップグレードされたジョブには、新しい世代 ID があります。新しい ID を Cloud Storage ディレクトリ名として使用します。

  6. レプリケーション ジョブを開始します。

次のステップ