Verwenden von Entitäten in Projekten

Mithilfe von in Data Fabric erstellten Entitäten können Sie Daten, die in einem einzigen Objekt aggregiert sind, verwalten und manipulieren, ohne im Einzelnen mit ihnen zu arbeiten. Dazu benötigen Sie Studio v2020.8 oder höher.

Im folgenden Beispiel werden Daten zu Olympischen Spielen und Medaillen für die 10 besten Länder für jede Art von Wettkampf abgerufen, zusammen mit den Medaillen, die sie gewonnen haben.

Beispiel herunterladen

Entitäten in Data Fabric

Gemäß den auf der Seite Erstellen einer Entität beschriebenen Schritte haben wir eine Entität erstellt, um Informationen zu den teilnehmenden Ländern, den Eröffnungs- und Schlussterminen und den gewonnenen Medaillen zu speichern.

Die Entität Olympische Spiele verfügt über folgende Felder: Name, Nation, Eröffnungstermine und Schlusstermine. Die Entität Medaillen verfügt über folgende Felder: Land, Gold, Silver, Bronze und die Gesamtzahl aller Medaillen. Die beiden Entitäten sind mit dem Tag Beziehung miteinander verknüpft.

In Studio importierte Entitäten

Importieren Sie die Entität in Ihren Workflow in Studio.

Der folgende Workflow extrahiert Informationen über ein bestimmtes Austragungsjahr der Olympiade, ordnet Daten Argumenten zu und leitet sie an den Hauptworkflow weiter.

Dazu haben wir für jeden Informationstyp, den wir sammeln, ein Argument definiert, was insgesamt fünf importierte Argumente ergibt.

Mithilfe von Entitäten müssen wir nur zwei Argumente importieren und mit ihnen arbeiten, um die Daten zu sammeln.

Hinweis: Entitäten müssen mit dem new-Operator initialisiert, aus Data Fabric gelesen oder vor der Verwendung durch ein Eingabeargument in einen Workflow übermittelt werden. Andernfalls kann das Zuweisen oder Lesen ihrer Werte zu Fehlern führen.

Die gesammelten Daten werden den beiden Argumenten inOlympics Year und outOlympics und deren jeweiligen Eigenschaften zugeordnet, denselben wie die in der Entität definierten Felder. Durch die Verwendung von Entitäten reduzieren wir die Anzahl der Argumente, die für die Weitergabe von Informationen erforderlich sind, indem wir Daten ordnungsgemäß den jeweiligen Entitätsfeldern zuordnen.

Datensätze erstellen

Sobald die Daten gesammelt wurden, können Sie die Aktivität Create Entity Record verwenden, um die Informationen zu Data Fabric hinzuzufügen.

In diesem Beispiel haben wir die importierten Argumente verwendet, um die gesammelten Informationen an Data Fabric weiterzuleiten. Die Datensätze Eingabe und Ausgabe sind die Werte von Variablen des Typs Olympische Spiele , die für die Übermittlung der Daten verwendet werden.

Nach dem Ausführen des Projekts wurde der folgende Datensatz in Data Fabric erstellt:

Datensätze mit strukturierten Daten erstellen

Datensätze, die in einer Datentabelle strukturiert sind, können mit der Aktivität For Each Row an Data Fabric übergeben werden. In diesem Beispiel rufen wir einen Workflow auf, der strukturierte Daten zu der Anzahl der von den einzelnen Ländern gewonnenen Medaillen sammelt und diese Datensätze an Data Fabric weiterleitet.

Nachdem der Workflow ausgeführt wird, werden die folgenden Daten in Data Fabric gespeichert:

Die zwischen den Entitäten Olympische Spiele und Medaillengesetzte Beziehung ermöglicht es uns, den Datensatz der einen Entität in der anderen zu verwenden. Zum Beispiel ist der Wert des Feldes Olympische Spiele innerhalb der Entität Medaillen derselbe wie in der verbundenen Entität.

Zugehörige Datensätze abfragen

Die Aktivität Query Entity Records kann verwendet werden, um eine Liste von Datensätzen aus Data Fabric abzurufen. Im folgenden Beispiel verwenden wir die Aktivität, um Datensätze von der Entität Olympische Spiele abzufragen, dem Benutzer die Möglichkeit zu geben, ein Austragungsjahr der Olympiade auszuwählen, und über die Entität Medaillen die Anzahl der Medaillen anzuzeigen, die jedes teilnehmende Land gewonnen hat.

Für die Abfrage der Tabelle Olympische Spiele haben wir die Bedingung Name != NULL aus dem Abfragegeneratorverwendet. Dadurch werden alle Datensätze aus der Spalte Name durchsucht und in der Variable listOlympics ausgegeben, die in der Aktivität Input Dialog verwendet werden soll.

Um die Liste der Datensätze als Optionen anzuzeigen, haben wir den folgenden Lambda-Ausdruck in der Aktivität Input Dialogverwendet: listOlympics.Select(Function (o as Olympics) o.Name).ToArray. Alternativ kann die Aktivität For Each verwendet werden.

Die Auswahl wird der Variable selectedOlympics zugeordnet und in einer anderen Aktivität vom Typ Query Entity Records verwendet, um die Liste der gewonnenen Medaillen in diesem bestimmten Austragungsjahr zu durchsuchen. Diese Bedingung wurde mit der Option equals im Abfragegenerator festgelegt.

Die Abfrage kann für die ausgewählte Entität und auch für zugehörige Entitätsdatensätze ausgeführt werden.

Paginierung (Pagination)

Data Fabric kann gegebenenfalls eine große Anzahl von Datensätzen speichern. Möchten Sie nur eine bestimmte Anzahl von Datensätzen abfragen, können Sie die Paginierungs- Eigenschaften aus der Aktivität Query Entities Records verwenden. Die Eigenschaft Top unterstützt eine maximale Anzahl von 1.000. Das bedeutet, dass 1.000 Datensätze gleichzeitig abgefragt werden können.

In diesem Beispiel werden die ersten fünf Datensätze und dann die nächsten fünf Datensätze abgefragt, bis die letzten Datensätzen der Liste erfasst wurden.

Dazu wurde der Variable Int64 skip der ursprüngliche Wert von 0 zugewiesen. Dann wird ihr Wert nach jeder Schleife erhöht, bis der letzte Datensatz erfasst wurde.

Nachdem die ersten fünf Medaillen erfasst wurden, wird die Aktivität For Each verwendet, um die teilnehmenden Länder und die Anzahl der gewonnenen Medaillen in die Notepad-Datei zu schreiben.

Aktualisieren Sie das Entitätsschema

Im folgenden Szenario werden die Schritte erläutert, um ein Entitätsschema in Data Fabric zu aktualisieren und dann die Daten mit Studio zu synchronisieren.

Wechseln Sie in Data Fabric zur Entität Medaillen , wählen Sie Neues Feld erstellen aus und fügen Sie eine neue Spalte HostCountry vom Typ Yes/No hinzu. Wählen Sie Speichern aus.

Wählen Sie in Studio Entitäten verwalten aus und dann die Schaltfläche Aktualisieren . Für die Entität Medaillen wurde eine Änderung erkannt, wie es in der Spalte Änderungen veranschaulicht wird. Wählen Sie Speichern aus, damit die Entität in Studio aktualisiert wird.

Datensätze abfragen und aktualisieren

Die Aktivität Update Entity Record kann verwendet werden, um Datensätzen aus Ihrem Workflow direkt in Data Fabric zu aktualisieren.

In diesem Beispiel fragen wir bestimmte Datensätze aus der Entität Medaillen ab und aktualisieren sie automatisch mithilfe der oben genannten Aktivität.

In der Entität Medaillen wird das Gastgeberland eines jeden Austragungsjahres mit einem Sternchen neben seinem Namen gekennzeichnet. Für das Austragungsjahr 2012 wird das Gastgeberland beispielsweise als Großbritannien (GBR)* in der Spalte Olympische Spiele aufgezeichnet.

Mit der Aktivität Query Entity Records durchsuchen wir alle Datensätze, die das Sternchen (*) enthalten, erfassen die Datensätze in der Variable listMedals und verwenden die Aktivität For Each, um jedes Element zu durchlaufen und den Wert True in der Spalte HostCountry neben dem Land zuzuweisen, das die Olympiade in einem bestimmten Austragungsjahr veranstaltet hat.

Die Aktivität Update Entity Record kann in zahlreichen anderen Szenarien verwendet werden, um Daten zu übermitteln und Datensätze in Data Fabric zu aktualisieren.