MongoDB (Eingangsagent Cron)

Dieser Eingangsagent liest zeitgesteuert Dokumente aus einer MongoDB und übergibt sie dem Profil als Eingangsdaten. Die Dokumente ermittelt er über eine Abfrage auf eine Collection.

 HINWEIS: Bei diesem Eingangsagenten setzt das System die Dokumentenart automatisch auf JSON.

Einstellungen

① Alias: Alias für die Verbindung zur Datenbank. Ein Datenbank-Alias ist eine konfigurierte Verbindung zu einem Datenbanksystem. Siehe Abschnitt MongoDBConnectionService. Zusätzlich stehen alle im Profil definierten Variablen mit Präfix MSG_CALL_ zur Auswahl. Damit übergeben Sie den Alias aus einem triggernden Profil oder per HTTP-Aufruf. Definieren Sie diese Variablen mit einem Defaultwert. Das erleichtert die Prüfung.

② Database: Die Database, auf die sich die Abfrage bezieht. Sie entspricht einem Schema in einer SQL-Datenbank. Der Alias enthält über den Parameter catalogName bereits eine Database. Den Wert für diese Verbindung überschreiben Sie hier im Eingangsagenten.

③ Collection: Die Collection, auf die sich die Abfrage bezieht. Sie entspricht einer Tabelle in einer SQL-Datenbank.

④ Ausgabeformat: Eine MongoDB speichert Datensätze als BSON-Dokumente. BSON ist eine binäre Darstellung von JSON-Dokumenten. Es enthält jedoch mehr Datentypen als JSON. Wählen Sie hier BSON, dann zeigt das zurückgegebene JSON-Dokument die BSON-spezifischen Datentypen. Siehe Abschnitt Ausgabeformat BSON und JSON. Siehe zum Thema auch den MongoPostexecutor.

⑤ Max erlaubte Dokumente: Liefert eine Abfrage mehr Dokumente als hier angegeben, dann liest das Profil nur die angegebene Anzahl ein. Alle weiteren Dokumente ignoriert es. Beispiel: Bei dem Wert 20 und 22 gefundenen Dokumenten ignoriert das Profil die Dokumente 21 und 22. Ein Fehler entsteht dabei nicht.

⑥ Alle Dokumente zusammenfassen: Ist diese Checkbox gesetzt, fasst das System alle gefundenen Dokumente zu einem einzigen JSON-Dokument zusammen. Es startet dann nur einen Job. Ist die Checkbox nicht gesetzt, gibt es jedes gefundene Dokument einzeln zurück und startet für jedes einen eigenen Job.

⑦ Query: Die auszuführende Abfrage. Beispiel: {}. Details zur Abfragesprache finden Sie in der Dokumentation des Herstellers. Über das Kontextmenü speichern Sie Abfragen und wählen gespeicherte Abfragen aus. Verwalten können Sie sie über Benutzer-Menü > Integration Notes > MongoDB.

Für dieses Feld gelten außerdem diese Regeln:

• Permanente Profil-Werte (Syntax %perm:KEYNAME%) sind erlaubt. Sie funktionieren jedoch nur im Profil-Lauf, nicht über ⑨.

• Geben Sie die Abfrage in geschweiften Klammern an, dann verwendet das System die Methode find(). Das zeigt auch der Screenshot.

• Geben Sie die Abfrage als Array in eckigen Klammern an, dann verwendet das System automatisch die Methode aggregate().

Beispiel für eine Abfrage mit aggregate():

[
{$match: {"FAILED": "false"}},
{$group: {"_id": "$_id", "PID": {"$first": "$PROFILE_ID"}, "TOTAL": {$sum: "$JOB"}}}
]

⑧ Projection: Über dieses Feld führen Sie eine Abfrage mit Projection aus. Beispiel: Der Wert {FAILED:1} führt die Abfrage find({},{FAILED:1}) aus.

⑨ Abfrage testen: Führt die Abfrage aus ⑦ testweise aus. Der Test zeigt nur den ersten Ergebnis-Datensatz.

⑩ Struktur erzeugen: Erzeugt eine zur Abfrage passende Quellstruktur.  ACHTUNG: Eine bereits vorhandene Quellstruktur überschreibt das System dabei.

Ausgabeformat BSON und JSON

Das Ausgabeformat wählen Sie in ④. Die folgenden Beispiele zeigen dasselbe Dokument in beiden Formaten.

JSON

[{
  "_id": "5ea94c0cfcba7e213485e8a4",
  "JOB": 0,
  "PROFILE": "httpin",
  "PROFILE_ID": "6f6fbe3d:171c4d6b593:-7f28.d19731995bc0c589:6f6fbe3d:171c4d6b593:-8000",
  "START": "2027-04-29T11:42:36.930Z",
  "END": "2027-04-29T11:42:36.944Z",
  "FAILED": false,
  "FILENAME": "n.a.",
  "BACKUP": "Job_0",
  "CLIENT": "-1",
  "ROLE": "",
  "DISPLAY1": "",
  "DISPLAY2": "",
  "DISPLAY3": "",
  "LOGPOOL": "STANDARD"
}]

BSON

[{
  "_id": {
    "$oid": "5ea94c0cfcba7e213485e8a4"
  },
  "JOB": {
    "$numberLong": "0"
  },
  "PROFILE": "httpin",
  "PROFILE_ID": "6f6fbe3d:171c4d6b593:-7f28.d19731995bc0c589:6f6fbe3d:171c4d6b593:-8000",
  "START": {
    "$date": {
      "$numberLong": "1808991756930"
    }
  },
  "END": {
    "$date": {
      "$numberLong": "1808991756944"
    }
  },
  "FAILED": false,
  "FILENAME": "n.a.",
  "BACKUP": "Job_0",
  "CLIENT": "-1",
  "ROLE": "",
  "DISPLAY1": "",
  "DISPLAY2": "",
  "DISPLAY3": "",
  "LOGPOOL": "STANDARD"
}]