O Data Integration do DataWorks lê mensagens de tópicos do Kafka e as grava em tabelas do AnalyticDB for MySQL por meio de uma tarefa de sincronização em lote executada em um grupo de recursos exclusivo para Data Integration.
Pré-requisitos
Adquira um grupo de recursos exclusivo para Data Integration que atenda aos seus requisitos de negócio. Para mais informações, consulte Criar e usar um grupo de recursos exclusivo para Data Integration.
Estabeleça conexões de rede entre o grupo de recursos exclusivo para Data Integration e suas fontes de dados (Kafka e AnalyticDB for MySQL). Para mais informações, consulte Estabelecer uma conexão de rede entre um grupo de recursos e uma fonte de dados.
Crie uma tarefa de sincronização em lote
Configure o leitor de source do Kafka e o gravador de destino do AnalyticDB for MySQL. Em seguida, crie uma tarefa de sincronização para conectá-los.
-
Etapa 1: Configure o Kafka Reader
Configure o leitor de source para ler dados do cluster Kafka.
Para obter detalhes da configuração, consulte Kafka Reader.
-
Etapa 2: Configure o AnalyticDB for MySQL 3.0 Writer
Configure o gravador de destino para gravar dados na tabela do AnalyticDB for MySQL.
Para obter detalhes da configuração, consulte AnalyticDB for MySQL 3.0 Writer.
-
Etapa 3: Crie a tarefa de sincronização
Combine o Kafka Reader e o AnalyticDB for MySQL 3.0 Writer em um trabalho de sincronização. A interface visual sem código do DataWorks permite configurar source, destino e mapeamentos de campos sem escrever código.
Para instruções passo a passo, consulte Configure uma tarefa de sincronização em lote usando a interface visual sem código.