Visualizza informazioni stato pipeline

Controllare lo stato della pipeline e ottenere altre informazioni sulla pipeline utilizzando le viste USER_CLOUD_PIPELINES o DBA_CLOUD_PIPELINES. Ad esempio, l'istruzione SELECT seguente con un predicato di clausola WHERE sul file pipeline_name mostra che MY_TREE_DATA è una pipeline di caricamento e la pipeline viene avviata:

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

Per maggiori informazioni, vedere DBMS_CLOUD_PIPELINE Views.

Visualizza attributi pipeline

È possibile monitorare gli attributi della pipeline eseguendo una query sulle viste USER_CLOUD_PIPELINE_ATTRIBUTES o DBA_CLOUD_PIPELINE_ATTRIBUTES. Eseguire una query su queste viste per visualizzare le informazioni sugli attributi della pipeline.

Ad esempio:

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

Per maggiori informazioni, vedere DBMS_CLOUD_PIPELINE Views.

Visualizza cronologia pipeline

Le viste USER_CLOUD_PIPELINE_HISTORY e DBA_CLOUD_PIPELINE_HISTORY mostrano lo stato dei job in esecuzione. Utilizzare le viste della cronologia della pipeline per monitorare lo stato di una pipeline e rilevare gli errori in una pipeline in esecuzione.

Ad esempio:

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

Per maggiori informazioni, vedere DBMS_CLOUD_PIPELINE Views.

Tabella dello stato della pipeline: monitoraggio aggiuntivo per le pipeline di caricamento

La tabella dello stato della pipeline mostra ogni nome file e il relativo stato per una pipeline di caricamento. La colonna STATUS_TABLE in DBA_CLOUD_PIPELINES e USER_CLOUD_PIPELINES mostra il nome della tabella di stato.

Ad esempio, l'istruzione SELECT seguente con un predicato di clausola WHERE in pipeline_name mostra il nome della tabella di stato per una pipeline:

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

Visualizzare la tabella di stato per visualizzare informazioni sulla pipeline, incluse le seguenti:

• Il numero e il messaggio di errore rilevanti vengono registrati nella tabella di stato se un'operazione su un file specifico non riesce.

• Per le operazioni di pipeline completate, il tempo necessario per ciascuna operazione può essere calcolato utilizzando i valori riportati START_TIME e END_TIME.

Ad esempio, quanto segue mostra che l'operazione di caricamento per due file non è riuscita e una completata:

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 

Le pipeline per il caricamento dei dati, dove pipeline_type è 'LOAD', riservano un ID visualizzato in USER_LOAD_OPERATIONS e in DBA_LOAD_OPERATIONS. Il valore ID in queste viste viene mappato al valore OPERATION_ID della pipeline in USER_CLOUD_PIPELINES e DBA_CLOUD_PIPELINES.

Per ottenere ulteriori informazioni per una pipeline di caricamento, eseguire una query sul file OPERATION_ID della pipeline:

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

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

Successivamente, eseguire una query su USER_LOAD_OPERATIONS o DBA_LOAD_OPERATIONS con un predicato di clausola WHERE nella colonna ID (utilizzando il valore OPERATION_ID).

Ad esempio:

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

Questa query mostra ID, TYPE, LOGFILE_TABLE, BADFILE_TABLE se esistente e STATUS_TABLE. È possibile visualizzare queste tabelle per ulteriori informazioni sul caricamento della pipeline.

Dettagli tabella stato pipeline

File di log della pipeline e tabelle dei file errati

Per ottenere il file di log e i nomi dei file errati per una pipeline di caricamento, eseguire una query sul file OPERATION_ID della pipeline. Ad esempio:

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

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

Successivamente, eseguire una query su USER_LOAD_OPERATIONS o DBA_LOAD_OPERATIONS con un predicato di clausola WHERE nella colonna ID (utilizzando il valore OPERATION_ID).

Ad esempio:

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

Questa query mostra ID, TYPE, LOGFILE_TABLE, BADFILE_TABLE se esistente e STATUS_TABLE. È possibile visualizzare queste tabelle per ulteriori informazioni sul caricamento della pipeline.

Visualizzare la tabella dei file di log della pipeline per visualizzare un log completo delle operazioni di caricamento della pipeline.

Ad esempio:

SELECT * FROM PIPELINE$9$41_LOG;

Visualizzare la tabella dei file errati della pipeline per visualizzare i dettagli sui record dei formati di input con errori. La tabella dei file non valida mostra le informazioni per le righe che riportano gli errori durante il caricamento. A seconda degli errori visualizzati nella tabella dei file di log e delle righe mostrate nella tabella dei file errati della pipeline, è possibile correggere gli errori modificando le opzioni degli attributi format della pipeline o modificando i dati nel file che si sta caricando.

Ad esempio:

SELECT * FROM PIPELINE$9$41_BAD;

Per ulteriori informazioni, vedere Monitoraggio e risoluzione dei problemi relativi ai carichi.