MongoDB-Abfrageaktivität in Jitterbit Studio
Einführung
Eine MongoDB Abfrage-Aktivität, die ihre MongoDB-Verbindung verwendet, ruft Daten aus einer MongoDB-Sammlung ab und ist dazu gedacht, als Quelle für Daten in einer Operation zu dienen.
Erstellen einer MongoDB-Abfrageaktivität
Eine Instanz einer MongoDB Abfrage-Aktivität wird aus einer MongoDB-Verbindung unter Verwendung des Abfrage-Aktivitätstyps erstellt.
Um eine Instanz einer Aktivität zu erstellen, ziehen Sie den Aktivitätstyp auf die Entwurfsfläche oder kopieren Sie den Aktivitätstyp und fügen Sie ihn auf der Entwurfsfläche ein. Weitere Informationen finden Sie unter Erstellen einer Aktivitäts- oder Toolinstanz in Komponentenwiederverwendung.
Eine vorhandene MongoDB Abfrage-Aktivität kann von diesen Orten aus bearbeitet werden:
- Der Entwurfsfläche (siehe Komponentenaktionsmenü in Entwurfsfläche).
- Der Komponenten-Registerkarte im Projektbereich (siehe Komponentenaktionsmenü in Projektbereich Komponenten-Registerkarte).
Konfigurieren einer MongoDB-Abfrageaktivität
Befolgen Sie diese Schritte, um eine MongoDB Abfrage-Aktivität zu konfigurieren:
-
Schritt 1: Geben Sie einen Namen ein und wählen Sie eine Sammlung aus
Geben Sie einen Namen für die Aktivität ein und wählen Sie eine Sammlung aus. -
Schritt 2: Geben Sie die Einstellungen an
Geben Sie den Filter, Limit, Projektionstyp und Projektion an. -
Schritt 3: Überprüfen Sie die Datenschemas
Alle Anfrage- oder Antwortschemas werden angezeigt.
Schritt 1: Geben Sie einen Namen ein und wählen Sie eine Sammlung aus
In diesem Schritt geben Sie einen Namen für die Aktivität ein und wählen eine Sammlung aus. Jedes Benutzeroberflächenelement dieses Schrittes wird unten beschrieben.
-
Endpoint-Menü: Wenn Sie mehrere Endpunkte desselben Verbindungstyps konfiguriert haben, wird oben auf dem Bildschirm ein Menü mit dem aktuellen Endpunktnamen angezeigt. Klicken Sie auf das Menü, um zu einem anderen Endpunkt zu wechseln. Weitere Informationen finden Sie unter Ändern des zugewiesenen Endpunkts in Konfigurationsbildschirmen.
- Endpunkt bearbeiten: Wird angezeigt, wenn Sie über den aktuellen Endpunktnamen fahren. Klicken Sie, um die Verbindungsconfiguration des aktuell ausgewählten Endpunkts zu bearbeiten.
-
Name: Geben Sie einen Namen ein, um die Aktivität zu identifizieren. Der Name muss für jede MongoDB Abfrage-Aktivität eindeutig sein und darf keine Schrägstriche
/oder Doppelpunkte:enthalten. -
Objekt auswählen: Dieser Abschnitt zeigt die in dem MongoDB-Endpunkt verfügbaren Sammlungen an.
-
Ausgewähltes MongoDB-Objekt: Nachdem eine Sammlung ausgewählt wurde, wird sie hier aufgelistet.
-
Suche: Geben Sie den Wert einer beliebigen Spalte in das Suchfeld ein, um die Liste der Sammlungen zu filtern. Die Suche ist nicht groß-/kleinschreibungsempfindlich. Wenn Sammlungen bereits in der Tabelle angezeigt werden, werden die Tabellenergebnisse in Echtzeit mit jedem Tastendruck gefiltert. Um Sammlungen vom Endpunkt beim Suchen neu zu laden, geben Sie Suchkriterien ein und aktualisieren Sie dann, wie unten beschrieben.
-
Aktualisieren: Klicken Sie auf das Aktualisierungssymbol oder das Wort Aktualisieren, um Sammlungen vom MongoDB-Endpunkt neu zu laden. Dies kann nützlich sein, wenn Sammlungen zu MongoDB hinzugefügt wurden. Diese Aktion aktualisiert alle Metadaten, die zum Erstellen der in der Konfiguration angezeigten Tabelle der Sammlungen verwendet werden.
-
Auswählen einer Sammlung: Klicken Sie innerhalb der Tabelle auf eine beliebige Stelle in einer Zeile, um eine Sammlung auszuwählen. Es kann nur eine Sammlung ausgewählt werden. Die Informationen, die für jede Sammlung verfügbar sind, werden vom MongoDB-Endpunkt abgerufen:
-
Name: Der Name der Sammlung.
-
Beschreibung: Die Beschreibung der Sammlung.
-
Tipp
Wenn die Tabelle nicht mit verfügbaren Sammlungen gefüllt wird, könnte die MongoDB-Verbindung nicht erfolgreich sein. Stellen Sie sicher, dass Sie verbunden sind, indem Sie die Verbindung erneut öffnen und die Anmeldeinformationen erneut testen.
-
-
Speichern & Beenden: Wenn aktiviert, klicken Sie, um die Konfiguration für diesen Schritt zu speichern und die Aktivitätskonfiguration zu schließen.
-
Weiter: Klicken Sie, um die Konfiguration für diesen Schritt vorübergehend zu speichern und zum nächsten Schritt fortzufahren. Die Konfiguration wird nicht gespeichert, bis Sie die Schaltfläche Fertig im letzten Schritt klicken.
-
Änderungen verwerfen: Nach Änderungen klicken Sie, um die Konfiguration zu schließen, ohne die vorgenommenen Änderungen zu speichern. Eine Nachricht fragt Sie, ob Sie die Änderungen verwerfen möchten.
Schritt 2: Einstellungen angeben
In diesem Schritt geben Sie den Filter, Limit, Projektionstyp und Projektion an. Jedes Benutzeroberflächenelement dieses Schrittes wird im Folgenden beschrieben.
Tipp
Felder mit einem Variablen-Icon unterstützen die Verwendung von globalen Variablen, Projektvariablen und Jitterbit-Variablen. Beginnen Sie entweder, indem Sie eine öffnende eckige Klammer [ in das Feld eingeben oder indem Sie auf das Variablen-Icon klicken, um ein Menü anzuzeigen, das vorhandene Variablen zur Auswahl auflistet.
-
Filter: Geben Sie einen Filter im Format MongoDB Extended JSON ein, der beim Abrufen von Dokumenten der angegebenen Sammlung verwendet werden soll.
-
Limit: Geben Sie die maximale Anzahl von Dokumenten an, die aus der Sammlung abgerufen werden sollen.
-
Projektionstyp: Wählen Sie einen Projektionstyp aus, entweder Einbeziehen oder Ausschließen:
-
Einbeziehen: Gibt bestimmte Felder (die im Feld Projektion angegeben sind) in der Antwort zurück.
-
Ausschließen: Schließt bestimmte Felder (die im Feld Projektion angegeben sind) aus der Antwort aus.
-
-
Projektion: Geben Sie eine Projektion ein, um Felder einzuschließen oder auszuschließen, die in der Abfrage-Antwort zurückgegeben werden. Mehrere Werte müssen durch ein Komma getrennt werden.
-
Sortieren: Definieren Sie die Sortierreihenfolge der Antwort dieser Aktivität. Klicken Sie auf das Hinzufügen-Symbol , um eine Eigenschaft und Sortierart in die folgende Tabelle hinzuzufügen:
- Eigenschaft: Geben Sie den Namen des Feldes ein, das sortiert wird.
- Sortierart: Geben Sie an, ob die Dokumente, die das Feld enthalten, in aufsteigender Reihenfolge (
1) oder in absteigender Reihenfolge (-1) sortiert sind.
Um die Zeile zu speichern, klicken Sie auf das Senden-Symbol in der rechten Spalte.
Um eine einzelne Zeile zu bearbeiten oder zu löschen, fahren Sie mit der Maus über die rechte Spalte und verwenden Sie das Bearbeiten-Symbol oder das Löschen-Symbol .
Um alle Zeilen zu löschen, klicken Sie auf Alle löschen.
Wichtig
Felder in der Sortieren-Tabelle zeigen das Variablen-Symbol nur im Bearbeitungsmodus an. Damit die Variablenwerte dieser Felder zur Laufzeit befüllt werden, muss die Agenten-Version mindestens 10.75 / 11.13 sein.
Felder in der Sortieren-Tabelle unterstützen nicht die Verwendung von Variablen, um rohes JSON zu übergeben. Wenn Ihr Anwendungsfall nicht unterstützt, rohes JSON direkt in den Feldern zu definieren, entkommen Sie den JSON-Inhalt, bevor Sie ihn mit einer Variablen übergeben. Zum Beispiel wird
{"success": "true"};zu{\"success\": \"true\"};. -
Zurück: Klicken Sie, um die Konfiguration für diesen Schritt vorübergehend zu speichern und zum vorherigen Schritt zurückzukehren.
-
Weiter: Klicken Sie, um die Konfiguration für diesen Schritt vorübergehend zu speichern und zum nächsten Schritt fortzufahren. Die Konfiguration wird nicht gespeichert, bis Sie auf die Schaltfläche Fertig im letzten Schritt klicken.
-
Änderungen verwerfen: Nachdem Sie Änderungen vorgenommen haben, klicken Sie, um die Konfiguration zu schließen, ohne die Änderungen an einem Schritt zu speichern. Eine Nachricht fragt Sie, ob Sie die Änderungen wirklich verwerfen möchten.
Schritt 3: Überprüfen der Datenschemas
Alle Anforderungs- oder Antwortschemas werden angezeigt. Jedes Benutzeroberflächenelement dieses Schrittes wird im Folgenden beschrieben.
-
Datenschemas: Diese Datenschemas werden von benachbarten Transformationen geerbt und während der Transformationszuordnung erneut angezeigt.
Hinweis
Die in einer Transformation bereitgestellten Daten haben Vorrang vor der Aktivitätskonfiguration.
Der MongoDB-Connector verwendet den MongoDB Java Driver v4.1. Weitere Informationen zu den Schemanodes und -feldern finden Sie in der Treiberdokumentation und im MongoDB-Referenzhandbuch.
Die Abfrage-Aktivität verwendet XML sowohl in ihren Anforderungs- als auch in ihren Antwortschemata.
Die Daten-Schemas für Anfrage und Antwort bestehen aus diesen Knoten und Feldern:
-
Anfrage:
Anfrage-Schema Feld/Knoten Beschreibung queryRequestAnfrage zur Abfrage der Datenbank filterEin Filter im MongoDB Extended JSON-Format, der verwendet wird, um die Dokumente in der ausgewählten Sammlung zuzuordnen projectionDer Projektionsstring limitMaximale Anzahl von Dokumenten, die aus der Sammlung abgerufen werden sollen projectionTypeDer Projektionstyp, entweder includeoderexcludesortDie Sortierreihenfolge der Antwort dieser Aktivität keyGeben Sie das Feld an, nach dem sortiert werden soll valueGeben Sie an, ob die Dokumente, die das Feld enthalten, in aufsteigender Reihenfolge ( 1) oder in absteigender Reihenfolge (-1) sortiert werdenaggregrateKnoten, der die Spezifikationen einer Aggregationsoperation enthält unwindGeben Sie das Feld an, das entwirrt werden soll matchKnoten, der das Schlüssel-Wert-Paar der Bedingungen für die Match-Pipeline-Phase enthält keyGeben Sie das Feld an, das abgefragt wird valueGeben Sie den gewünschten Wert des abgefragten Feldes an sortAggregrateKnoten, der die Sortierreihenfolge der Aggregatergebnisse enthält keyGeben Sie das Feld an, nach dem sortiert werden soll valueGeben Sie an, ob die Dokumente, die das Feld enthalten, in aufsteigender Reihenfolge ( 1) oder in absteigender Reihenfolge (-1) zurückgegeben werdenprojectKnoten, der Bedingungen für die Projekt-Pipeline-Phase enthält excludeGeben Sie das Feld an, das in der Antwort ausgeschlossen werden soll includeGeben Sie das Feld an, das in der Antwort enthalten sein soll groupKnoten, der Bedingungen für die Gruppierungs-Pipeline-Phase enthält keyGeben Sie den Gruppenschlüssel an valueGeben Sie den Gruppenwert an accumulatorGeben Sie den Accumulator an nameNewFieldGeben Sie den Namen des hinzuzufügenden Feldes an outGeben Sie die Sammlung für die Out-Pipeline-Phase an -
Antwort:
Antwort-Schema Feld/Knoten Beschreibung queryResponseAntwort von der Abfrage der Datenbank recordsAnzahl der zurückgegebenen Dokumente (Datensätze) documentsKnoten, der die documentsdarstelltdocumentDokumentinhalt
-
-
Aktualisieren: Klicken Sie auf das Aktualisierungssymbol oder das Wort Aktualisieren, um die Schemata vom MongoDB-Endpunkt neu zu generieren. Diese Aktion regeneriert auch ein Schema an anderen Stellen im Projekt, an denen dasselbe Schema referenziert wird, wie in einer benachbarten Transformation.
-
Zurück: Klicken Sie, um die Konfiguration für diesen Schritt vorübergehend zu speichern und zum vorherigen Schritt zurückzukehren.
-
Fertig: Klicken Sie, um die Konfiguration für alle Schritte zu speichern und die Aktivitätskonfiguration zu schließen.
-
Änderungen verwerfen: Nach Änderungen klicken Sie, um die Konfiguration zu schließen, ohne die vorgenommenen Änderungen an einem Schritt zu speichern. Eine Nachricht fragt Sie, ob Sie die Änderungen wirklich verwerfen möchten.
Nächste Schritte
Nachdem Sie eine MongoDB Abfrage-Aktivität konfiguriert haben, vervollständigen Sie die Konfiguration des Vorgangs, indem Sie andere Aktivitäten oder Werkzeuge als Vorgangsschritte hinzufügen und konfigurieren. Sie können auch die Betriebseinstellungen konfigurieren, die die Möglichkeit umfassen, Vorgänge zusammenzuschalten, die sich in denselben oder unterschiedlichen Workflows befinden.
Menüaktionen für eine Aktivität sind über das Projektfenster und die Entwurfskanvas zugänglich. Weitere Details finden Sie im Aktivitätsaktionsmenü in Connector-Grundlagen.
MongoDB Abfrage-Aktivitäten können als Quelle mit diesen Betriebsmustern verwendet werden:
- Transformationsmuster
- Zwei-Ziel-Archivmuster (nur als erste Quelle)
- Zwei-Ziel-HTTP-Archivmuster (nur als erste Quelle)
- Zwei-Transformationsmuster (als erste oder zweite Quelle)
Um die Aktivität mit Skriptfunktionen zu verwenden, schreiben Sie die Daten an einen temporären Speicherort und verwenden Sie dann diesen temporären Speicherort in der Skriptfunktion.
Wenn Sie bereit sind, bereitstellen und ausführen Sie den Vorgang und validieren Sie das Verhalten, indem Sie die Betriebsprotokolle überprüfen.