Documentación de Oracle Cloud Infrastructure

Pipelines de control (inicio, parada, borrado o restablecimiento de un pipeline)

Después de crear y probar un pipeline, puede controlar un pipeline iniciando, parando o borrando el pipeline. También puede restablecer un pipeline.

  • Iniciar un pipeline
    Después de crear un pipeline, puede iniciar el pipeline.
  • Parada de un pipeline
    Utilice STOP_PIPELINE para parar un pipeline. Cuando se para un pipeline, no se programan trabajos futuros para el pipeline.
  • Borrado de un pipeline
    El procedimiento DROP_PIPELINE borra un pipeline existente.
  • Restablecer un pipeline
    Utilice la operación de restablecimiento de pipeline para borrar el registro del pipeline al estado inicial.

Tema principal: Uso de pipelines de datos para carga y exportación continuas

Iniciar un pipeline

Después de crear un pipeline, puede iniciar el pipeline.

Cuando se inicia un pipeline, el pipeline se ejecuta continuamente en un trabajo programado. El trabajo programado del pipeline se repite, por defecto cada 15 minutos o en el intervalo definido con el atributo interval.

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

    Por defecto, un trabajo de pipeline se inicia inmediatamente, tan pronto como se inicia el pipeline. Para iniciar un trabajo de pipeline posteriormente, especifique una fecha o un registro de hora futuros válidos mediante el parámetro start_date.

    Consulte START_PIPELINE Procedure para obtener más información.

  2. Verifique que el pipeline se ha iniciado.

    Por ejemplo:

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

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

Parada de un pipeline

Utilice STOP_PIPELINE para parar un pipeline. Cuando se para un pipeline, no se programan trabajos futuros para el pipeline.

Por defecto, los trabajos que se están ejecutando actualmente se completan al parar un pipeline. Defina el parámetro force en TRUE para terminar cualquier trabajo en ejecución y parar el pipeline inmediatamente.

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

    Consulte STOP_PIPELINE Procedure para obtener más información.

  2. Verifique que el pipeline está parado.
    
SELECT pipeline_name, status from USER_CLOUD_PIPELINES
   WHERE pipeline_name = 'EMPLOYEE_PIPELINE';

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

Consulte STOP_PIPELINE Procedure para obtener más información.

Borrado de un pipeline

El procedimiento DROP_PIPELINE borra un pipeline existente.

Si se ha iniciado un pipeline, se debe parar antes de que se pueda borrar el pipeline. Consulte STOP_PIPELINE Procedure para obtener más información.

Para borrar un pipeline iniciado, defina el parámetro force en TRUE para terminar cualquier trabajo en ejecución y borrar el pipeline inmediatamente

  1. Borrar un pipeline.
    BEGIN
  DBMS_CLOUD_PIPELINE.DROP_PIPELINE(
      pipeline_name => 'EMPLOYEE_PIPELINE'
  );
END;
/
  2. Verifique que el pipeline se ha borrado.
    SELECT pipeline_name, status from USER_CLOUD_PIPELINES
   WHERE pipeline_name = 'EMPLOYEE_PIPELINE';

No rows selected

Consulte DROP_PIPELINE Procedure para obtener más información.

Restablecer un pipeline

Utilice la operación de restablecimiento de pipeline para borrar el registro del pipeline al estado inicial.
Nota

Si lo desea, puede utilizar el pipeline de restablecimiento para depurar los datos de la tabla de base de datos asociada a un pipeline de carga o para eliminar archivos del almacén de objetos para un pipeline de exportación. Normalmente, esta opción se utiliza cuando está probando un pipeline durante el desarrollo del pipeline.

El restablecimiento del pipeline funciona de la siguiente manera:

  • Pipeline de carga: para un pipeline de carga, al restablecer el pipeline, se borra el registro de los archivos que está cargando el pipeline. Al llamar a START_PIPELINE o RUN_PIPELINE_ONCE después de restablecer un pipeline de carga, el pipeline repite la carga de datos e incluye todos los archivos presentes en la ubicación del almacén de objetos.

    Cuando purge_data se define en TRUE, el procedimiento trunca los datos de la tabla de base de datos.

  • Exportar pipeline: para un pipeline de exportación, al restablecer el pipeline, se borran los últimos datos con seguimiento en la tabla de base de datos. Al llamar a START_PIPELINE o RUN_PIPELINE_ONCE después de restablecer un pipeline de exportación, el pipeline repite la exportación de datos de la tabla o consulta.

    Cuando purge_data se define en TRUE, el procedimiento suprime los archivos existentes en la ubicación del almacén de objetos especificada con el atributo location.

Para restablecer un pipeline:

  1. Pare el pipeline que desea restablecer.

    Un pipeline de datos debe estar en estado parado para restablecerlo. Consulte STOP_PIPELINE Procedure para obtener más información.

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

    Utilice solo el parámetro purge_data con el valor TRUE si desea borrar datos de la tabla de la base de datos, de un pipeline de carga o de archivos en el almacén de objetos para un pipeline de exportación. Normalmente, esta opción se utiliza cuando está probando un pipeline durante el desarrollo del pipeline.

    Consulte RESET_PIPELINE Procedure para obtener más información.