Data Transmission Service:Criar um canal de rastreamento de alterações do PolarDB for MySQL

Pré-requisitos

Ative o recurso de binary logging no cluster PolarDB for MySQL de origem. Para mais informações, consulte Enable binary logging.

Observações de uso

• Ferramentas como gh-ost ou pt-online-schema-change não rastreiam alterações de DDL online. O cliente pode falhar ao gravar os dados consumidos na tabela de destino devido a incompatibilidades de esquema.

• Se o banco de dados de origem for utilizado em outra tarefa, como migração de dados, informações fora do escopo da assinatura poderão ser rastreadas. Filtre os dados indesejados na aplicação cliente.

Procedimento

1. Adquira um canal de rastreamento de alterações. Para mais informações, consulte Purchase a change tracking task.

   Nota

   Ao adquirir o canal, defina

   Source database

   como

   PolarDB

   e selecione a região onde está localizado o cluster PolarDB for MySQL de origem.

2. Faça login no DTS console

   .

3. No painel de navegação à esquerda, clique em Change Tracking.

4. Na página Change Tracking Tasks, selecione a região da instância de rastreamento de alterações.

5. Localize o canal adquirido e clique em Configure channel.

6. Configure as informações do banco de dados de origem e o tipo de rede.

   Seção	Parâmetro	Descrição
   N/A	Task name	O DTS gera automaticamente um nome para a tarefa. Recomendamos especificar um nome descritivo para facilitar a identificação. O nome não precisa ser único.
   Source database	Instance type	Definido como PolarDB instance. Não é possível alterar esse valor.
   	Database type	Definido como PolarDB. Não é possível alterar esse valor.
   	Instance region	Corresponde à região de origem selecionada durante a aquisição do canal. Não é possível alterar este parâmetro.
   	PolarDB instance ID	Selecione o ID do cluster PolarDB for MySQL de origem.
   	Database account	Insira a conta do banco de dados do cluster PolarDB for MySQL de origem. Nota A conta deve ter as permissões REPLICATION CLIENT, REPLICATION SLAVE, SHOW VIEW e SELECT nos objetos da assinatura.
   	Database password	Insira a senha da conta do banco de dados.
   Network type	N/A	Especifique o tipo de rede do canal. Classic Network Se definir o tipo de rede como Classic Network, nenhuma configuração adicional será necessária. What is a classic network?. Proprietary Network Se definir o tipo de rede como Proprietary Network, também será necessário selecionar uma Proprietary Network e um vSwitch. What is a VPC?. Nota Selecione o mesmo tipo de rede da instância ECS onde o cliente de assinatura está implantado. Por exemplo, se a instância ECS estiver em uma VPC, selecione VPC como tipo de rede e especifique a Proprietary Network e o vSwitch. Conexões de rede privada minimizam a latência.

7. Clique em Set whitelist and next.

   O DTS adiciona automaticamente os endereços IP dos servidores DTS da região correspondente à lista de permissões da instância de banco de dados Alibaba Cloud. Para obter a lista de endereços IP dos servidores DTS, consulte IP address ranges of DTS servers.

   Aviso

   Adicionar blocos CIDR públicos apresenta riscos de segurança. Use senhas fortes, restrinja portas abertas, autentique APIs internas, revise o acesso à rede regularmente e utilize conexões privadas por meio do Express Connect, VPN Gateway ou Smart Access Gateway.

8. Configure os tipos de dados e os objetos a serem rastreados.

   Parâmetro	Descrição
   Required data types	Data Update Assina alterações de dados (operações INSERT, DELETE e UPDATE) para os objetos selecionados. Schema Update Assina alterações de esquema (operações CREATE, DROP e ALTER) para todos os objetos da instância. Filtre os dados necessários na aplicação cliente. Nota Selecionar um banco de dados inteiro também rastreia alterações em objetos adicionados posteriormente. Selecionar uma tabela específica rastreia apenas essa tabela. Para rastrear novas tabelas, adicione-as aos objetos da assinatura. Modify the objects for change tracking.
   Required objects	Na caixa Required Objects, selecione os objetos a serem rastreados e clique no ícone para movê-los para a caixa Selected Objects. Nota É possível selecionar objetos no nível do banco de dados ou da tabela.

9. Clique em Save and Precheck.

   Nota

   • A tarefa só inicia após passar na verificação prévia.

   • Se a verificação prévia falhar, clique no ícone

     ao lado do item com falha para obter detalhes. Corrija o problema e execute a verificação prévia novamente.

10. Quando a mensagem Precheck Passed aparecer na caixa de diálogo Precheck, feche a caixa de diálogo Precheck.

Próximas etapas

Após a configuração, o canal leva cerca de um minuto para inicializar. Quando a inicialização for concluída, execute as seguintes operações:

1. Create a consumer group

2. Consume subscribed data by using a Kafka client

3. Consume subscribed data by using SDK sample code