Oracle Cloud Infrastructure-Dokumentation

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

Nachdem Sie eine Pipeline erstellt und getestet haben, steuern Sie eine Pipeline, 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
    Im Verfahren 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 anfänglichen Status zurücksetzen.

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

Pipeline starten

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

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

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

    Standardmäßig wird ein Pipelinejob sofort gestartet, 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.

    Beispiel:

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

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

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.

Standardmäßig werden derzeit ausgeführte Jobs 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. Eine Pipeline stoppen.
    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 ausgeführte 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 anfänglichen Status zurücksetzen.
Hinweis

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

Die Zurücksetzungspipeline funktioniert wie folgt:

  • Pipeline laden: Beim Zurücksetzen der Pipeline wird der Datensatz der von der Pipeline geladenen Dateien gelöscht. Wenn Sie nach dem Zurücksetzen einer Ladepipeline START_PIPELINE oder RUN_PIPELINE_ONCE aufrufen, wiederholt die Pipeline den Dataload und enthält alle Dateien, die im Objektspeicherverzeichnis vorhanden sind.

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

  • Pipeline exportieren: Wenn Sie eine Exportpipeline zurücksetzen, 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 ist.

So setzen Sie eine Pipeline zurück:

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

    Eine Datenpipeline muss den Status "Gestoppt" aufweisen, um sie zurückzusetzen. Weitere Informationen finden Sie unter Prozedur STOP_PIPELINE.

  2. Zurücksetzen der Pipeline.
    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 Pipeline-Entwicklung testen.

    Weitere Informationen finden Sie unter Prozedur RESET_PIPELINE.