Data Operations · NGSI-LD und Stellio

Stellio Subscriptions

Der Node verwaltet vorhandene NGSI-LD-Subscriptions des Stellio Context Brokers: alle Subscriptions auflisten, eine einzelne lesen, per PATCH aktivieren oder deaktivieren und löschen. Die Operation lässt sich im Dialog festlegen oder je Nachricht über msg.operation steuern. Eine Browser-Registerkarte zeigt alle Subscriptions mit Status direkt im Editor.

Subscriptions
Verwalten
NGSI-LD

Node-Typ: stellio-subscriptions
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

Subscriptions (Abonnements) sorgen dafür, dass der Context Broker Änderungen an Entitäten an einen Empfänger meldet, zum Beispiel an eine Zeitreihendatenbank. Mit der Zeit sammeln sich Subscriptions an, die geprüft, vorübergehend pausiert oder entfernt werden müssen. Dieser Node fasst die dafür nötigen Operationen zusammen; neue Subscriptions legen Sie mit Stellio Create Subscription an.

Typische Einsatzfälle sind:

Inventur: alle Subscriptions eines Tenants mit Entitätstyp, beobachteten Attributen und Status auflisten.
Wartungsfenster: eine Subscription deaktivieren, während Daten bereinigt werden, und danach wieder aktivieren.
Aufräumen: verwaiste Subscriptions anhand ihrer ID löschen.

So funktioniert der Node

Operation bestimmen

msg.operation oder die konfigurierte Aktion wählt zwischen List, Get, Set Active und Delete.

Request senden

Der Node ruft /ngsi-ld/v1/subscriptions per GET, PATCH oder DELETE mit Tenant- und Link-Header auf.

Antwort ausgeben

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

Ergebnis: Eine Subscription-Liste, eine einzelne Subscription oder das Ergebnis der Änderung in msg.payload.

Der Node ist nachrichtenbasiert und löst je eingehender Nachricht genau einen Request aus. Die Registerkarte Browser lädt bis zu 100 Subscriptions über die Admin-Endpunkte des Node-RED-Servers und erlaubt dort das Aktivieren, Deaktivieren und Löschen per Schaltfläche.

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 `Subscriptions: <Aktion>`.
API URL	Text	`${STELLIO_API_URL}`	Basis-URL des Brokers. Platzhalter `${VAR}` werden zur Laufzeit ersetzt; leer bedeutet Rückfall auf die Umgebungsvariable `STELLIO_API_URL`.
Tenant	Text	leer	Wert des Headers `NGSILD-Tenant`. Leer: Standard-Tenant des Brokers.
Context	Text	siehe unten	JSON-LD-Kontext für den `Link`-Header bei List, Get und Set Active.
Aktion	Auswahl	`List`	`List` (alle Subscriptions), `Get` (einzelne per ID), `Set Active` (aktiv/inaktiv schalten), `Delete` (löschen).
Limit	Zahl	`100`	Maximale Anzahl bei List.
Subscription ID	Text	leer	Vollständige URN für Get, Set Active und Delete, zum Beispiel `urn:ngsi-ld:Subscription:001`.
Status	Auswahl	`aktiv`	Zielzustand bei Set Active: `aktiv` oder `inaktiv`.

Standardwerte der URL-Felder:

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

Welche Felder sichtbar sind, hängt von der Aktion ab: Limit bei List, Subscription ID bei Get, Set Active und Delete, Status nur bei Set Active.

Registerkarte Browser

Laden listet bis zu 100 Subscriptions mit ID, Beschreibung, Entitätstypen, beobachteten Attributen, q-Filter, Context und Status (aktiv/inaktiv). Je Zeile stehen Schaltflächen für Details, Aktivieren/Deaktivieren und Löschen (mit Rückfrage) bereit.

Änderungen aus dem Editor

Aktivieren, Deaktivieren und Löschen in der Browser-Registerkarte wirken sofort auf den Broker, ohne dass der Flow bereitgestellt werden muss. Sie setzen die Node-RED-Berechtigung stellio.write voraus.

Eingang

Werte aus der Nachricht haben Vorrang vor der Konfiguration.

Eigenschaft	Typ	Bedeutung
`msg.operation`	Text	`list`, `get`, `setActive` oder `delete`. Unbekannte Werte werden wie `list` behandelt.
`msg.apiUrl`	Text	Überschreibt die API URL.
`msg.tenant`	Text	Überschreibt den Tenant.
`msg.contextUrl`	Text	Überschreibt den Context (Link-Header).
`msg.subscriptionId`	Text	Überschreibt die Subscription ID (Get, Set Active, Delete).
`msg.active`	Boolean oder Text `"true"`/`"false"`	Zielzustand bei `setActive`. Fehlt die Eigenschaft, gilt die Auswahl Status aus dem Dialog.
`msg.limit`	Zahl	Überschreibt das Limit bei `list`.
`msg.payload`	beliebig	Wird nicht ausgewertet; die Nachricht dient nur als Auslöser.

Ausgang

Die Nachricht wird um die Antwort des Brokers ergänzt. Für list enthält msg.payload zum Beispiel:

[
  {
    "id": "urn:ngsi-ld:Subscription:7f3a2c1e-0000-4000-8000-000000000001",
    "type": "Subscription",
    "subscriptionName": "Subscription for entity type WeatherObserved.",
    "entities": [{"type": "WeatherObserved"}],
    "watchedAttributes": ["dateObserved"],
    "notificationTrigger": ["entityCreated", "attributeCreated", "attributeUpdated"],
    "isActive": true,
    "notification": {
      "format": "normalized",
      "endpoint": {"uri": "https://quantumleap.beispielstadt.example/v2/notify", "accept": "application/json"}
    },
    "@context": ["https://context.beispielstadt.example/main-context.jsonld"]
  }
]

Feld	Bedeutung
`msg.payload`	`list`: Array von Subscription-Objekten. `get`: ein Subscription-Objekt. `setActive`: Antwortkörper des Brokers; bei leerer Antwort (`204`) ein Objekt mit `id` und `isActive`. `delete`: in der Regel leer.
`msg.statusCode`	HTTP-Statuscode der Antwort.
`msg.headers`	Antwort-Header des Brokers.
`msg.count`	Trefferzahl aus dem Header `NGSILD-Results-Count` bei `list`, sofern der Broker ihn sendet.

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-Subscriptions-Node ist darin enthalten, jedoch nicht als vollständiger Inject-Subscriptions-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