O Data Transmission Service (DTS) utiliza uma arquitetura modular desenvolvida para alta disponibilidade (HA). Cada módulo opera em servidores com redundância primária/secundária. O gerenciador de HA monitora continuamente a integridade de todos os servidores e, ao detectar uma exceção, transfere as cargas de trabalho para um servidor íntegro com latência mínima. Em replicações contínuas — como sincronização de dados e rastreamento de alterações — o gerenciador de HA também identifica mudanças nos endpoints das fontes de dados e configure a conexão automaticamente.
-
Redundância primária/secundária
Cada módulo do DTS é implantado em uma arquitetura primária/secundária para fornecer redundância. O sistema de recuperação de desastres execute verificações de integridade contínuas em cada servidor. Se houver falha em um servidor, o sistema transfere suas cargas de trabalho para um servidor íntegro com latência mínima.
-
Detecção dinâmica de endpoint
Nas tarefas de sincronização de dados e rastreamento de alterações, o sistema de recuperação de desastres detecta modificações no endpoint da fonte de dados. Quando uma mudança é identificada, o sistema reconfigura a fonte de dados para manter a estabilidade da conexão.
Funcionamento do DTS no modo de migração de dados
Uma migração de dados completa passa por três fases sequenciais: migração de schema, migração completa de dados e migração incremental de dados. Selecione todas as três fases ao configurar uma tarefa de migração de dados — isso mantém o banco de dados source operacional durante todo o processo.
Migração de schema: O DTS recria o schema no banco de dados de destino antes de mover qualquer dado. Para migrações entre bancos de dados heterogêneos, o DTS analisa a DDL (Linguagem de Definição de Dados) do banco de dados source, traduz para a sintaxe do banco de dados de destino e recria os objetos de schema.
Migração completa de dados: O DTS migra os dados históricos do source para o destino. O banco de dados source permanece online e continua aceitando gravações durante esta fase. Para capturar essas gravações contínuas, o DTS ativa um leitor de dados incrementais no início da migração completa. Os dados incrementais são analisados, reformatados e armazenados localmente no servidor DTS enquanto a migração completa está em execução.
Migração incremental de dados: Após a conclusão da migração completa, o DTS recupera os dados incrementais armazenados localmente e os aplica ao destino. Esta fase continua até que o destino esteja sincronizado com o source e o atraso de replicação atinja um estado estável.
Funcionamento do DTS no modo de sincronização de dados
O modo de sincronização de dados replica alterações contínuas entre dois armazenamentos de dados. É comumente utilizado para replicações OLTP-to-OLAP, onde o OLTP (processamento transacional online) gerencia cargas de trabalho transacionais e o OLAP (processamento analítico online) lida com consultas analíticas.
Uma tarefa de sincronização de dados execute duas fases em sequência:
Sincronização inicial de dados: O DTS sincroniza os dados históricos do source para o destino.
Sincronização de dados em tempo real: O DTS replica continuamente as alterações de dados em andamento para manter o destino sincronizado com o source.
Dois componentes gerenciam a replicação contínua:
Leitor de log de transações: Conecta-se à instância source pelo protocolo apropriado — por exemplo, via protocolo binlog dump para uma instância ApsaraDB RDS for MySQL. Ele lê logs incrementais, analisa, filtra e converte os dados antes de persisti-los localmente no servidor DTS.
Aplicador de log de transações: Recupera atualizações do leitor de log de transações, filtra alterações não relacionadas aos objetos replicados e aplica as mudanças restantes ao banco de dados de destino. O aplicador preserva as propriedades ACID (atomicidade, consistência, isolamento e durabilidade) de cada transação.
Ambos os componentes operam em modo de redundância. Se ocorrer uma exceção em qualquer um deles, o gerenciador de HA retoma a execução do log de transações em um servidor íntegro.
Funcionamento do DTS no modo de rastreamento de alterações
O modo de rastreamento de alterações fornece acesso em tempo real aos logs de dados incrementais de uma instância ApsaraDB RDS. Consuma os logs no servidor de rastreamento de alterações usando SDKs do DTS e defina regras personalizadas de consumo de dados conforme suas necessidades.
O processador de logs conecta-se à instância source pelo protocolo adequado — por exemplo, via protocolo binlog dump para uma instância ApsaraDB RDS for MySQL. Ele lê os logs incrementais, analisa, filtra e converte a sintaxe antes de armazenar os dados localmente no servidor DTS.
O DTS garante alta disponibilidade em dois níveis:
HA do processador de logs: Ao detectar uma exceção no processador de logs, o gerenciador de HA reinicia o processador em um nó de serviço íntegro.
HA de consumo via SDK: Inicie múltiplos processos de consumo baseados em SDK para uma única tarefa de rastreamento de alterações. O servidor envia dados incrementais por meio de um processo por vez. Se esse processo encontrar uma exceção, o servidor muda automaticamente para outro processo de consumo.