Documentation sur Oracle Cloud Infrastructure

Création d'un flux de données

Créez un flux de données dans un projet ou un dossier du service d'intégration de données. Un flux de données est un programme visuel qui représente le flux des données provenant de ressources de données sources, telles qu une base de données ou un fichier plat, vers des ressources de données cibles, telles qu un lac de données ou un entrepôt de données.

Data Integration inclut un projet par défaut pour vous aider à démarrer. Pour créer d'autres projets ou dossiers, voir Projets et dossiers.

    1. Dans la section Flux de données du projet ou du dossier dans lequel vous voulez créer un flux de données, sélectionnez Créer un flux de données. Si vous avez besoin d'aide pour trouver la section Flux de données dans la page des détails d'un projet ou d'un dossier, voir Liste des flux de données.

      Data Integration affiche le concepteur dans un onglet. Le canevas est vide. Le panneau Opérateurs et le panneau Propriétés sont ouverts. Pour plus d'informations sur les opérateurs, voir Utilisation des opérateurs de flux de données.

    2. Dans l'onglet Détails du panneau Propriétés, entrez un nom et une description facultative pour le flux de données.

      L'identificateur est une valeur générée par le système en fonction du nom. Vous pouvez modifier la valeur mais, après avoir créé et enregistré le flux de données, vous ne pouvez pas mettre à jour l'identificateur.

    3. (Facultatif) Pour le champ Projet ou dossier, cliquez sur Sélectionner et sélectionnez un autre projet ou dossier dans lequel enregistrer le flux de données.
    4. Faites glisser les opérateurs de flux de données du panneau Opérateurs vers le canevas pour concevoir le flux de données.

      Pour être valide, un flux de données doit avoir au moins un opérateur Source et un opérateur Cible. Bien que le service d'intégration de données prenne en charge plusieurs opérateurs Cible dans un flux de données, un opérateur Cible ne peut avoir qu'un seul port entrant.

      Conseil

      Lorsque vous utilisez un opérateur de tri, appliquez-le après avoir appliqué d'autres opérateurs. L'application de l'opérateur de tri immédiatement avant l'opérateur Cible garantit que les données de la cible sont insérées dans l'ordre de tri souhaité.

    5. Pour dupliquer un opérateur Source, Cible ou Expression, cliquez avec le bouton droit de la souris sur l'icône de l'opérateur et sélectionnez Publier. Sélectionnez ensuite l'opérateur dupliqué et renommez l'identificateur dans le panneau Propriétés.

      Si l'opérateur initial est connecté à d'autres opérateurs, les connexions ne sont pas copiées vers l'opérateur dupliqué.

    6. Connectez les opérateurs du canevas :

      • Passez le pointeur de la souris sur un opérateur jusqu'à ce que le connecteur (petit cercle) apparaisse sur le côté droit de l'opérateur, puis faites glisser le connecteur vers l'opérateur suivant auquel vous souhaitez vous connecter. La connexion est valide lorsqu'une ligne relie les deux opérateurs.

        Note

        Une ligne de connexion symbolise la façon dont les données circulent d'un noeud à l'autre. Bien que vous puissiez faire glisser un connecteur visible d'un objet à un autre, vous ne pouvez pas avoir plus d'une ligne de connexion entrante vers un opérateur Filtre, expression, agréger, distinct, tri et cible.

      • Pour insérer un opérateur entre deux opérateurs connectés, cliquez avec le bouton droit de la souris sur la ligne de connexion et utilisez le menu Insérer.

      • Pour supprimer une connexion, cliquez sur la ligne avec le bouton droit de la souris et sélectionnez Supprimer.

    7. Dans l'onglet Détails du panneau Propriétés, configurez les propriétés de base et requises pour chaque opérateur.
    8. Pour enregistrer le flux de données pour la première fois, sélectionnez l'un des boutons suivants :
      • Créer : Crée et enregistre le flux de données. Vous pouvez poursuivre la création et la modification du flux de données dans le concepteur.
      • Créer et fermer : Permet de créer et d'enregistrer le flux de données, de fermer le concepteur et de retourner à la liste Flux de données dans la page des détails du projet ou du dossier.
    9. Enregistrez périodiquement pendant que vous travaillez dans le concepteur en sélectionnant l'un des boutons suivants :
      • Enregistrer : Valide les modifications depuis le dernier enregistrement. Vous pouvez poursuivre la modification après l'enregistrement.
      • Enregistrer et fermer : Valide les modifications, ferme le concepteur et vous ramène à la liste Flux de données dans la page des détails du projet ou du dossier.
      • Enregistrer sous : Valide les modifications (depuis le dernier enregistrement) et enregistre une copie, au lieu de remplacer le flux de données courant. Vous pouvez indiquer un nom pour la copie et en sélectionner un autre, ou l'enregistrer dans le même projet ou dossier que le flux de données courant.
    10. Validez le flux de données pour vérifier les avertissements ou les erreurs qui pourraient causer des problèmes lors de l'exécution. Dans la barre d'outils du concepteur, sélectionnez Valider.

      Le service d'intégration de données affiche le panneau Validation globale. Si des avertissements ou des erreurs sont détectés, sélectionnez un nom d'identificateur dans la liste des problèmes pour mettre l'opérateur avec cet avertissement ou cette erreur en évidence sur le canevas.

    11. Lorsque vous avez terminé de travailler dans le flux de données, sélectionnez Créer et fermer ou Enregistrer et fermer.
    Pour exécuter le flux de données, créez une tâche d'intégration. Voir Création d'une tâche d'intégration.

  • Utilisez la commande oci data-integration data-flow create et les paramètres requis pour créer un flux de données :

    oci data-integration data-flow create [OPTIONS]

    Pour la liste complète des indicateurs et des options de variable pour les commandes de l'interface de ligne de commande, voir Informations de référence sur la ligne de commande.

  • Exécutez l'opération CreateDataFlow pour créer un flux de données.