Data Operations · NGSI-LD und Stellio

Stellio Entities

Der Node bündelt die wichtigsten Entitäten-Operationen des Stellio Context Brokers: Abfragen nach Typ, Filter und ID-Muster, Lesen einer einzelnen Entität, Zählen von Treffern sowie Löschen einzeln oder als Stapel. Die Operation lässt sich im Dialog festlegen oder je Nachricht über msg.operation steuern. Eine Browser-Registerkarte zeigt Entitäten direkt im Editor.

Abfragen
Löschen
NGSI-LD

Node-Typ: stellio-entities
Paket: @htag/node-red-contrib-hypertegrity-ngsi-ld
Eingänge / Ausgänge: 1 / 1
Ziel: Stellio Context Broker (NGSI-LD)

Wofür Sie den Node verwenden

Nach dem Veröffentlichen von Entitäten möchten Sie meist prüfen, was im Broker liegt, einzelne Datensätze nachlesen oder veraltete Entitäten entfernen. Stellio Entities deckt diese Aufgaben mit einem Node ab und erspart Ihnen das manuelle Zusammenbauen von HTTP-Requests, Headern und Query-Parametern.

Typische Einsatzfälle sind:

Qualitätskontrolle nach einem Import: alle Entitäten eines Typs abfragen und mit der Quelle vergleichen.
Dashboards und Anreicherung: eine Entität per ID lesen und ihre Attribute in einem Flow weiterverwenden.
Monitoring: die Anzahl der Entitäten eines Typs zählen und bei Abweichungen alarmieren.
Bereinigung: Entitäten anhand eines ID-Musters ermitteln und per Stapel-Löschung entfernen.

So funktioniert der Node

Operation bestimmen

msg.operation oder die konfigurierte Aktion legt fest, ob abgefragt, gelesen, gezählt oder gelöscht wird.

Request aufbauen

Verbindung (API URL, Tenant, Context) und Parameter (Type, q, ID Pattern, Attrs, Limit, Offset, Entity ID) werden aus msg und Konfiguration zusammengeführt.

Broker ansprechen

Der Node ruft /ngsi-ld/v1/entities bzw. /entityOperations/delete mit NGSILD-Tenant- und Link-Header auf.

Antwort ausgeben

Antwortkörper, Statuscode, Header und gegebenenfalls die Trefferzahl werden in die Nachricht geschrieben.

Ergebnis: Entitäten, eine einzelne Entität, eine Trefferzahl oder das Ergebnis einer Löschung in msg.payload.

Der Node ist nachrichtenbasiert. Jede eingehende Nachricht löst genau einen Request aus. Die Registerkarte Browser im Dialog arbeitet unabhängig davon: Sie nutzt die Admin-Endpunkte des Node-RED-Servers, um Entitäten im Editor aufzulisten, Details anzuzeigen und Entitäten direkt zu löschen.

Konfiguration

Der Dialog hat die Registerkarten Aktion und Browser. Alle gespeicherten Felder liegen auf der Registerkarte Aktion.

Registerkarte Aktion

Feld	Typ	Standard	Bedeutung
Name	Text	leer	Anzeigename des Nodes im Flow. Ohne Namen zeigt der Node `Entities: <Aktion>`.
API URL	Text	`${STELLIO_API_URL}`	Basis-URL des Brokers. Platzhalter `${VAR}` werden zur Laufzeit aus Umgebungsvariablen ersetzt; ein abschließender Schrägstrich wird entfernt. Leer: Rückfall auf die Umgebungsvariable `STELLIO_API_URL`.
Tenant	Text	leer	Wert des Headers `NGSILD-Tenant`. Leer: der Header wird nicht gesendet (Standard-Tenant des Brokers).
Context	Text	siehe unten	JSON-LD-Kontext, der als `Link`-Header mitgesendet wird. Er bestimmt, wie Typ- und Attributnamen in der Antwort abgekürzt werden.
Aktion	Auswahl	`Query`	`Query` (Entitäten suchen), `Get` (einzelne Entität per ID), `Count` (Anzahl ermitteln), `Delete` (Entität löschen), `Batch Delete` (Array von IDs aus `msg.payload`).
Type	Text	leer	Entitätstyp(en) für Query und Count, mehrere kommagetrennt, zum Beispiel `Device,WeatherObserved`.
q-Filter	Text	leer	NGSI-LD-Filterausdruck (Beispiel unten).
ID Pattern	Text	leer	Regulärer Ausdruck auf die Entitäts-ID, zum Beispiel `urn:ngsi-ld:Device:.*`.
Attrs	Text	leer	Nur diese Attribute zurückgeben, kommagetrennt. Gilt auch für Get.
Limit	Zahl	`100`	Maximale Trefferzahl je Antwort (Query).
Offset	Zahl	leer	Anzahl zu überspringender Treffer für seitenweises Abrufen.
Entity ID	Text	leer	Vollständige URN für Get und Delete, zum Beispiel `urn:ngsi-ld:Device:001`.

Beispiel für einen q-Filter:

temperature>20;category=="urban"

Standardwerte der URL-Felder:

Context: https://context.${DOMAIN}/main-context.jsonld

Welche Felder sichtbar sind, hängt von der gewählten Aktion ab: Type, q-Filter, ID Pattern, Attrs, Limit und Offset erscheinen bei Query und Count, Entity ID bei Get und Delete, ein Hinweis zu msg.payload bei Batch Delete.

Registerkarte Browser

Die Registerkarte verwendet die Verbindung aus der Registerkarte Aktion. Sie können nach Type und q-Filter suchen, ein Limit setzen, mit Laden die Treffer auflisten, Details als JSON einblenden und einzelne Entitäten nach Rückfrage löschen. Die Browser-Felder werden nicht gespeichert.

Löschen aus dem Editor

Das Löschen in der Browser-Registerkarte wirkt sofort auf den Broker, ohne dass der Flow bereitgestellt werden muss. Es setzt die Node-RED-Berechtigung stellio.write voraus.

Eingang

Werte aus der Nachricht haben Vorrang vor der Konfiguration.

Eigenschaft	Typ	Bedeutung
`msg.operation`	Text	`query`, `get`, `count`, `delete` oder `batchDelete`. Unbekannte Werte werden wie `query` behandelt.
`msg.apiUrl`	Text	Überschreibt die API URL.
`msg.tenant`	Text	Überschreibt den Tenant.
`msg.contextUrl`	Text	Überschreibt den Context (Link-Header).
`msg.type`	Text	Überschreibt Type (Query, Count).
`msg.q`	Text	Überschreibt den q-Filter (Query, Count).
`msg.idPattern`	Text	Überschreibt das ID Pattern (Query, Count).
`msg.attrs`	Text	Überschreibt Attrs (Query, Count, Get).
`msg.limit`	Zahl	Überschreibt das Limit (Query).
`msg.offset`	Zahl	Überschreibt den Offset (Query, Count).
`msg.entityId`	Text	Überschreibt die Entity ID (Get, Delete; Rückfallwert für Batch Delete).
`msg.payload`	Array von Texten	Nur bei `batchDelete`: Liste der zu löschenden URNs. Ist der Payload kein Array, wird stattdessen die Entity ID als einzelnes Element verwendet.

Enthält eine Query weder Type, q-Filter noch ID Pattern, setzt der Node automatisch idPattern=.*, damit der Broker alle Entitäten liefert.

Ausgang

Die Nachricht wird um die Antwort des Brokers ergänzt. Bei query mit Type WeatherObserved sieht msg.payload zum Beispiel so aus:

[
  {
    "id": "urn:ngsi-ld:WeatherObserved:beispielstadt:station-042",
    "type": "WeatherObserved",
    "temperature": {
      "type": "Property",
      "value": 14.2,
      "observedAt": "2026-10-01T06:00:00.000Z"
    },
    "location": {
      "type": "GeoProperty",
      "value": {"type": "Point", "coordinates": [7.3322, 50.3315]}
    },
    "@context": ["https://context.beispielstadt.example/main-context.jsonld"]
  }
]

Feld	Bedeutung
`msg.payload`	`query`: Array von Entitäten. `get`: ein Entitätsobjekt. `count`: Objekt `{"count": n}`. `delete`: in der Regel leer (`204`). `batchDelete`: Ergebnisobjekt des Brokers mit erfolgreichen und fehlgeschlagenen IDs.
`msg.statusCode`	HTTP-Statuscode der Antwort.
`msg.headers`	Antwort-Header, darunter bei Zählabfragen `ngsi-ld-results-count`.
`msg.count`	Trefferzahl aus dem Header `NGSILD-Results-Count`, sofern der Broker ihn bei `query` mitsendet.

Beispiel-Flow

Das Paket bringt einen gemeinsamen Beispiel-Flow für mehrere Stellio-Nodes mit. Sie importieren ihn in Node-RED über Menü → Importieren → Beispiele → @htag/node-red-contrib-hypertegrity-ngsi-ld → stellio-helper-nodes. Der Stellio-Entities-Node ist darin enthalten, jedoch nicht als vollständiger Inject-Entities-Debug-Ablauf verdrahtet; der folgende Ausschnitt zeigt deshalb eine minimale Verdrahtung dieses Nodes. Alternativ laden Sie die Datei stellio-helper-nodes.json herunter und importieren sie über Menü → Importieren.

Schritt 1

Inject

Ein Inject-Node löst die Abfrage manuell oder in einem festen Intervall aus.

Schritt 2