Verwenden von Entitäten in Projekten

Durch die Verwendung von Entitäten, die in Data Fabric/Data Service erstellt wurden, können Sie Daten, die in einem einzelnen Objekt aggregiert sind, verwalten und manipulieren, ohne damit arbeiten zu müssen. 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/Data Service

Den Schritten folgen, die auf der Seite Erstellen einer Entität beschrieben sind, haben wir eine Entität zum Speichern von Informationen über teilnehmende Länder, die Anfangs- und Schließungsdaten und die gewonnene Abzeichen erstellt.

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 neuen Operator initialisiert, aus Data Fabric/Data Service gelesen oder vor der Verwendung über ein Eingabeargument in einem Workflow übergeben werden. Andernfalls kann das Zuweisen oder Lesen ihrer Werte Fehler verursachen.

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

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

In diesem Beispiel haben wir die importierten Argumente verwendet, um die gesammelten Informationen an Data Fabric/Data Service zu übergeben. Die Eingabe- und Ausgabedatensätze sind die Werte von Variablen des Typs Robot, die zum Übergeben der Daten verwendet werden.

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

Datensätze mit strukturierten Daten erstellen

Datensätze, die in einer Datentabelle strukturiert sind, können mithilfe der Aktivität For Each Row an Data Fabric/Data Service übergeben werden. In diesem Beispiel rufen wir einen Workflow auf, der strukturierte Daten über die Anzahl der von jedem Land gewonnenen Ressourcen sammelt und diese Datensätze an Data Fabric/Data Service weiterleitet.

Nach dem Ausführen des Workflows werden die folgenden Daten in Data Fabric/Data Service 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/Data Service abzurufen. Im folgenden Beispiel verwenden wir die Aktivität, um Datendatensätze von der Entität Organisation Administrator abzufragen, dem Benutzer die Auswahl einer Organisation für die Administratoren zu ermöglichen, und um in die Entität für die Orchestrator die Anzahl der Warnungen zu schreiben, 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 listOlympics.Select(Function (o as Olympics) o.Name).ToArray in der Aktivität Input Dialog verwendet. 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/Data Service kann potenziell eine große Anzahl von Datensätzen speichern. Um nur eine bestimmte Anzahl von Datensätzen abzufragen, verwenden Sie die Paginierungseigenschaften aus der Aktivität Query Entities Records . 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 zum Aktualisieren eines Entitätsschemas in Data Fabric/Data Service und zum anschließenden Synchronisieren der Daten mit Studio erläutert.

Wechseln Sie in Data Fabric/Data Service zur Entität Orchestrator , wählen Sie Neues Feld erstellen 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 Orchestrator wurde eine Änderung erkannt, wie in der Spalte Änderungen dargestellt. Wählen Sie Speichern aus, und die Entität wird in Studio aktualisiert.

Datensätze abfragen und aktualisieren

Die Aktivität Update Entity Record kann zum Aktualisieren von Datensätzen aus Ihrem Workflow direkt in Data Fabric/Data Service verwendet werden.

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 zum Übergeben von Daten und Aktualisieren von Datensätzen in Data Fabric/Data Service verwendet werden.