StableNet-Abfragen

Dieser Abschnitt gilt nur für Systeme, die in StableNet® integriert sind.

StableNet®-Daten können sowohl aus einem aggregierten Datensatz in einer lokalen SKOOR-Datenbank als auch in Echtzeit über die StableNet®-API abgefragt werden. Die folgenden Richtlinien helfen dabei, diese beiden Methoden zu kombinieren und zu optimieren.

Erstellen Sie eine materialisierte Datenabfrage für Geräte und Messungen

Die folgende Beispielabfrage liefert Basisdaten für die Verwendung mit einem FilterMatrix-Widget (z. B. Filter für Geräte oder Messungen) sowie zum Verknüpfen von Messdaten aus der StableNet®-API oder der aggregierten Datentabelle. Die Datenquelle muss auf einen Typ von StableNet eingestellt sein.

-- Data query example "device_measurement"

SELECT   
  std.id AS device_id,
  std.display_name AS device_name,
  sm.id as measurement_id,
  sm.name as measurement_name
FROM stablenet_taggable_device std
JOIN stablenet_measurement sm 
  ON std.id = sm.dest_device_id

Da sich Geräte- und Messdaten nicht sehr oft ändern, sollte diese Abfrage materialisiert werden. Dadurch wird die Leistung erheblich gesteigert.

Stellen Sie das Aktualisierungsintervall auf täglich ein und erstellen Sie Indizes für alle Attribute:

Fremdtabelle für Echtzeitdaten verknüpfen

Zusätzlich zu der vorbereiteten materialisierten Datenabfrage können Daten aus der StableNet®-API mithilfe einer Fremdtabelle verknüpft werden.

Das FROM-Schlüsselwort im folgenden Beispiel verweist auf die oben vorbereitete materialisierte Abfrage.

SELECT   
  dm.device_id,
  dm.device_name,
  dm.measurement_name,
  dm.measurement_id,
  sma.metric_key,
  sma.metric_name,
  sma.interval,
  sma.min,
  sma.max,
  sma.avg,
  sma.timestamp
FROM device_measurement dm
JOIN stablenet_measurement_data sma 
  ON dm.measurement_id = sma.measurement_id
WHERE sma.start = ${begin}::timestamptz
  AND sma."end" = ${end}::timestamptz
  AND sma.bucket_size = EXTRACT(
    EPOCH FROM ('1 ' || ${bucket_size})::interval
  )::integer
  AND sma.metric_name = ${metric_name}

Im Dashboard oder in der Datenvorschau müssen für diese Beispielabfrage die folgenden Attribute festgelegt werden:

begin/end: ISO 8601-Zeitstempel, z. B. 2024-05-01T00:00:00Z
bucket_size: Zeitbucket in Worten wie Stunde, Tag, Monat usw.
metric_name: Ein gültiger StableNet®-Metrikname wie Round Trip Time

Anstelle des Attributs metric_name können Sie das Attribut metric_key in der WHERE-Klausel verwenden, um eine bestimmte Metrik auszuwählen, wenn mehrere verfügbar sind.

Aggregierte Datentabelle verbinden

Wenn die Leistung wichtiger ist als Echtzeitdaten, sollte die aggregierte Datentabelle den Fremdtabellen vorgezogen werden.

Das FROM-Schlüsselwort im folgenden Beispiel verweist auf die oben vorbereitete materialisierte Abfrage.

SELECT   
  dm.device_id,
  dm.device_name,
  dm.measurement_name,
  dm.measurement_id,
  sma.metric_key,
  sma.metric_name,
  sma.interval,
  sma.min,
  sma.max,
  sma.avg,
  sma.timestamp
FROM device_measurement dm
JOIN stablenet_measurement_data_aggregated sma 
  ON dm.measurement_id = sma.measurement_id
WHERE sma.timestamp BETWEEN ${begin}::timestamptz AND ${end}::timestamptz
  AND sma.metric_name = ${metric_name}

Im Dashboard oder in der Datenvorschau müssen für diese Beispielabfrage die folgenden Attribute festgelegt werden:

begin/end: ISO 8601-Zeitstempel, z. B. 2024-05-01T00:00:00Z
metric_name: Ein gültiger StableNet®-Metrikname wie Round Trip Time

Anstelle des Attributs metric_name können Sie das Attribut metric_key in der WHERE-Klausel verwenden, um eine bestimmte Metrik auszuwählen, wenn mehrere verfügbar sind.

Fremdtabellen

Name	Felder	Qualifizierer
`stablenet_info`	`server_name TEXT` `name TEXT` `version TEXT` `technical_version TEXT`
`stablenet_taggable`	`server_name TEXT` `domain TEXT` `id BIGINT` `name TEXT` `display_name TEXT` `state TEXT` `attribute_tags JSONB` `custom_tags JSONB` `tag_filter TEXT`	`domain TEXT` (obligatorisch) `id BIGINT` `tag_filter TEXT`
`stablenet_taggable_device`	`server_name TEXT` `id BIGINT` `name TEXT` `display_name TEXT` `state TEXT` `attribute_tags JSONB` `custom_tags JSONB` `tag_filter TEXT`	`id BIGINT` `tag_filter TEXT`
`stablenet_taggable_interface`	`server_name TEXT` `id BIGINT` `name TEXT` `display_name TEXT` `state TEXT` `attribute_tags JSONB` `custom_tags JSONB` `tag_filter TEXT`	`id BIGINT` `tag_filter TEXT`
`stablenet_taggable_job`	`server_name TEXT` `id BIGINT` `name TEXT` `display_name TEXT` `state TEXT` `attribute_tags JSONB` `custom_tags JSONB` `tag_filter TEXT`	`id BIGINT` `tag_filter TEXT`
`stablenet_taggable_link`	`server_name TEXT` `id BIGINT` `name TEXT` `display_name TEXT` `state TEXT` `attribute_tags JSONB` `custom_tags JSONB` `tag_filter TEXT`	`id BIGINT` `tag_filter TEXT`
`stablenet_taggable_service`	`server_name TEXT` `id BIGINT` `name TEXT` `display_name TEXT` `state TEXT` `attribute_tags JSONB` `custom_tags JSONB` `tag_filter TEXT`	`id BIGINT` `tag_filter TEXT`
`stablenet_taggable_agent`	`server_name TEXT` `id BIGINT` `name TEXT` `display_name TEXT` `state TEXT` `attribute_tags JSONB` `custom_tags JSONB` `tag_filter TEXT`	`id BIGINT` `tag_filter TEXT`
`stablenet_tag_category`	`server_name TEXT` `domain TEXT` `id BIGINT` `name TEXT` `description TEXT`	`domain TEXT` (obligatorisch) `id BIGINT`
`stablenet_measurement`	`server_name TEXT` `id BIGINT` `name TEXT` `description TEXT` `categories JSONB` `dest_device_id BIGINT` `dest_interface_id BIGINT` `agent_id BIGINT` `start_time TIMESTAMPTZ` `end_time TIMESTAMPTZ` `state TEXT` `type TEXT` `template_name TEXT` `permanent BOOL` `payload JSONB` `active BOOL` `tag_filter TEXT`	`tag_filter TEXT` `dest_device_id BIGINT`
`stablenet_measurement_metric`	`server_name TEXT` `measurement_id BIGINT` `data_id BIGINT` `description TEXT` `expected_interval INT` `key TEXT` `name TEXT` `only_average BOOL` `unit TEXT`	`measurement_id BIGINT`
`stablenet_measurement_data`	`server_name TEXTmeasurement_id BIGINTmetric_key TEXTmetric_name TEXT"start" TIMESTAMPTZ"end" TIMESTAMPTZbucket_size INT`(Sekunden) `"timestamp" TIMESTAMPTZ` `min double precision` `max double precision` `avg double precisiontag_filter TEXT`	`measurement_id BIGINTmetric_key TEXT"start" TIMESTAMPTZ`(obligatorisch) `"end" TIMESTAMPTZ`(obligatorisch) `bucket_size INT`(obligatorisch) `tag_filter TEXT`

Obwohl measurement_id und metric_key optional sind, wird es nicht empfohlen, Abfragen ohne diese durchzuführen. Dadurch werden die Messdaten aller Messungen und aller Metriken gelesen, was sehr lange dauern kann und den StableNet-Server stark belastet. Nur für sehr kurze Zeiträume < 1 Stunde empfehlenswert. Wenn mehrere Messungen und Metriken benötigt werden, sollte die Tabelle stablenet_measurement_data_aggregated verwendet werden.

Aggregierte Messdaten

Aggregiert nach Stunden, wird automatisch stündlich aktualisiert. Kann verwendet werden, um Analyseabfragen über einen großen Bereich von Messungen und über große Zeiträume durchzuführen.

Im Grunde handelt es sich um eine Timescale-Hypertabelle (https://docs.timescale.com/ ). Die Chunk-Größe beträgt 7 Tage, Chunks werden nach 7 Tagen komprimiert.

Name	Felder
`stablenet_measurement_data_aggregated`	`server_name TEXT` `measurement_id BIGINT` `metric_key TEXT` `metric_name TEXT` `"timestamp" TIMESTAMPTZ NOT NULL` `min double precision` `max double precision` `avg double precision`

stablenet_measurement_data_aggregated Enthält nur Daten für konfigurierte Metrikschlüssel.