Documentation Oracle Cloud Infrastructure

Contrôle des pipelines (démarrage, arrêt, suppression ou réinitialisation d'un pipeline)

Après avoir créé et testé un pipeline, vous le contrôlez en le démarrant, en l'arrêtant ou en le supprimant. Vous pouvez également réinitialiser un pipeline.

Rubrique parent : Utilisation de pipelines de données pour le chargement et l'export continus

Démarrage d'un pipeline

Une fois que vous avez créé un pipeline, vous pouvez le démarrer.

Lorsqu'un pipeline est démarré, il est exécuté en continu dans un travail programmé. Le travail programmé du pipeline se répète, soit par défaut toutes les 15 minutes, soit à l'intervalle défini avec l'attribut interval.

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

    Par défaut, un travail de pipeline commence immédiatement, dès que le pipeline est démarré. Pour démarrer un travail de pipeline ultérieurement, indiquez une date ou un horodatage futur valide à l'aide du paramètre start_date.

    Pour plus d'informations, reportez-vous à START_PIPELINE Procédure.

  2. Vérifiez que le pipeline est démarré.

    Exemple :

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

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

Arrêt d'un pipeline

Utilisez STOP_PIPELINE pour arrêter un pipeline. Lorsqu'un pipeline est arrêté, aucun travail futur n'est programmé pour le pipeline.

Par défaut, les travaux en cours d'exécution se terminent lorsque vous arrêtez un pipeline. Définissez le paramètre force sur TRUE pour mettre fin aux travaux en cours d'exécution et arrêter immédiatement le pipeline.

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

    Pour plus d'informations, reportez-vous à STOP_PIPELINE Procédure.

  2. Vérifiez que le pipeline est arrêté.
    
SELECT pipeline_name, status from USER_CLOUD_PIPELINES
   WHERE pipeline_name = 'EMPLOYEE_PIPELINE';

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

Pour plus d'informations, reportez-vous à STOP_PIPELINE Procédure.

Suppression d'un pipeline

La procédure DROP_PIPELINE supprime un pipeline existant.

Si un pipeline a été démarré, il doit être arrêté pour pouvoir être supprimé. Pour plus d'informations, reportez-vous à STOP_PIPELINE Procédure.

Afin de supprimer un pipeline démarré, définissez le paramètre force sur TRUE pour mettre fin aux travaux en cours d'exécution et supprimer le pipeline immédiatement

  1. Supprimez un pipeline.
    BEGIN
  DBMS_CLOUD_PIPELINE.DROP_PIPELINE(
      pipeline_name => 'EMPLOYEE_PIPELINE'
  );
END;
/
  2. Vérifiez que le pipeline est supprimé.
    SELECT pipeline_name, status from USER_CLOUD_PIPELINES
   WHERE pipeline_name = 'EMPLOYEE_PIPELINE';

No rows selected

Pour plus d'informations, reportez-vous à DROP_PIPELINE Procédure.

Réinitialisation d'un pipeline

Utilisez l'opération de réinitialisation du pipeline pour rétablir l'état initial de l'enregistrement du pipeline.
Remarque

Vous pouvez éventuellement utiliser le pipeline de réinitialisation pour purger les données de la table de base de données associée à un pipeline de chargement ou pour enlever des fichiers de la banque d'objets pour un pipeline d'export. Cette option est généralement utilisée lorsque vous testez un pipeline lors du développement du pipeline.

La réinitialisation du pipeline fonctionne comme suit :

  • Pipeline de chargement : pour un pipeline de chargement, la réinitialisation du pipeline efface l'enregistrement des fichiers chargés par le pipeline. Lorsque vous appelez START_PIPELINE ou RUN_PIPELINE_ONCE après la réinitialisation d'un pipeline de chargement, le pipeline répète le chargement de données et inclut tous les fichiers présents dans l'emplacement de la banque d'objets.

    Lorsque purge_data est défini sur TRUE, la procédure tronque les données de la table de base de données.

  • Pipeline d'export : pour un pipeline d'export, la réinitialisation du pipeline efface les dernières données suivies dans la table de base de données. Lorsque vous appelez START_PIPELINE ou RUN_PIPELINE_ONCE après la réinitialisation d'un pipeline d'export, le pipeline répète l'export de données à partir de la table ou de la requête.

    Lorsque purge_data est défini sur TRUE, la procédure supprime les fichiers existants dans l'emplacement de banque d'objets indiqué avec l'attribut location.

Pour réinitialiser un pipeline, procédez comme suit :

  1. Arrêtez le pipeline à réinitialiser.

    Un pipeline de données doit être à l'état Arrêté pour pouvoir être réinitialisé. Pour plus d'informations, reportez-vous à STOP_PIPELINE Procédure.

  2. Réinitialisez le pipeline.
    BEGIN
     DBMS_CLOUD_PIPELINE.RESET_PIPELINE(
        pipeline_name => 'EMPLOYEE_PIPELINE',
        purge_data => TRUE);
END;
/

    Utilisez uniquement le paramètre purge_data avec la valeur TRUE si vous voulez effacer des données dans la table de base de données, pour un pipeline de chargement ou pour effacer des fichiers dans la banque d'objets pour un pipeline d'export. Cette option est généralement utilisée lorsque vous testez un pipeline lors du développement du pipeline.

    Pour plus d'informations, reportez-vous à RESET_PIPELINE Procédure.