Construction système monitoring time-series robuste : Intégration RTI Connext DDS, Telegraf, InfluxDB

Pourquoi Combiner DDS, Telegraf, et InfluxDB ?

En IIoT industriel, visibilité temps-réel dans télémétrie dispositifs est critique. RTI Connext DDS délivre distribution données low-latence, scalable, tandis qu'InfluxDB excelle à stocker et requêter métriques time-series. Telegraf, collecteur métriques lightweight de InfluxData, bridge les deux en ingérant données DDS et les forwardant vers InfluxDB (ou autres destinations). Cette architecture offre pipeline monitoring flexible, haute performance adaptable à tout déploiement IIoT.

Introduction Plugin Input Telegraf Connext DDS

Jusqu'à récemment, Telegraf manquait plugin input DDS natif, limitant sa capacité à consommer données depuis Connext DDS directement. Le plugin dds_consumer comble ce gap. Il tourne comme service background, écoutant messages DDS via WaitSets, et pousse métriques parsées dans buffer interne Telegraf pour traitement downstream.

Fonctionnalités Clés

• Opération style service : forward automatiquement échantillons DDS entrants sans polling.
• Support format JSON, sérialisation la plus commune pour démos DDS.
• Tags configurables, noms measurement, mappings champs.
• Compatible avec processors et aggregators built-in Telegraf pour gestion métriques avancée.

Aperçu Développement Plugin

Framework plugin Telegraf définit set interfaces. Un input plugin implémente méthodes Sample et SampleSet, tandis qu'un service plugin ajoute fonctions Start et Stop pour gérer threads background. Le plugin dds_consumer leverages ces pour spawner listener réagissant aux arrivées DDS.

Démarrage : Configuration Basics

Fichiers configuration Telegraf sont écrits en TOML. Plugin requiert fichier XML additionnel décrivant entités DDS (Participant, Publisher, Subscriber, Reader, etc.). Ci-dessous exemple minimal lisant topic DDS Square publié par RTI Shapes demo et écrivant métriques vers fichier local.

[[inputs.dds_consumer]] ## Path to the DDS XML description config_path = "example_configs/ShapeExample.xml" ## DDS Participant configuration name participant_config = "MyParticipantLibrary::Zero" ## DDS DataReader configuration name reader_config = "MySubscriber::MySquareReader" ## Tag keys extracted from the DDS payload tag_keys = ["color"] ## Override default measurement name name_override = "shapes" ## Expected data format data_format = "json" 

Pour générer configuration Telegraf complète incluant cet input et file output, exécutez :

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

Après publication échantillon Square dans Shapes demo, métriques apparaîtront dans /tmp/metrics.out.

Basculement vers Output InfluxDB

Remplacez file output par InfluxDB en régénérant config :

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

Amélioration Votre Pipeline Métriques

Écosystème Telegraf inclut plusieurs plugins built-in ajoutant valeur :

Aggregators

Calculent statistiques comme mean, min, max, standard deviation over time :

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

Processors

Renomment ou transforment champs avant stockage :

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

Ces outils vous permettent d'adapter modèle données à vos besoins monitoring, whether you need raw samples, aggregated summaries, ou custom field names.

Ressources et Support Communautaire

Le plugin fait partie de RTI Labs, programme gratuit donnant accès early à technologie RTI. Trouvez code source, documentation, configurations exemple sur GitHub :

• RTI Community Telegraf Plugin
• Example Configurations

Pour questions, feedback, feature requests, visitez RTI Community forum ou ouvrez issue sur GitHub.

Conclusion

Le plugin Telegraf Connext DDS débloque pipeline puissant, low-overhead pour ingérer télémétrie DDS dans InfluxDB. En combinant architecture extensible Telegraf avec middleware DDS RTI, vous pouvez construire solution monitoring time-series scalable, trustworthy pour tout scénario IIoT.