機械翻訳について

パイプラインの制御(パイプラインの起動、停止、削除またはリセット)

パイプラインを作成してテストした後、パイプラインを開始、停止または削除してパイプラインを制御します。 パイプラインをリセットすることもできます。

• パイプラインの開始
  パイプラインを作成した後、パイプラインを開始できます。
• パイプラインの停止
  パイプラインを停止するには、STOP_PIPELINEを使用します。 パイプラインが停止すると、パイプラインに対して今後のジョブはスケジュールされません。
• パイプラインの削除
  プロシージャDROP_PIPELINEは、既存のパイプラインを削除します。
• パイプラインのリセット
  パイプラインのリセット操作を使用して、パイプラインのレコードを初期状態にクリアします。

パイプラインの開始

パイプラインを作成した後、パイプラインを開始できます。

パイプラインが開始されると、パイプラインはスケジュール済ジョブで継続的に実行されます。 パイプライン・スケジュール済ジョブは、デフォルトで15分ごと、またはinterval属性で設定した間隔で繰り返されます。

1. パイプラインを開始します。

   BEGIN
     DBMS_CLOUD_PIPELINE.START_PIPELINE(
         pipeline_name => 'EMPLOYEE_PIPELINE'
     );
   END;
   /

   デフォルトでは、パイプラインが開始されるとすぐにパイプライン・ジョブが開始されます。 パイプライン・ジョブを後で開始するには、start_dateパラメータを使用して有効な将来の日付またはタイムスタンプを指定します。

   詳細については、「START_PIPELINEプロシージャ」を参照してください。

2. パイプラインが開始されていることを確認します。

   たとえば:

   
   SELECT pipeline_name, status from USER_CLOUD_PIPELINES
      WHERE pipeline_name = 'EMPLOYEE_PIPELINE';
   
   PIPELINE_NAME            STATUS  
   ------------------------ ------- 
   EMPLOYEE_PIPELINE        STARTED

パイプラインの停止

パイプラインを停止するには、STOP_PIPELINEを使用します。 パイプラインが停止すると、パイプラインに対して今後のジョブはスケジュールされません。

デフォルトでは、現在実行中のジョブはパイプラインを停止すると完了します。 実行中のジョブを終了し、すぐにパイプラインを停止するには、forceパラメータをTRUEに設定します。

1. パイプラインを停止します。

   BEGIN
     DBMS_CLOUD_PIPELINE.STOP_PIPELINE(
         pipeline_name => 'EMPLOYEE_PIPELINE'
     );
   END;
   /

   詳細については、「STOP_PIPELINEプロシージャ」を参照してください。

2. パイプラインが停止していることを確認します。

   
   SELECT pipeline_name, status from USER_CLOUD_PIPELINES
      WHERE pipeline_name = 'EMPLOYEE_PIPELINE';
   
   PIPELINE_NAME            STATUS  
   ------------------------ ------- 
   EMPLOYEE_PIPELINE        STOPPED

詳細については、「STOP_PIPELINEプロシージャ」を参照してください。

パイプラインの削除

プロシージャDROP_PIPELINEは、既存のパイプラインを削除します。

パイプラインが開始されている場合は、パイプラインを削除する前にパイプラインを停止する必要があります。 詳細については、「STOP_PIPELINEプロシージャ」を参照してください。

開始されたパイプラインを削除するには、forceパラメータをTRUEに設定して実行中のジョブを終了し、すぐにパイプラインを削除

1. パイプラインを削除します。

   BEGIN
     DBMS_CLOUD_PIPELINE.DROP_PIPELINE(
         pipeline_name => 'EMPLOYEE_PIPELINE'
     );
   END;
   /

2. パイプラインが削除されたことを確認します。

   SELECT pipeline_name, status from USER_CLOUD_PIPELINES
      WHERE pipeline_name = 'EMPLOYEE_PIPELINE';
   
   No rows selected

詳細については、「DROP_PIPELINEプロシージャ」を参照してください。

パイプラインのリセット

パイプラインのリセット操作を使用して、パイプラインのレコードを初期状態にクリアします。

ノート:

オプションで、リセット・パイプラインを使用して、ロード・パイプラインに関連付けられたデータベース表のデータをパージしたり、エクスポート・パイプラインのオブジェクト・ストア内のファイルを削除できます。 通常、このオプションは、パイプライン開発中にパイプラインをテストするときに使用されます。

リセット・パイプラインは次のように動作します:

• パイプラインのロード: ロード・パイプラインの場合、パイプラインをリセットすると、パイプラインによってロードされているファイルのレコードがクリアされます。 ロード・パイプラインのリセット後にSTART_PIPELINEまたはRUN_PIPELINE_ONCEをコールすると、パイプラインはデータ・ロードを繰り返し、オブジェクト・ストアのロケーションに存在するすべてのファイルを含めます。

  purge_dataがTRUEに設定されている場合、プロシージャはデータベース表のデータを切り捨てます。

• パイプラインのエクスポート: エクスポート・パイプラインの場合、パイプラインをリセットすると、データベース表内の最後の追跡データがクリアされます。 エクスポート・パイプラインのリセット後にSTART_PIPELINEまたはRUN_PIPELINE_ONCEをコールすると、パイプラインは表または問合せからのデータのエクスポートを繰り返します。

  purge_dataがTRUEに設定されている場合、プロシージャはlocation属性で指定されたオブジェクト・ストアのロケーションにある既存のファイルを削除します。

パイプラインをリセットするには:

1. リセットするパイプラインを停止します。

   リセットするには、データ・パイプラインが停止状態である必要があります。 詳細については、「STOP_PIPELINEプロシージャ」を参照してください。

2. パイプラインをリセットします。

   BEGIN
        DBMS_CLOUD_PIPELINE.RESET_PIPELINE(
           pipeline_name => 'EMPLOYEE_PIPELINE',
           purge_data => TRUE);
   END;
   /

   データベース表のデータをクリアする場合、ロード・パイプラインの場合、またはエクスポート・パイプラインのオブジェクト・ストア内のファイルをクリアする場合は、値TRUEのpurge_dataパラメータのみを使用します。 通常、このオプションは、パイプライン開発中にパイプラインをテストするときに使用されます。

   詳細については、「RESET_PIPELINEプロシージャ」を参照してください。