Pipeline-Statusinformationen anzeigen

Prüfen Sie den Pipelinestatus, und rufen Sie andere Pipelineinformationen mit den Ansichten USER_CLOUD_PIPELINES oder DBA_CLOUD_PIPELINES ab. Beispiel: Die folgende SELECT-Anweisung mit einem WHERE-Klauselprädikat in pipeline_name zeigt, dass MY_TREE_DATA eine Ladepipeline ist und die Pipeline gestartet wird:

SELECT pipeline_name, pipeline_type, status FROM USER_CLOUD_PIPELINES
   WHERE pipeline_name = 'MY_TREE_DATA';


PIPELINE_NAME PIPELINE_TYPE STATUS  
------------- ------------- ------- 
MY_TREE_DATA  LOAD          STARTED

Weitere Informationen finden Sie unter DBMS_CLOUD_PIPELINE-Views.

Pipelineattribute anzeigen

Die Pipelineattribute können überwacht werden, indem die Ansichten USER_CLOUD_PIPELINE_ATTRIBUTES oder DBA_CLOUD_PIPELINE_ATTRIBUTES abgefragt werden. Fragen Sie diese Ansichten ab, um Pipelineattributinformationen anzuzeigen.

Beispiele:

SELECT pipeline_name, attribute_name, attribute_value FROM user_cloud_pipeline_attributes
     WHERE pipeline_name = 'MY_TREE_DATA';

PIPELINE_NAME ATTRIBUTE_NAME  ATTRIBUTE_VALUE                                                                   
------------- --------------- --------------------------------------------------------------------------------- 
MY_TREE_DATA  credential_name DEF_CRED_OBJ_STORE                                                                
MY_TREE_DATA  format          {"type": "csv"}                                                                   
MY_TREE_DATA  interval        20                                                                                
MY_TREE_DATA  location        https://objectstorage.us-ashburn-1.oraclecloud.com/n/namespace/b/treetypes/o/ 
MY_TREE_DATA  priority        high                                                                              
MY_TREE_DATA  table_name      TREES

Weitere Informationen finden Sie unter DBMS_CLOUD_PIPELINE-Views.

Pipelinehistorie anzeigen

Die Ansichten USER_CLOUD_PIPELINE_HISTORY und DBA_CLOUD_PIPELINE_HISTORY zeigen den Status der ausgeführten Jobs an. Mit den Pipelinehistorienansichten können Sie den Zustand einer Pipeline überwachen und Fehler in einer ausgeführten Pipeline erkennen.

Beispiele:

SELECT pipeline_id, pipeline_name, status, error_message  FROM user_cloud_pipeline_history      
     WHERE pipeline_name = 'MY_TREE_DATA';

PIPELINE_ID PIPELINE_NAME STATUS    ERROR_MESSAGE 
----------- ------------- --------- ------------- 
          7  MY_TREE_DATA SUCCEEDED

Weitere Informationen finden Sie unter DBMS_CLOUD_PIPELINE-Views.

Pipeline-Statustabelle: Zusätzliche Überwachung für Load Pipelines

In der Pipeline-Statustabelle werden jeder Dateiname und sein Status für eine Ladepipeline angezeigt. In der Spalte STATUS_TABLE in DBA_CLOUD_PIPELINES und USER_CLOUD_PIPELINES wird der Name der Statustabelle angezeigt.

Beispiel: Die folgende SELECT-Anweisung mit einem WHERE-Klauselprädikat in der pipeline_name zeigt den Statustabellennamen für eine Pipeline an:

SELECT pipeline_name, status_table FROM user_cloud_pipelines
   WHERE pipeline_name = 'MY_TREE_DATA';

PIPELINE_NAME STATUS_TABLE
------------- --------------------
MY_TREE_DATA  PIPELINE$9$41_STATUS

Zeigen Sie die Statustabelle an, um Informationen zur Pipeline anzuzeigen, darunter:

• Die entsprechende Fehlernummer und Fehlermeldung werden in der Statustabelle aufgezeichnet, wenn ein Vorgang für eine bestimmte Datei nicht erfolgreich verläuft.

• Bei abgeschlossenen Pipelinevorgängen kann die für jeden Vorgang benötigte Zeit mit den gemeldeten Werten START_TIME und END_TIME berechnet werden.

Beispiel: Das folgende Beispiel zeigt, dass der Ladevorgang für zwei Dateien nicht erfolgreich war und eine abgeschlossen wurde:

SELECT id, name, status, error_code, error_message, sid FROM PIPELINE$9$41_STATUS;

ID NAME       STATUS    ERROR_CODE ERROR_MESSAGE                      SID 
-- ---------- --------- ---------- -------------------------------- ----- 
 1 trees1.txt FAILED         30653 ORA-30653: reject limit reached  18070 
 2 trees2.txt FAILED         30653 ORA-30653: reject limit reached  18070 
 3 trees3.txt COMPLETED                                             18070 

Pipelines zum Laden von Daten, bei denen pipeline_type 'LOAD' ist, reservieren ein ID, das in USER_LOAD_OPERATIONS und DBA_LOAD_OPERATIONS angezeigt wird. Der Wert ID in diesen Ansichten wird dem Wert OPERATION_ID der Pipeline in USER_CLOUD_PIPELINES und DBA_CLOUD_PIPELINES zugeordnet.

Um weitere Informationen für eine Ladepipeline abzurufen, fragen Sie die OPERATION_ID der Pipeline ab:

SELECT PIPELINE_NAME, OPERATION_ID FROM USER_CLOUD_PIPELINES
     WHERE PIPELINE_NAME = 'MY_TREE_DATA';

PIPELINE_NAME OPERATION_ID 
------------- ------------ 
MY_TREE_DATA            41

Fragen Sie als Nächstes entweder USER_LOAD_OPERATIONS oder DBA_LOAD_OPERATIONS mit einem WHERE-Klauselprädikat für die Spalte ID ab (mit dem Wert OPERATION_ID).

Beispiele:

SELECT ID, TYPE, LOGFILE_TABLE, BADFILE_TABLE, STATUS_TABLE FROM USER_LOAD_OPERATIONS
     WHERE ID = 41;

ID TYPE     LOGFILE_TABLE     BADFILE_TABLE     STATUS_TABLE
-- -------- ----------------- ----------------- --------------------
41 PIPELINE PIPELINE$9$41_LOG PIPELINE$9$41_BAD PIPELINE$9$41_STATUS

Diese Abfrage zeigt ID, TYPE, LOGFILE_TABLE, BADFILE_TABLE (sofern vorhanden) und STATUS_TABLE an. Sie können diese Tabellen für zusätzliche Pipeline-Ladeinformationen anzeigen.

Pipelinestatus - Tabellendetails

Pipeline-Logdatei und Tabellen mit fehlerhaften Dateien

Um die Logdatei und die ungültigen Dateinamen für eine Ladepipeline abzurufen, fragen Sie OPERATION_ID der Pipeline ab. Beispiele:

SELECT PIPELINE_NAME, OPERATION_ID FROM USER_CLOUD_PIPELINES
     WHERE PIPELINE_NAME = 'MY_TREE_DATA';

PIPELINE_NAME OPERATION_ID 
------------- ------------ 
MY_TREE_DATA            41

Fragen Sie als Nächstes entweder USER_LOAD_OPERATIONS oder DBA_LOAD_OPERATIONS mit einem WHERE-Klauselprädikat für die Spalte ID ab (mit dem Wert OPERATION_ID).

Beispiele:

SELECT ID, TYPE, LOGFILE_TABLE, BADFILE_TABLE, STATUS_TABLE FROM USER_LOAD_OPERATIONS
     WHERE ID = 41;

ID TYPE     LOGFILE_TABLE     BADFILE_TABLE     STATUS_TABLE
-- -------- ----------------- ----------------- --------------------
41 PIPELINE PIPELINE$9$41_LOG PIPELINE$9$41_BAD PIPELINE$9$41_STATUS

Diese Abfrage zeigt ID, TYPE, LOGFILE_TABLE, BADFILE_TABLE (sofern vorhanden) und STATUS_TABLE an. Sie können diese Tabellen für zusätzliche Pipeline-Ladeinformationen anzeigen.

Zeigen Sie die Tabelle mit der Pipelinelogdatei an, um ein vollständiges Log der Ladevorgänge der Pipeline anzuzeigen.

Beispiele:

SELECT * FROM PIPELINE$9$41_LOG;

Zeigen Sie die Tabelle mit fehlerhaften Pipelinedateien an, um Details zu Eingabeformatdatensätzen mit Fehlern anzuzeigen. Die fehlerhafte Dateitabelle zeigt Informationen für die Zeilen an, die Fehler beim Laden melden. Je nach den in der Logdatei-Tabelle angezeigten Fehlern und den Zeilen in der fehlerhaften Dateitabelle der Pipeline können Sie die Fehler möglicherweise korrigieren, indem Sie die format-Attributoptionen der Pipeline ändern oder die Daten in der Datei ändern, die Sie gerade laden.

Beispiele:

SELECT * FROM PIPELINE$9$41_BAD;

Weitere Informationen finden Sie unter Ladevorgänge überwachen und Fehler beheben.