Pour simplifier l'utilisation du SDK, Data Transmission Service (DTS) met en œuvre un mécanisme de tolérance aux pannes. Ce mécanisme repose sur la transmission en temps réel de l'horodatage de consommation au nœud de contrôle central de DTS lorsque le SDK traite les données. Cette rubrique explique comment utiliser ce mécanisme.
Dans le code de consommation des messages du SDK, chaque traitement de message appelle l'API ackAsConsumed pour signaler l'horodatage de consommation à DTS.
Un canal de souscription requiert le démarrage d'au moins un SDK principal et d'un SDK secondaire.
Architecture de consommation
Au sein d'un canal de souscription DTS, un seul SDK peut extraire les données incrémentielles. Si plusieurs SDK descendants sont présents dans un même canal, seul l'un d'eux reçoit ces données. Il est ainsi possible de mettre en place une architecture de tolérance aux pannes pour le SDK.
Dans l'exemple d'architecture illustré ci-dessus, deux SDK descendants sont connectés à un seul canal de souscription. L'un sert de SDK principal, l'autre de SDK secondaire. Sur une même période, seul le SDK principal s'abonne aux données incrémentielles et les consomme. En cas d'exception sur le SDK principal ou de problème de connexion réseau, DTS déclenche un basculement automatique vers le SDK secondaire et démarre ce dernier en utilisant le dernier horodatage de consommation connu. À chaque consommation de message, le SDK principal envoie un message ACK au système de contrôle de DTS, signalant ainsi l'horodatage de consommation.