Utilisation d’entités dans les projets

By using entities created in Data Fabric, you can manage and manipulate data aggregated in a single object, without having to work with it in a granular way. To do so you need Studio v2020.8 or later.

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

Entities in Data Fabric

Following the steps detailed on the Creating an entity page, we created an entity for storing information about participating nations, the opening and closing dates, and the medals they won.

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 cshamps 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.

To do so we defined an argument for each type of information that we are collecting, thus resulting in five imported arguments.

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

Note: Entities must be initialized using the new operator, read from Data Fabric or passed through an input argument in a workflow before usage, otherwise assigning or reading their values can cause errors.

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

Once the data was collected, you can use the Create Entity Record activity to add the information to Data Fabric.

In this example, we used the imported arguments to pass the collected information to Data Fabric. The Input and Output records are the values of variables of type Olympics used for passing along the data.

After running the project, the following record was created in Data Fabric:

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

Records structured in a data table can be passed along to Data Fabric using the For Each Row activity. In this example, we're invoking a workflow that collects structured data on the number of medals won by each country and passes these records along to Data Fabric.

After running the workflow, the following data is stored in Data Fabric:

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

The Query Entity Records activity can be used to pull up a list of records from Data Fabric. In the following example, we use the activity to query data records from the Olympics entity, allow the user to choose an Olympics edition, and from the Medals entity write the number of medals that each participating country won.

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 (Lambda) listOlympics.Select(Function (o as Olympics) o.Name).ToArray dans l'activité Boîte de dialogue (Input Dialog). Autrement, il est possible d'utiliser l'activité Pour chaque (For Each).

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 can potentially store a large number of records. To query only a certain number of records, use the Pagination properties from the Query Entities Records activity. The Top property supports a maximum number of 1,000, this means that 1,000 records can be queried at a time.

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.

Update entity schema

The following scenario explains the steps for updating an entity schema in Data Fabric and then syncing the data with Studio.

In Data Fabric, go to the Medals entity, select Create New Field, and add a new column HostCountry of type Yes/No. Select Save.

In Studio, select on Manage Entities, and then the Refresh button. A change was detected for the Medals entity, as illustrated in the Changes column. Select Save and the entity is updated in Studio.

Interroger et mettre à jour des enregistrements

The Update Entity Record activity can be used for updating records from your workflow directly into Data Fabric.

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.

The Update Entity Record activity can be used in numerous other scenarios for passing along data and updating records in Data Fabric.