190 fonctionnalités, une seule plateforme

Support des bases de données en sourceLecture de vos bases, par ODBC ou client dédié Support des API en sourceIngestion de données via API Support des fichiers en sourceIngestion de fichiers plats Support des journaux (logs) en sourceIngestion de fichiers de journalisation Support des flux temps réelIngestion de flux de données en continu Support fichiers CSVLecture et exploitation de fichiers CSV Support fichiers JSONLecture et exploitation de fichiers JSON Support fichiers texte (.txt)Lecture de texte brut Support fichiers XMLLecture de fichiers XML Support fichiers .logLecture de fichiers de logs Chargement de fichiers en bloc binaireFichiers non-texte stockés en binaire Pipelines ETL optimisésExtract / Transform / Load intégrés Extraction de donnéesExtraction depuis sources hétérogènes Transformation de données en transitTransformation avant restitution Chargement en temps réelChargement continu des données Ingestion haute performanceGestion efficace des flux entrants Métriques Prometheus et OpenMetricsLes métriques de vos machines comme source de flux

Support HTTP(s)Communication HTTP sécurisée Support MQTT(s)Publish/subscribe MQTT Encodeur/décodeur JSONConversion JSON Encodeur/décodeur CSVLecture et écriture de CSV, dialecte et encodage réglables Encodeur/décodeur StructConversion Struct Encodeur/décodeur CayenneLPPConversion CayenneLPP Encodeur/décodeur TexteConversion texte Message queueingFile d'attente de messages Gestion des priorités de messagesOrdonnancement des tâches Support AMQPFile de messages AMQP Support RabbitMQBroker RabbitMQ, par le protocole AMQP Support Z-WavePlugin protocole Z-Wave Support rtl433Plugin protocole rtl433 Support BLEPlugin Bluetooth Low Energy Support BACnet/IPPlugin protocole BACnet/IP Support ModbusDécodeur spécifique par dispositif Commandes descendantes vers capteursEnvoi de commandes aux devices Remontée ascendante de donnéesCollecte des données vers le SI Support OPC UALecture des serveurs OPC UA de vos automates Support Siemens S7Lecture directe des automates Siemens Support CoAPÉchanges avec les objets contraints, en client et en serveur Support gRPCÉchanges binaires performants, flux continus compris Modbus RTU et port sérieLecture sur bus série, y compris en écoute passive Support LwM2MModèle standard pour la gestion d'objets

End-pointsConnexion au monde extérieur End-points prédéfinisPostgreSQL, ThingsBoard… Connecteur génériqueProtocoles génériques (HTTP, MQTT…) Connecteurs spécifiques backendGestion des spécificités backend Connecteur partagé multi-end-pointsUn connecteur pour plusieurs end-points ImportateurGestion des charges utiles entrantes ExportateurEnvoi vers systèmes externes Exportateurs personnalisésExport sur mesure via module Mappeur (mapping)Correspondance données brutes → modèle Alignement multi-schémasCartographie de structures hétérogènes Support E/S bas niveauCommunication matérielle intégrée Templates d'exportFormatage de charges utiles complexes TemplatingGénération automatique de sorties formatées Exportation multiple simultanéeEnvoi vers plusieurs cibles en parallèle Connexion ODBC aux basesUn même pilote pour PostgreSQL, SQL Server, Oracle et les autres Connecteur ThingsBoard (clé en main)Export vers ThingsBoard Connecteur InfluxDB (clé en main)Export vers InfluxDB Connecteur TSorage (clé en main)Export vers TSorage Connecteur MongoDBExport vers MongoDB (config spécifique) Export vers GrafanaPar la base temporelle que Grafana interroge Échangeur HTTPSortie HTTP (format à spécifier) Échangeur MQTTSortie MQTT (format à spécifier) Échangeur RabbitMQSortie RabbitMQ (format à spécifier) Connecteurs personnalisésCréation de connecteurs sur mesure PostgreSQL par ODBCÉcriture dans vos tables PostgreSQL

Data-modelDescription des objets et données Data-models prédéfinisZWave, CayenneLPP, OneIOTA, HGI… Data-models personnalisésModèles définis par l'utilisateur Info-model (modèle d'information)Organisation hiérarchique événementielle Multi Data-ModellingModélisation adaptable en périphérie (edge) Couche sémantique configurableLogiques d'enrichissement dynamiques Définition libre d'attributsValeurs, règles, déclencheurs Opération bidirectionnelleCirculation des données dans les 2 sens Gestion des événementsRéaction temps réel aux stimuli Exécution synchroneTraitement immédiat dans le flux Exécution asynchroneTraitement différé / parallèle ModularitéComposants instanciables et configurables ExtensibilitéCroissance sans refonte majeure ProgrammabilitéCodage direct des traitements DataCell, un espace de travail isoléChaque projet dans son espace, sans mélange Bibliothèque de modèles réutilisablesRejouer une chaîne déjà construite Modification à chaud, validation, redémarragePréparer, vérifier, appliquer : dans cet ordre Support bases SQLChoix moteur SQL selon besoin Support bases NoSQLChoix moteur NoSQL selon besoin Gestion des métadonnéesOrganisation optimale des données Persistance des données activableStockage en DB optionnel Table opération supportStructure de stockage des opérations (CSV/TXT/JSON) Préparer des jeux de donnéesDes tables propres pour vos outils d'analyse et d'IA Dépôts de fichiers, local, S3 et archiveOù le moteur lit et dépose les fichiers Tables de données et transformationsAssembler, nettoyer et agréger avant d'envoyer Historisation par dataloggerGarder les dernières valeurs sur place, sans base

Suppression des valeurs manquantesRetrait des enregistrements incomplets Suppression des doublonsDéduplication des enregistrements Contrôle de cohérenceVérification de la cohérence des données Regroupement (grouping)Regroupement de données Filtrage des donnéesFiltrage à l'ingestion Correction adaptative en temps réelRectification des incohérences en flux Enrichissement sémantiqueEnrichissement des données brutes Filtrage contextuelFiltrage selon le contexte métier Agrégation des donnéesRegroupement pour analyse ciblée Segmentation en groupesDécoupage en groupes cohérents Agrégats sur vos tablesSomme, moyenne, minimum, maximum, comptage, par groupe Réduction des données (compression)Compression pour accélérer les traitements Sous-échantillonnageRéduction de volume par échantillonnage Optimisation des structures de modèlesStructures optimisées pour le calcul Faible empreinte ressourcesMoteur léger, installé au plus près des sources Traitement parallèleCalculs en parallèle Colonnes calculées par expressionCalculer une valeur sur chaque ligne, sans écrire de programme Règles d'intégritéGarantie d'intégrité des données Règles d'unicitéGarantie d'unicité Règles de cohérenceGarantie de cohérence

Orchestration des workflowsEnchaînement fluide des étapes Nettoyage automatisé en temps réelNettoyage sans intervention manuelle Mise à jour des données en temps réelActualisation continue Surveillance proactive des pipelinesMonitoring continu Détection d'anomaliesAlerte sur anomalies de flux Scheduling par calendrier programméDéclenchement planifié Scheduling événementielDéclenchement sur événement système Scheduling conditionnelDéclenchement selon conditions utilisateur Interrogation dynamique d'une sourceRequête à la demande à tout instant Collecte instantanée sur événementCollecte en réaction à un signal Exécution à la demandeTraitements manuels/ponctuels Règles d'attachement automatiqueUn traitement s'applique à tout ce qui remplit la condition Jobs (actions ciblées)Actions sur objets/types d'objets Job EngineOrchestration et exécution des jobs Opérations unitairesFiltrage, nettoyage simples Agrégations conditionnelles multi-niveauxTraitements avancés paramétrables Prise en charge des métadonnéesContextualisation via métadonnées Multi-opération (séquentielle/simultanée)Traitements multiples dans un pipeline Calculs mathématiquesOpérations mathématiques sur données Filtres conditionnelsFiltres selon conditions Exécution de blocs de code personnalisésCode sur mesure dans le flux

Topologie de déploiement en étoile1 mère → n filles Communication mère-fille HTTP(s)Connexion inter-instances HTTP Communication mère-fille MQTT(s)Connexion inter-instances MQTT Hiérarchie multi-instancesInterconnexion pour grands sites Superviseur globalToutes les mères reliées à un superviseur Compteurs instantanésÉtat à un instant T (ex. nb sources) AccumulateursCumul sur période (ex. volume échangé) Collecte & agrégation périodiqueAgrégation des métriques Identifiant unique par instanceTraçabilité des instances Agrégation par période (jour/semaine/mois)Regroupement temporel API REST de supervision (JSON)Récupération des métriques Transmission push-onlyContournement des pare-feu Résilience des données non transmisesConservation puis envoi différé Métrique Active-sourcesNombre de sources actives Métrique Egress-dataVolume de données sortantes (octets) Stockage des métriques (InfluxDB)Historisation des métriques Sauvegardes périodiques des métriquesRétention des données de supervision Agrégation avancée de supervisionMétriques détaillées par sous-système Surveillance temps réel des performancesSuivi latence / temps de réponse Alarmes du moteurCe qui ne va pas, par DataCell et par composant Journal d'exécution et tâches en coursCe que le moteur fait, en direct

Interface UI ID4ConnectIHM de configuration de l'instance Interface ExpertConfiguration avancée des modules Gestion des sources (matériel/fichier)Ajout et gestion des sources Configuration des décodeursSélection du décodeur adapté Configuration des Data ModelsModèle de données via UI Configuration du MappingAssociation décodeur ↔ modèle Configuration des End PointsChoix du système distant Configuration des JobEnginesTraitements spécifiques via UI Tableau de supervision (UI)Compteurs de consommation par instance Import de fichiers via l'UIFonction « Importer des fichiers » Prétraitement de fichiers (UI)Nettoyage, correction, fusion, typage Édition des champs de tableRenommage / typage des colonnes Création de data-model via UI ExpertAssistant de création de modèle

Authentification identifiant/mot de passeContrôle d'accès à l'UI Gestion des identifiants (on-premise/cloud)Admin. locale ou ID4Connect Audit & traçabilitéSuivi des modifications Transmission sécurisée HTTPS/MQTTCommunication chiffrée inter-instances Masquage des données sensibles en transitRetirer ou remplacer un champ avant qu'il ne parte Vos données restent chez vousTraitement sur votre infrastructure, sans copie extérieure Gestionnaire d'identifiantsLes secrets des connexions, hors des configurations Déploiement image DockerPackage conteneurisé Déploiement package Debian (.deb)Installation native Déploiement via Docker ComposeOrchestration de conteneurs Support Linux (systemd)Distributions Linux avec systemd Gestion apt / dpkgGestionnaire de paquets Debian Support ARM32 (armv7)Architecture ARM 32 bits Support ARM64 (armv8)Architecture ARM 64 bits Support x86 / AMD64Architecture Intel/AMD Gestion via systemctlStart/stop/status du service Journaux via journalctlConsultation des logs Fichier de configuration config.yamlParamétrage d'exécution Chargement de plugins externesVolume /opt/dmway/plugins API DMWay exposée (port 8000)Interface API du moteur Déploiement edge / gatewayInstallation au plus près des sources Déploiement serveur / hybrideFlexibilité de déploiement Gestion de licence (MAC / ID unique)Fichier license.lic + mise à jour