Documentação do Oracle Cloud Infrastructure

Controlar pipelines (iniciar, interromper, eliminar ou redefinir um pipeline)

Depois de criar e testar um pipeline, você o controla iniciando, interrompendo ou eliminando. Você também pode redefinir um pipeline.

  • Iniciar um Pipeline
    Depois de criar um pipeline, você poderá iniciá-lo.
  • Interromper um Pipeline
    Use STOP_PIPELINE para interromper um pipeline. Quando um pipeline é interrompido, nenhum job futuro é programado para o pipeline.
  • Eliminar um Pipeline
    O procedimento DROP_PIPELINE elimina um pipeline existente.
  • Redefinir um Pipeline
    Use a operação de redefinição de pipeline para limpar o registro do pipeline para o estado inicial.

Tópico principal: Usando pipelines de dados para carga e exportação contínuas

Iniciar um Pipeline

Depois de criar um pipeline, você poderá iniciá-lo.

Quando um pipeline é iniciado, ele é executado continuamente em um job programado. O job programado do pipeline se repete, por padrão a cada 15 minutos ou no intervalo definido com o atributo interval.

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

    Por padrão, um job de pipeline começa imediatamente, assim que o pipeline é iniciado. Para iniciar um job de pipeline posteriormente, especifique uma data ou timestamp futuro válido usando o parâmetro start_date.

    Consulte START_PIPELINE Procedimento para obter mais informações.

  2. Verifique se o pipeline foi iniciado.

    Por exemplo:

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

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

Interromper um Pipeline

Use STOP_PIPELINE para interromper um pipeline. Quando um pipeline é interrompido, nenhum job futuro é programado para o pipeline.

Por padrão, os jobs em execução no momento são concluídos quando você interrompe um pipeline. Defina o parâmetro force como TRUE para encerrar qualquer job em execução e interromper o pipeline imediatamente.

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

    Consulte STOP_PIPELINE Procedimento para obter mais informações.

  2. Verifique se o pipeline foi interrompido.
    
SELECT pipeline_name, status from USER_CLOUD_PIPELINES
   WHERE pipeline_name = 'EMPLOYEE_PIPELINE';

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

Consulte STOP_PIPELINE Procedimento para obter mais informações.

Eliminar um Pipeline

O procedimento DROP_PIPELINE elimina um pipeline existente.

Se um pipeline tiver sido iniciado, ele deverá ser interrompido para que possa ser eliminado. Consulte STOP_PIPELINE Procedimento para obter mais informações.

Para eliminar um pipeline que foi iniciado, defina o parâmetro force como TRUE para encerrar qualquer job em execução e eliminar o pipeline imediatamente

  1. Elimine um pipeline.
    BEGIN
  DBMS_CLOUD_PIPELINE.DROP_PIPELINE(
      pipeline_name => 'EMPLOYEE_PIPELINE'
  );
END;
/
  2. Verifique se o pipeline foi eliminado.
    SELECT pipeline_name, status from USER_CLOUD_PIPELINES
   WHERE pipeline_name = 'EMPLOYEE_PIPELINE';

No rows selected

Consulte DROP_PIPELINE Procedimento para obter mais informações.

Redefinir um Pipeline

Use a operação de redefinição do pipeline para limpar o registro do pipeline para o estado inicial.
Observação

Opcionalmente, você pode usar o pipeline de redefinição para expurgar dados na tabela de banco de dados associada a um pipeline de carga ou para remover arquivos no armazenamento de objetos de um pipeline de exportação. Geralmente, essa opção é usada quando você está testando um pipeline durante o desenvolvimento do pipeline.

O pipeline de redefinição opera da seguinte forma:

  • Carregar Pipeline: Para um pipeline de carga, a redefinição do pipeline limpa o registro dos arquivos que estão sendo carregados pelo pipeline. Quando você chama START_PIPELINE ou RUN_PIPELINE_ONCE após redefinir um pipeline de carga, o pipeline repete o carregamento de dados e inclui todos os arquivos presentes no local do armazenamento de objetos.

    Quando purge_data é definido como TRUE, o procedimento trunca os dados na tabela de banco de dados.

  • Exportar Pipeline: Para um pipeline de exportação, a redefinição do pipeline limpa os últimos dados rastreados na tabela do banco de dados. Quando você chama START_PIPELINE ou RUN_PIPELINE_ONCE após redefinir um pipeline de exportação, o pipeline repete a exportação de dados da tabela ou consulta.

    Quando purge_data é definido como TRUE, o procedimento exclui arquivos existentes no local de armazenamento de objetos especificado com o atributo location.

Para redefinir um pipeline:

  1. Interrompa o pipeline que você deseja redefinir.

    Um pipeline de dados deve estar no estado interrompido para redefini-lo. Consulte STOP_PIPELINE Procedimento para obter mais informações.

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

    Só use o parâmetro purge_data com o valor TRUE se quiser limpar dados em sua tabela de banco de dados, para um pipeline de carga ou limpar arquivos no armazenamento de objetos para um pipeline de exportação. Geralmente, essa opção é usada quando você está testando um pipeline durante o desenvolvimento do pipeline.

    Consulte RESET_PIPELINE Procedimento para obter mais informações.