Documentation Oracle Cloud Infrastructure

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

Une fois que vous avez créé et testé un pipeline, vous pouvez le contrôler 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 informations pour le chargement et l'export continus

Démarrer 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, par défaut toutes les 15 minutes ou à l'intervalle que vous définissez 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 démarre immédiatement dès que le pipeline est démarré. Pour démarrer un travail de pipeline ultérieurement, indiquez une date future ou un horodatage valide à l'aide du paramètre start_date.

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

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

    Par 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 sont terminés 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 à Procédure STOP_PIPELINE.

  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 à Procédure STOP_PIPELINE.

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é avant de pouvoir le supprimer. Pour plus d'informations, reportez-vous à Procédure STOP_PIPELINE.

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 immédiatement le pipeline

  1. Supprimer 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 à Procédure DROP_PIPELINE.

Réinitialisation d'un pipeline

Utilisez l'opération de réinitialisation de pipeline pour faire passer l'enregistrement du pipeline à l'état initial.
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 les fichiers de la banque d'objets d'un pipeline d'export. En général, cette option est utilisée lorsque vous testez un pipeline pendant son développement.

Le pipeline de réinitialisation fonctionne comme suit :

  • Charger le pipeline : pour un pipeline de chargement, la réinitialisation du pipeline efface l'enregistrement des fichiers en cours de chargement 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.

  • Exporter le pipeline : 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 des données de la table ou de la requête.

    Lorsque purge_data est défini sur TRUE, la procédure supprime les fichiers existants à 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 le réinitialiser. Pour plus d'informations, reportez-vous à Procédure STOP_PIPELINE.

  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. En général, cette option est utilisée lorsque vous testez un pipeline pendant son développement.

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