Data Integration de DataWorks lit les messages des topics Kafka et les écrit dans les tables AnalyticDB for MySQL via une tâche de synchronisation par lots exécutée sur un groupe de ressources exclusif Data Integration.
Prérequis
Achetez un groupe de ressources exclusif Data Integration adapté à vos besoins métier. Pour plus d'informations, consultez la rubrique Créer et utiliser un groupe de ressources exclusif pour Data Integration.
Établissez les connexions réseau entre le groupe de ressources exclusif Data Integration et vos sources de données (Kafka et AnalyticDB for MySQL). Pour plus d'informations, consultez la rubrique Établir une connexion réseau entre un groupe de ressources et une source de données.
Créer une tâche de synchronisation par lots
Configurez le lecteur source Kafka et le rédacteur de destination AnalyticDB for MySQL, puis créez la tâche de synchronisation qui les relie.
-
Étape 1 : Configurer le lecteur Kafka
Configurez le lecteur source pour lire les données depuis votre cluster Kafka.
Pour les détails de configuration, consultez la rubrique Lecteur Kafka.
-
Étape 2 : Configurer le rédacteur AnalyticDB for MySQL 3.0
Configurez le rédacteur de destination pour écrire les données dans votre table AnalyticDB for MySQL.
Pour les détails de configuration, consultez la rubrique Rédacteur AnalyticDB for MySQL 3.0.
-
Étape 3 : Créer la tâche de synchronisation
Associez le lecteur Kafka et le rédacteur AnalyticDB for MySQL 3.0 au sein d'une tâche de synchronisation. L'interface sans code de DataWorks permet de configurer la source, la destination et les mappages de champs sans écrire de code.
Pour des instructions détaillées, consultez la rubrique Configurer une tâche de synchronisation par lots à l'aide de l'interface sans code.