Een Robuust Time‑Series Monitoring Systeem Bouwen: RTI Connext DDS Integreren met Telegraf en InfluxDB

Waarom DDS, Telegraf, en InfluxDB Combineren?

In industriële IoT is real‑time zichtbaarheid in device telemetrie cruciaal. RTI Connext DDS levert lage‑latentie, schaalbare datadistributie, terwijl InfluxDB uitblinkt in het opslaan en opvragen van time‑series metrics. Telegraf, de lichtgewicht metrics collector van InfluxData, overbrugt de twee door DDS data te consumeren en door te sturen naar InfluxDB (of andere bestemmingen). Deze architectuur biedt een flexibele, hoge‑prestatie monitoring pipeline die aangepast kan worden aan elke IIoT implementatie.

De Telegraf Connext DDS Input Plugin Introduceren

Tot onlangs ontbrak Telegraf een native DDS input plugin, wat de capaciteit beperkte om data van Connext DDS direct te consumeren. De dds_consumer plugin vult die kloof. Het draait als achtergrondservice, luistert naar DDS berichten via WaitSets, en duwt geparsede metrics in Telegraf's interne buffer voor downstream verwerking.

Belangrijkste Kenmerken

• Service‑stijl operatie: stuurt binnenkomende DDS samples automatisch door zonder polling.
• Ondersteunt JSON dataformaat, de meest voorkomende serialisatie voor DDS demo's.
• Configureerbare tags, meetnamen, en veldmappings.
• Compatibel met Telegraf's ingebouwde processors en aggregators voor geavanceerde metric handling.

Plugin Ontwikkeling Overzicht

Telegraf's plugin framework definieert een set interfaces. Een input plugin implementeert Sample en SampleSet methoden, terwijl een service plugin Start en Stop functies toevoegt om achtergrondthreads te managen. De dds_consumer plugin benut deze om een listener te spawnen die reageert op DDS aankomsten.

Aan de Slag: Configuratie Basis

Telegraf configuratiebestanden zijn geschreven in TOML. De plugin vereist een additioneel XML bestand dat DDS entiteiten beschrijft (Participant, Publisher, Subscriber, Reader, etc.). Hieronder is een minimaal voorbeeld dat een DDS Square topic leest gepubliceerd door de RTI Shapes demo en metrics schrijft naar een lokaal bestand.

[[inputs.dds_consumer]] ## Pad naar de DDS XML beschrijving config_path = "example_configs/ShapeExample.xml" ## DDS Participant configuratie naam participant_config = "MyParticipantLibrary::Zero" ## DDS DataReader configuratie naam reader_config = "MySubscriber::MySquareReader" ## Tag keys geëxtraheerd uit de DDS payload tag_keys = ["color"] ## Override standaard meetnaam name_override = "shapes" ## Verwacht dataformaat data_format = "json" 

Om een volledige Telegraf configuratie te genereren die deze input en een file output bevat, voer uit:

$ telegraf --input-filter dds_consumer --output-filter file config > dds_to_file.conf $ telegraf -config dds_to_file.conf 

Na het publiceren van een Square sample in de Shapes demo, verschijnen metrics in /tmp/metrics.out.

Overschakelen naar InfluxDB Output

Vervang de file output door InfluxDB door de config te regenereren:

$ telegraf --input-filter dds_consumer --output-filter influxdb config > dds_to_influx.conf $ telegraf -config dds_to_influx.conf 

Uw Metrics Pipeline Verbeteren

Telegraf's ecosysteem omvat diverse ingebouwde plugins die waarde toevoegen:

Aggregators

Bereken statistieken zoals gemiddelde, min, max, en standaarddeviatie over tijd:

[[aggregators.basicstats]] period = "10s" drop_original = false 

Processors

Hernoem of transformeer velden voor opslag:

[[processors.rename]] [[processors.rename.replace]] field = "x" dest = "y_trans" [[processors.rename.replace]] field = "y" dest = "x_trans" 

Deze tools stellen u in staat het datamodel aan uw monitoringbehoeftes aan te passen, of u nu raw samples, geaggregeerde samenvattingen, of custom veldnamen nodig heeft.

Bronnen en Community Ondersteuning

De plugin is onderdeel van RTI Labs, een gratis programma dat vroege toegang geeft tot RTI technologie. Vind de broncode, documentatie, en voorbeeldconfiguraties op GitHub:

• RTI Community Telegraf Plugin
• Voorbeeldconfiguraties

Voor vragen, feedback, of feature requests, bezoek het RTI Community forum of open een issue op GitHub.

Conclusie

De Telegraf Connext DDS plugin ontgrendelt een krachtige, lage‑overhead pipeline voor het consumeren van DDS telemetrie in InfluxDB. Door Telegraf's uitbreidbare architectuur te combineren met RTI's DDS middleware, kunt u een schaalbare, betrouwbare time‑series monitoring oplossing bouwen voor elk IIoT scenario.