Documentation sur Oracle Cloud Infrastructure

Contrôler les pipelines (démarrer, arrêter, supprimer ou réinitialiser un pipeline)

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

  • Démarrer un pipeline
    Après avoir créé un pipeline, vous pouvez le démarrer.
  • Arrêter un pipeline
    Utilisez STOP_PIPELINE pour arrêter un pipeline. Lorsqu'un pipeline est arrêté, aucune tâche future n'est programmée pour le pipeline.
  • Supprimer un pipeline
    La procédure DROP_PIPELINE supprime un pipeline existant.
  • Réinitialiser un pipeline
    Utilisez l'opération de réinitialisation de pipeline pour effacer l'enregistrement du pipeline à l'état initial.

Rubrique parent : Utilisation de pipelines de données pour le chargement et l'exportation en continu

Démarrer un pipeline

Après avoir créé un pipeline, vous pouvez le démarrer.

Lorsqu'un pipeline est démarré, il s'exécute en continu dans une tâche programmée. La tâche programmée 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, une tâche de pipeline commence immédiatement, dès que le pipeline est démarré. Pour démarrer une tâche de pipeline ultérieurement, spécifiez une date ou un horodatage futur valide à l'aide du paramètre start_date.

    Pour plus d'informations, voir ProcédureSTART_PIPELINE.

  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êter un pipeline

Utilisez STOP_PIPELINE pour arrêter un pipeline. Lorsqu'un pipeline est arrêté, aucune tâche future n'est programmée pour le pipeline.

Par défaut, les tâches en cours d'exécution sont terminées lorsque vous arrêtez un pipeline. Réglez le paramètre force à TRUE pour mettre fin aux tâches 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, voir ProcédureSTOP_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, voir ProcédureSTOP_PIPELINE.

Supprimer 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 abandonné. Pour plus d'informations, voir ProcédureSTOP_PIPELINE.

Pour supprimer un pipeline démarré, réglez le paramètre force à TRUE pour mettre fin aux tâches 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 a été abandonné.
    SELECT pipeline_name, status from USER_CLOUD_PIPELINES
   WHERE pipeline_name = 'EMPLOYEE_PIPELINE';

No rows selected

Pour plus d'informations, voir ProcédureDROP_PIPELINE.

Réinitialiser un pipeline

Utilisez l'opération de réinitialisation de pipeline pour effacer l'enregistrement du pipeline à l'état initial.
Note

Vous pouvez éventuellement utiliser le pipeline de réinitialisation pour épurer les données de la table de base de données associée à un pipeline de chargement ou pour supprimer les fichiers du magasin d'objets pour un pipeline d'exportation. Cette option est généralement utilisée lorsque vous testez un pipeline lors du développement d'un 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 en cours de chargement par le pipeline. Lorsque vous appelez START_PIPELINE ou RUN_PIPELINE_ONCE après avoir réinitialisé un pipeline de chargement, celui-ci répète le chargement de données et inclut tous les fichiers présents dans l'emplacement du magasin d'objets.

    Lorsque purge_data est réglé à TRUE, la procédure tronque les données de la table de base de données.

  • Pipeline d'exportation : Pour un pipeline d'exportation, 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 avoir réinitialisé un pipeline d'exportation, le pipeline répète l'exportation des données à partir de la table ou de l'interrogation.

    Lorsque purge_data est réglé à TRUE, la procédure supprime les fichiers existants dans l'emplacement du magasin d'objets spécifié avec l'attribut location.

Pour réinitialiser un pipeline :

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

    Un pipeline de données doit être à l'état Arrêté pour être réinitialisé. Pour plus d'informations, voir ProcédureSTOP_PIPELINE.

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

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

    Pour plus d'informations, voir ProcédureRESET_PIPELINE.