Documentazione di Oracle Cloud Infrastructure

Controllare le pipeline (avvio, arresto, eliminazione o reimpostazione di una pipeline)

Dopo aver creato e sottoposto a test una pipeline, è possibile controllarla avviando, arrestando o rilasciando la pipeline. È inoltre possibile reimpostare una pipeline.

  • Avvia una pipeline
    Dopo aver creato una pipeline, è possibile avviarla.
  • Arresta una pipeline
    Utilizzare STOP_PIPELINE per arrestare una pipeline. Quando una pipeline viene arrestata, non viene pianificato alcun job futuro per la pipeline.
  • Elimina una pipeline
    La procedura DROP_PIPELINE elimina una pipeline esistente.
  • Reimposta una pipeline
    Utilizzare l'operazione di reimpostazione della pipeline per cancellare il record della pipeline allo stato iniziale.

Argomento padre: Utilizzo delle pipeline dati per il caricamento e l'esportazione continui

Avvio di una pipeline

Dopo aver creato una pipeline, è possibile avviarla.

Quando viene avviata una pipeline, la pipeline viene eseguita in modo continuo in un job pianificato. Il job pianificato della pipeline si ripete, per impostazione predefinita ogni 15 minuti o all'intervallo impostato con l'attributo interval.

  1. Avviare una pipeline.
    BEGIN
  DBMS_CLOUD_PIPELINE.START_PIPELINE(
      pipeline_name => 'EMPLOYEE_PIPELINE'
  );
END;
/

    Per impostazione predefinita, un job della pipeline viene avviato immediatamente non appena la pipeline viene avviata. Per avviare un job pipeline in un secondo momento, specificare una data o un indicatore orario futuri validi utilizzando il parametro start_date.

    Per ulteriori informazioni, vedere START_PIPELINE Procedura.

  2. Verificare che la pipeline sia stata avviata.

    Ad esempio:

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

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

Arresta una pipeline

Utilizzare STOP_PIPELINE per arrestare una pipeline. Quando una pipeline viene arrestata, non viene pianificato alcun job futuro per la pipeline.

Per impostazione predefinita, i job attualmente in esecuzione vengono completati quando si arresta una pipeline. Impostare il parametro force su TRUE per arrestare qualsiasi job in esecuzione e arrestare immediatamente la pipeline.

  1. Arrestare una pipeline.
    BEGIN
  DBMS_CLOUD_PIPELINE.STOP_PIPELINE(
      pipeline_name => 'EMPLOYEE_PIPELINE'
  );
END;
/

    Per ulteriori informazioni, vedere STOP_PIPELINE Procedura.

  2. Verificare che la pipeline sia stata arrestata.
    
SELECT pipeline_name, status from USER_CLOUD_PIPELINES
   WHERE pipeline_name = 'EMPLOYEE_PIPELINE';

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

Per ulteriori informazioni, vedere STOP_PIPELINE Procedura.

Elimina una pipeline

La procedura DROP_PIPELINE elimina una pipeline esistente.

Se è stata avviata, una pipeline deve essere arrestata prima di poter essere eliminata. Per ulteriori informazioni, vedere STOP_PIPELINE Procedura.

Per eliminare una pipeline avviata, impostare il parametro force su TRUE in modo da arrestare tutti i job in esecuzione ed eliminare immediatamente la pipeline

  1. Eliminare una pipeline.
    BEGIN
  DBMS_CLOUD_PIPELINE.DROP_PIPELINE(
      pipeline_name => 'EMPLOYEE_PIPELINE'
  );
END;
/
  2. Verificare che la pipeline sia stata eliminata.
    SELECT pipeline_name, status from USER_CLOUD_PIPELINES
   WHERE pipeline_name = 'EMPLOYEE_PIPELINE';

No rows selected

Per ulteriori informazioni, vedere DROP_PIPELINE Procedura.

Reimposta pipeline

Utilizzare l'operazione di reimpostazione della pipeline per cancellare il record della pipeline allo stato iniziale.
Nota

Se lo si desidera, è possibile utilizzare la pipeline di reimpostazione per rimuovere i dati nella tabella di database associata a una pipeline di caricamento o per rimuovere i file nell'area di memorizzazione degli oggetti per una pipeline di esportazione. Di solito questa opzione viene utilizzata quando si esegue il test di una pipeline durante lo sviluppo della pipeline.

La pipeline di reimpostazione funziona come indicato di seguito.

  • Carica pipeline: per una pipeline di caricamento, la reimpostazione della pipeline comporta la cancellazione del record dei file caricati dalla pipeline. Quando si chiama START_PIPELINE o RUN_PIPELINE_ONCE dopo aver reimpostato una pipeline di caricamento, la pipeline ripete il caricamento dei dati e include tutti i file presenti nella posizione dell'area di memorizzazione degli oggetti.

    Quando purge_data è impostato su TRUE, la procedura tronca i dati nella tabella del database.

  • Esporta pipeline: per una pipeline di esportazione, la reimpostazione della pipeline cancella gli ultimi dati registrati nella tabella di database. Quando si chiama START_PIPELINE o RUN_PIPELINE_ONCE dopo aver reimpostato una pipeline di esportazione, la pipeline ripete l'esportazione dei dati dalla tabella o dalla query.

    Quando purge_data è impostato su TRUE, la procedura elimina i file esistenti nella posizione dell'area di memorizzazione degli oggetti specificata con l'attributo location.

Per reimpostare una pipeline:

  1. Arrestare la pipeline che si desidera reimpostare.

    Per reimpostarla, è necessario che una pipeline dati sia in stato arrestato. Per ulteriori informazioni, vedere STOP_PIPELINE Procedura.

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

    Utilizzare il parametro purge_data con valore TRUE solo se si desidera cancellare i dati nella tabella del database, per una pipeline di caricamento o cancellare i file nell'area di memorizzazione degli oggetti per una pipeline di esportazione. Di solito questa opzione viene utilizzata quando si esegue il test di una pipeline durante lo sviluppo della pipeline.

    Per ulteriori informazioni, vedere RESET_PIPELINE Procedura.