Documentazione dell'infrastruttura Oracle Cloud

Pipeline di controllo (avvio, arresto, eliminazione o reimpostazione di una pipeline)

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

  • Avviare 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.
  • Eliminare una pipeline
    La procedura DROP_PIPELINE elimina una pipeline esistente.
  • Reimpostare 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

Avvia 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. Avvia una pipeline.
    BEGIN
  DBMS_CLOUD_PIPELINE.START_PIPELINE(
      pipeline_name => 'EMPLOYEE_PIPELINE'
  );
END;
/

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

    Per ulteriori informazioni, vedere START_PIPELINE Procedure.

  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 terminare tutti i 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 Procedure.

  2. Verificare che la pipeline sia 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 Procedure.

Elimina una pipeline

La procedura DROP_PIPELINE elimina una pipeline esistente.

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

Per eliminare una pipeline avviata, impostare il parametro force su TRUE per terminare qualsiasi 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 Procedure.

Reimposta pipeline

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

Facoltativamente, è 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. In genere questa opzione viene utilizzata quando si esegue il test di una pipeline durante lo sviluppo della pipeline.

La reimpostazione della pipeline 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 la reimpostazione di 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.

    Se 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 comporta la cancellazione degli ultimi dati registrati nella tabella del 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.

    Se 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 di dati sia in stato arrestato. Per ulteriori informazioni, vedere STOP_PIPELINE Procedure.

  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. In genere questa opzione viene utilizzata quando si esegue il test di una pipeline durante lo sviluppo della pipeline.

    Per ulteriori informazioni, vedere RESET_PIPELINE Procedure.