Oracle Cloud Infrastructure-Dokumentation

Pipeline steuern (Pipeline starten, stoppen, löschen oder zurücksetzen)

Nachdem Sie eine Pipeline erstellt und getestet haben, steuern Sie sie, indem Sie die Pipeline starten, stoppen oder löschen. Sie können auch eine Pipeline zurücksetzen.

  • Pipeline starten
    Nachdem Sie eine Pipeline erstellt haben, können Sie die Pipeline starten.
  • Pipeline stoppen
    Mit STOP_PIPELINE können Sie eine Pipeline stoppen. Wenn eine Pipeline gestoppt wird, werden keine zukünftigen Jobs für die Pipeline geplant.
  • Pipeline löschen
    Mit der Prozedur DROP_PIPELINE wird eine vorhandene Pipeline gelöscht.
  • Pipeline zurücksetzen
    Mit dem Vorgang "Pipeline zurücksetzen" können Sie den Datensatz der Pipeline in den Anfangsstatus zurücksetzen.

Übergeordnetes Thema: Datenpipelines für kontinuierliches Laden und Exportieren verwenden

Pipeline starten

Nachdem Sie eine Pipeline erstellt haben, können Sie die Pipeline starten.

Wenn eine Pipeline gestartet wird, wird sie kontinuierlich in einem geplanten Job ausgeführt. Der geplante Job der Pipeline wird standardmäßig alle 15 Minuten oder in dem Intervall wiederholt, das Sie mit dem Attribut interval festgelegt haben.

  1. Starten Sie eine Pipeline.
    BEGIN
  DBMS_CLOUD_PIPELINE.START_PIPELINE(
      pipeline_name => 'EMPLOYEE_PIPELINE'
  );
END;
/

    Standardmäßig beginnt ein Pipelinejob sofort, sobald die Pipeline gestartet wird. Um einen Pipelinejob zu einem späteren Zeitpunkt zu starten, geben Sie mit dem Parameter start_date ein gültiges zukünftiges Datum oder einen gültigen Zeitstempel an.

    Weitere Informationen finden Sie unter Prozedur START_PIPELINE.

  2. Prüfen Sie, ob die Pipeline gestartet wurde.

    Beispiele:

    
SELECT pipeline_name, status from USER_CLOUD_PIPELINES
   WHERE pipeline_name = 'EMPLOYEE_PIPELINE';

PIPELINE_NAME            STATUS  
------------------------ ------- 
EMPLOYEE_PIPELINE        STARTED

Pipeline stoppen

Verwenden Sie STOP_PIPELINE, um eine Pipeline zu stoppen. Wenn eine Pipeline gestoppt wird, werden keine zukünftigen Jobs für die Pipeline geplant.

Derzeit ausgeführte Jobs werden standardmäßig abgeschlossen, wenn Sie eine Pipeline stoppen. Setzen Sie den Parameter force auf TRUE, um alle ausgeführten Jobs zu beenden und die Pipeline sofort zu stoppen.

  1. Stoppen Sie eine Pipeline.
    BEGIN
  DBMS_CLOUD_PIPELINE.STOP_PIPELINE(
      pipeline_name => 'EMPLOYEE_PIPELINE'
  );
END;
/

    Weitere Informationen finden Sie unter Prozedur STOP_PIPELINE.

  2. Prüfen Sie, ob die Pipeline gestoppt wurde.
    
SELECT pipeline_name, status from USER_CLOUD_PIPELINES
   WHERE pipeline_name = 'EMPLOYEE_PIPELINE';

PIPELINE_NAME            STATUS  
------------------------ ------- 
EMPLOYEE_PIPELINE        STOPPED

Weitere Informationen finden Sie unter Prozedur STOP_PIPELINE.

Pipeline löschen

Die Prozedur DROP_PIPELINE löscht eine vorhandene Pipeline.

Wenn eine Pipeline gestartet wurde, muss sie gestoppt werden, bevor die Pipeline gelöscht werden kann. Weitere Informationen finden Sie unter Prozedur STOP_PIPELINE.

Um eine gestartete Pipeline zu löschen, setzen Sie den Parameter force auf TRUE, um alle ausgeführten Jobs zu beenden und die Pipeline sofort zu löschen.

  1. Pipeline löschen.
    BEGIN
  DBMS_CLOUD_PIPELINE.DROP_PIPELINE(
      pipeline_name => 'EMPLOYEE_PIPELINE'
  );
END;
/
  2. Prüfen Sie, ob die Pipeline gelöscht wurde.
    SELECT pipeline_name, status from USER_CLOUD_PIPELINES
   WHERE pipeline_name = 'EMPLOYEE_PIPELINE';

No rows selected

Weitere Informationen finden Sie unter Prozedur DROP_PIPELINE.

Pipeline zurücksetzen

Mit dem Vorgang "Pipeline zurücksetzen" können Sie den Datensatz der Pipeline in den Ausgangsstatus zurücksetzen.
Hinweis

Optional können Sie mit "Pipeline zurücksetzen" Daten in der Datenbanktabelle löschen, die mit einer Ladepipeline verknüpft ist, oder Dateien im Objektspeicher für eine Exportpipeline entfernen. Normalerweise wird diese Option verwendet, wenn Sie eine Pipeline während der Pipelineentwicklung testen.

Die Reset-Pipeline funktioniert wie folgt:

  • Pipeline laden: Beim Zurücksetzen der Pipeline wird der Datensatz der von der Pipeline geladenen Dateien gelöscht. Wenn Sie START_PIPELINE oder RUN_PIPELINE_ONCE aufrufen, nachdem Sie eine Ladepipeline zurückgesetzt haben, wiederholt die Pipeline den Dataload und enthält alle Dateien, die im Objektspeicherort vorhanden sind.

    Wenn purge_data auf TRUE gesetzt ist, schneidet die Prozedur die Daten in der Datenbanktabelle ab.

  • Pipeline exportieren: Beim Zurücksetzen der Pipeline werden die zuletzt verfolgten Daten in der Datenbanktabelle gelöscht. Wenn Sie START_PIPELINE oder RUN_PIPELINE_ONCE nach dem Zurücksetzen einer Exportpipeline aufrufen, wiederholt die Pipeline den Export von Daten aus der Tabelle oder Abfrage.

    Wenn purge_data auf TRUE gesetzt ist, löscht die Prozedur vorhandene Dateien im Objektspeicherort, der mit dem Attribut location angegeben wird.

So setzen Sie eine Pipeline zurück:

  1. Stoppen Sie die Pipeline, die Sie zurücksetzen möchten.

    Eine Datenpipeline muss sich im Status "Stoppt" befinden, um sie zurückzusetzen. Weitere Informationen finden Sie unter Prozedur STOP_PIPELINE.

  2. Setzen Sie die Pipeline zurück.
    BEGIN
     DBMS_CLOUD_PIPELINE.RESET_PIPELINE(
        pipeline_name => 'EMPLOYEE_PIPELINE',
        purge_data => TRUE);
END;
/

    Verwenden Sie den Parameter purge_data nur mit dem Wert TRUE, wenn Sie Daten in der Datenbanktabelle, für eine Ladepipeline oder Dateien im Objektspeicher für eine Exportpipeline löschen möchten. Normalerweise wird diese Option verwendet, wenn Sie eine Pipeline während der Pipelineentwicklung testen.

    Weitere Informationen finden Sie unter Prozedur RESET_PIPELINE.