Utilisation d’entités dans les projets

En utilisant des entités créées dans Data Fabric/Data Service, vous pouvez gérer et manipuler des données agrégées dans un seul object, sans avoir à travailler avec de manière granulaire. Pour ce faire, vous avez besoin de Studio v2020.8 ou d'une version ultérieure.

L'exemple suivant récupère des données sur les Jeux olympiques et les médailles des 10 premiers pays pour chaque catégorie de jeux, ainsi que les médailles qu'ils ont remportées.

Téléchargez l'exemple

Entités dans Data Fabric/Data Service

En suivant les étapes détaillées sur la page Créer une entité , nous avons créé une entité destinée à stocker des informations sur les pays participants, les dates d'ouverture et de clôture et les Méataux qu'ils ont gagnés.

L'entité Jeux olympiques (Olympics) comporte les champs suivants : Nom (Name), Nations (Nations), Dates d'ouverture (Opening) et Dates de clôture (Closing Dates). L'entité Médailles (Medals) comporte les champs suivants : Pays (Country), Or (Gold), Argent (Silver), Bronze (Brone) et le nombre total de médailles. Les deux entités sont liées l'une à l'autre par la balise Relationship (Relation).

Entités importées dans Studio

Importez l'entité dans votre workflow dans Studio.

Le workflow suivant récupère les informations d'une édition des Jeux olympiques, mappe les données aux arguments et les transmet au workflow principal.

Pour ce faire, nous avons défini un argument pour chaque type d'informations que nous collectons, résultant ainsi en cinq arguments importés.

Avec les entités, nous n'avons besoin que d'importer et d'utiliser deux arguments pour effectuer la collecte des données.

Remarque :

Les entités doivent être initialisées à l’aide du nouvel opérateur, lues depuis Data Fabric/Data Service ou transmises à un argument d’entrée dans un workflow avant l’utilisation, sinon l’attribution ou la lecture de leurs valeurs peut entraîner des erreurs.

Les données collectées sont mappées sur les deux arguments inOlympics Year et outOlympics ainsi que leurs propriétés respectives, les mêmes que les champs définis dans l'entité. En utilisant des entités, nous réduisons le nombre d'arguments requis pour transmettre des informations en mappant correctement les données à leurs champs d'entité respectifs.

Créer des enregistrements de données

Une fois les données collectées, vous pouvez utiliser l'activité Créer un enregistrement d'entité pour ajouter les informations à Data Fabric/Data Service.

Dans cet exemple, nous avons utilisé les arguments importés pour transmettre les informations collectées à Data Fabric/Data Service. Les enregistrements d'entrée et de sortie sont les valeurs de variables de type Jeux d'Orchestrator utilisés pour la transmission des données.

Après l'exécution du projet, l'enregistrement suivant a été créé dans Data Fabric/Data Service:

Créer des enregistrements avec des données structurées

Les enregistrements structurés dans une table de données peuvent être transmis à Data Fabric/Data Service à l'aide de l'activité Pour chaque ligne . Dans cet exemple, nous invoquons un workflow qui collecte des données structurées sur le nombre de classifications gagnées par chaque pays et transmet ces enregistrements à Data Fabric/Data Service.

Après l'exécution du workflow, les données suivantes sont stockées dans Data Fabric/Data Service:

La relation établie entre les entités Jeux olympiques (Olympics) et Médailles (Medals) nous permet d'utiliser l'enregistrement de données de l'une dans l'autre. Par exemple, la valeur du champ Jeux olympiques (Olympics) dans l'entité Médailles (Medals) est la même que dans l'entité associée.

Interroger les enregistrements liés

L'activité Interroger des enregistrements d'entités peut être utilisée pour extraire une liste d'enregistrements de Data Fabric/Data Service. Dans l'exemple suivant, nous utilisons cette activité pour interroger les enregistrements de données de l'entité Jeux d' robots , permettre à l'utilisateur de choisir une édition des jeux rédivergents et, à partir de l'entité Métriques , écrire le nombre de mémoires gagnées par chaque pays participant.

Pour interroger la table Jeux olympiques (Olympics), nous avons utilisé la condition Name != NULL du Générateur de requêtes (Query Builder). Elle parcourt tous les enregistrements de la colonne Nom (Name) et les génère dans la variable listOlympics à utiliser dans l'activité Boîte de dialogue (Input Dialog).

Pour afficher la liste des enregistrements sous forme d'options, nous avons utilisé l' expression Lambda listOlympics.Select(Function (o as Olympics) o.Name).ToArray dans l'activité Boîte de dialogue . Autrement, il est possible d'utiliser l'activité Pour chaque .

La sélection est mappée sur la variable selectedOlympics et utilisée dans une autre activité Rechercher des enregistrements d’entités (Query Entity Records) pour parcourir la liste des médailles remportées lors de cette édition. Cette condition a été définie à l'aide de l'option equals dans le Générateur de requêtes (Query Builder).

La requête peut être effectuée sur l'entité sélectionnée ainsi que sur les enregistrements d'entités associés.

Pagination

Data Fabric/Data Service peut potentiellement stocker un grand nombre d'enregistrements. Pour interroger uniquement un certain nombre d'enregistrements, utilisez les propriétés de pagination de l'activité Query Entities Records ( Requête d'enregistrements d'entités). La propriété Haut prend en charge un nombre maximum de 1 000, ce qui signifie que 1 000 enregistrements peuvent être interrogés à la fois.

Cet exemple interroge les cinq premiers enregistrements, puis les cinq enregistrements suivants jusqu'à ce que les derniers enregistrements de la liste soient récupérés.

Pour ce faire, la variable skip Int64 a reçu la valeur initiale de 0, puis sa valeur a été incrémentée après chaque boucle jusqu'à ce que le dernier enregistrement soit récupéré.

Une fois les cinq premières médailles récupérées, l'activité Pour chaque (For Each) est utilisée pour écrire les pays participants et le nombre de médailles qu'ils ont remportées dans le fichier Bloc-notes.

Mettre à jour le schéma de l'entité

Le scénario suivant explique les étapes permettant de mettre à jour un schéma d'entité dans Data Fabric/Data Service, puis de synchroniser les données avec Studio.

Dans Data Fabric/Data Service, accédez à l'entité Métriques , sélectionnez Créer un nouveau champ et ajoutez une nouvelle colonne HostCountry de type Oui/Non. Sélectionnez Enregistrer.

Dans Studio, sélectionnez Gérer les entités, puis le bouton Actualiser . Une modification a été détectée pour l'entité Métriques , comme illustré dans la colonne Modifications . Sélectionnez Enregistrer et l'entité est mise à jour dans Studio.

Interroger et mettre à jour des enregistrements

L'activité Mettre à jour un enregistrement d'entité peut être utilisée pour mettre à jour les enregistrements de votre workflow directement dans Data Fabric/Data Service.

Dans cet exemple, nous interrogeons certains enregistrements de l'entité Médailles (Medals) et les mettons à jour automatiquement à l'aide de l'activité susmentionnée.

Dans l'entité Médailles (Medals), le nom du pays d'accueil de chaque édition est marqué d'un astérisque. Par exemple, pour l'édition 2012, le pays hôte enregistré est la Grande-Bretagne (GBR)* dans la colonne Jeux olympiques (Olympics).

À l'aide de l'activité Rechercher des enregistrements d’entités (Query Entity Records), nous parcourons tous les enregistrements contenant l'astérisque (*), récupérons les enregistrements dans la variable listMedals et utilisons l'activité Pour chaque (For Each) pour parcourir chaque élément et ensuite attribuer la valeur Vrai (True) dans la colonne HostCountry. au pays qui a accueilli une édition.

L'activité Mettre à jour un enregistrement d'entité peut être utilisée dans de nombreux autres scénarios de transmission de données et de mise à jour des enregistrements dans Data Fabric/Data Service.