Este tópico descreve como usar o DTS para sincronizar dados de uma instância PolarDB-X 1.0 com um cluster Elasticsearch.
Pré-requisitos
A instância PolarDB-X 1.0 de origem deve usar o ApsaraDB RDS for MySQL como tipo de armazenamento. Isso inclui instâncias personalizadas e adquiridas separadamente do ApsaraDB RDS. O PolarDB for MySQL não é suportado.
crie um cluster Elasticsearch de destino. Para mais informações, consulte Create an Alibaba Cloud Elasticsearch instance.
O espaço de armazenamento disponível do cluster Elasticsearch de destino deve exceder o tamanho total dos dados da instância PolarDB-X 1.0 de origem.
Considerações
|
Tipo |
Descrição |
|
Limites do banco de dados de origem |
|
|
Outros limites |
|
|
Outras observações |
O DTS atualiza periodicamente a tabela |
Se os objetos sincronizados pelo DTS forem aliases de índice no Elasticsearch de destino, podem ocorrer inconsistências de dados caso o índice real apontado pelo alias seja alterado. Por exemplo, o alias aponta para o índice A durante a gravação de dados, mas aponta para o índice B durante a sincronização subsequente de operações de exclusão. Nesse caso, o DTS não consegue excluir os dados no índice A, e os dados já excluídos da origem continuam disponíveis para consulta no destino.
Faturamento
|
Tipo de sincronização |
Preço |
|
Sincronização de esquema e sincronização completa de dados |
Gratuito. |
|
Sincronização incremental de dados |
Cobrado. Para mais informações, consulte Billing overview. |
Operações SQL para sincronização incremental
Tipo de operação | Instrução SQL |
DML | INSERT, UPDATE e DELETE Nota O DTS não suporta a remoção de colunas por meio de instruções UPDATE na sincronização. |
Permissões para contas de banco de dados
|
Instância |
Permissões necessárias |
Referências |
|
Instância PolarDB-X 1.0 de origem |
Permissão de leitura nos objetos a serem sincronizados. |
|
|
Instância Elasticsearch de destino |
A conta do banco de dados deve ter permissões de leitura e gravação. Normalmente, esta é a conta elastic. |
|
Mapeamento de tipos de dados
-
Um banco de dados de origem e uma instância do Elasticsearch suportam diferentes tipos de dados que nem sempre têm mapeamento direto. Durante a inicialização da estrutura, o DTS mapeia os tipos de dados com base naqueles suportados pela instância Elasticsearch de destino. Para mais informações, consulte Data type mapping for structure initialization.
NotaDurante o processo de migração de esquema do DTS, o DTS não define o parâmetro
dynamicemmapping. O comportamento desse parâmetro depende das configurações da sua instância do Elasticsearch. Se seus dados de origem forem do tipo json, garanta que, para uma chave específica, seus valores correspondentes tenham o mesmo tipo de dados em todas as linhas de uma tabela. Caso contrário, o DTS poderá encontrar problemas de sincronização. Para mais informações, consulte dynamic. -
O mapeamento entre o Elasticsearch e um banco de dados relacional varia de acordo com a versão do Elasticsearch.
ImportanteA partir do Elasticsearch 7.0, um índice não suporta mais vários tipos, e os tipos foram completamente removidos no Elasticsearch 8.0. Por padrão, ao configurar uma tarefa de sincronização ou migração, o DTS mapeia uma tabela de um banco de dados relacional para um índice no Elasticsearch. Altere esse mapeamento ao configurar os objetos a serem sincronizados ou migrados.
Elasticsearch 7.0 e posterior
Elasticsearch
Banco de dados relacional
index
table
document
row
field
column
mapping
schema
Versões anteriores ao Elasticsearch 7.0
Elasticsearch
Banco de dados relacional
index
database
type
table
document
row
field
column
mapping
schema
Precauções
Procedimento
-
Acesse a página da lista de tarefas de sincronização da região de destino. Você pode usar um dos dois métodos a seguir:
Pelo console do DTS
Faça login no console do Data Transmission Service (DTS).
No painel de navegação à esquerda, clique em Data Synchronization.
No canto superior esquerdo da página, selecione a região onde está a instância de sincronização.
Pelo console do DMS
NotaAs operações reais podem variar com base no modo e no layout do console do DMS. Para mais informações, consulte Simple mode e Customize the layout and style of the DMS interface.
Faça login no Data Management (DMS).
Na barra de menu superior, escolha .
À direita de Data Synchronization Tasks, selecione a região onde está a instância de sincronização.
Clique em Create Task para abrir a página de configuração da tarefa.
-
Configure os bancos de dados de origem e de destino.
Categoria
Parâmetro
Descrição
N/A
Task Name
O DTS gera automaticamente um nome para a tarefa. especifique um nome descritivo para facilitar a identificação. O nome não precisa ser exclusivo.
Source Database
Select Existing Connection
-
Para usar uma instância de banco de dados que é added to the system (recém-criada ou salva), selecione a instância de banco de dados na lista suspensa. As informações do banco de dados são configuradas automaticamente.
NotaNo console do DMS, este item de configuração é chamado de Select a DMS database instance..
-
Se você não adicionou a instância de banco de dados ao sistema, ou não precisa usar uma instância já adicionada, configure manualmente as seguintes informações do banco de dados.
Database Type
Selecione PolarDB-X 1.0.
Access Method
Selecione Alibaba Cloud Instance.
Instance Region
Selecione a região onde está a instância PolarDB-X 1.0 de origem.
Replicate Data Across Alibaba Cloud Accounts
Este exemplo sincroniza dados dentro da mesma conta Alibaba Cloud. Selecione No.
Instance ID
Selecione o ID da instância PolarDB-X 1.0 de origem.
Database Account
insira a conta do banco de dados da instância PolarDB-X 1.0 de origem.
Database Password
insira a senha correspondente à conta do banco de dados.
Destination Database
Select Existing Connection
-
Para usar uma instância de banco de dados que é added to the system (recém-criada ou salva), selecione a instância de banco de dados na lista suspensa. As informações do banco de dados são configuradas automaticamente.
NotaNo console do DMS, este item de configuração é chamado de Select a DMS database instance..
-
Se você não adicionou a instância de banco de dados ao sistema, ou não precisa usar uma instância já adicionada, configure manualmente as seguintes informações do banco de dados.
Database Type
Selecione Elasticsearch.
Access Method
Selecione Alibaba Cloud Instance.
Instance Region
Selecione a região onde está a instância Elasticsearch de destino.
Type
Selecione Cluster ou Serverless conforme os requisitos do seu negócio.
Instance ID
Selecione o ID da instância Elasticsearch de destino.
Database Account
insira a conta usada para conectar à instância Elasticsearch de destino. Este é o Login name especificado ao criar a instância Elasticsearch. A conta padrão é elastic.
Database Password
insira a senha correspondente à conta do banco de dados.
Encryption
Selecione HTTP ou HTTPS conforme necessário.
-
-
Após concluir a configuração, clique em Test Connectivity and Proceed na parte inferior da página.
NotaCertifique-se de que os blocos CIDR de endereços IP dos servidores DTS foram adicionados às configurações de segurança dos bancos de dados de origem e de destino para permitir o acesso dos servidores DTS. Você pode adicionar esses blocos automática ou manualmente. Para mais informações, consulte Add the IP address CIDR blocks of DTS servers to a whitelist.
Se o banco de dados de origem ou de destino for um banco de dados autogerenciado (onde o Access Method não é Alibaba Cloud Instance), clique também em Test Connectivity na caixa de diálogo CIDR Blocks of DTS Servers.
-
Configure os objetos da tarefa.
-
Na página Configure Objects, configure os objetos a serem sincronizados.
Parâmetro
Descrição
Synchronization Types
A opção Incremental Data Synchronization está selecionada. Por padrão, selecione também Schema Synchronization e Full Data Synchronization. Após a conclusão da pré-verificação, o DTS executa uma sincronização completa de dados dos objetos selecionados da instância de origem para o cluster de destino. Isso serve como dados de linha de base para a sincronização incremental de dados subsequente.
Processing Mode of Conflicting Tables
-
Precheck and Report Errors: Verifica se o banco de dados de destino contém um índice com o mesmo nome. Se não existir nenhum índice com o mesmo nome, a pré-verificação é aprovada. Se existir um índice com o mesmo nome, o DTS relata um erro durante a pré-verificação e a tarefa de sincronização não é iniciada.
NotaSe você não puder excluir ou renomear o índice conflitante no banco de dados de destino, especifique um specify a different name for the synchronized object in the destination instance para evitar conflitos de nomes.
-
Ignore Errors and Proceed: Ignora a verificação de índices com o mesmo nome no banco de dados de destino.
AvisoSe você selecionar Ignore Errors and Proceed, poderá ocorrer inconsistência de dados, o que representa riscos para o seu negócio. Por exemplo:
-
Se as estruturas de mapeamento forem iguais e um registro no banco de dados de destino tiver o mesmo valor de chave primária que um registro no banco de dados de origem, o DTS manterá o registro de destino durante a inicialização, mas o sobrescreverá durante a sincronização incremental de dados.
-
Se as estruturas de mapeamento forem diferentes, a inicialização de dados poderá falhar, o DTS sincronizará apenas colunas parciais ou a sincronização poderá falhar completamente.
-
Index Name
-
Se você selecionar Table Name, o índice na instância Elasticsearch de destino receberá o nome da tabela de origem.
-
Se você selecionar Database Name_Table Name, o índice Elasticsearch de destino será nomeado no formato
database_name_table_name.
NotaEsta configuração de mapeamento de nome de índice se aplica a todas as tabelas.
Capitalization of Object Names in Destination Instance
Configure a política de diferenciação de maiúsculas e minúsculas para nomes de objetos de banco de dados, tabelas e colunas que são sincronizados com a instância de destino. Por padrão, a DTS default policy é selecionada. Ou opte por usar as políticas padrão dos bancos de dados de origem e de destino. Para mais informações, consulte Case sensitivity policy for destination object names.
Source Objects
Na seção Source Objects, clique nos objetos que deseja sincronizar e, em seguida, clique em
para adicioná-los à seção Selected Objects.NotaSelecione tabelas como objetos de sincronização. Se você selecionar um banco de dados inteiro, o DTS não sincronizará as alterações para adicionar ou exclua tabelas nesse banco de dados com o banco de dados de destino.
Selected Objects
-
Para renomear um único objeto de sincronização na instância de destino, clique com o botão direito do mouse no objeto na caixa Selected Objects. Para mais informações sobre como renomear objetos, consulte Map a single database, table, or column.
-
Para alterar os nomes de vários objetos de sincronização na instância de destino em lote, clique em Batch Edit no canto superior direito da caixa Selected Objects. Para mais informações, consulte Map databases, tables, and columns in a batch.
Nota-
O DTS suporta apenas sublinhados (_) como caracteres especiais em nomes de índices e tipos.
-
Para especificar condições WHERE para filtrar dados, clique com o botão direito do mouse em uma tabela na seção Selected Objects e especifique as condições na caixa de diálogo que aparece. Para mais informações, consulte Set filter conditions.
-
Se você usar o recurso de mapeamento de nomes de objetos, a sincronização de objetos dependentes poderá falhar.
-
-
Clique em Next: Advanced Settings para configurar parâmetros avançados.
Parâmetro
Descrição
Dedicated Cluster for Task Scheduling
Por padrão, o DTS agenda tarefas em um cluster compartilhado, e você não precisa selecionar um cluster. Para um desempenho mais estável, adquira um cluster dedicado para executar tarefas de sincronização do DTS. Para mais informações, consulte What is a DTS dedicated cluster?.
Retry Time for Failed Connections
Após o início de uma tarefa de sincronização, se a conexão com o banco de dados de origem ou de destino falhar, o DTS relatará um erro e começará imediatamente a tentar reconectar. A duração padrão da nova tentativa é de 720 minutos. especifique uma duração personalizada de nova tentativa de 10 a 1.440 minutos. Defina a duração para 30 minutos ou mais. Se o DTS se reconectar com sucesso ao banco de dados dentro da duração especificada, a tarefa de sincronização será retomada automaticamente. Caso contrário, a tarefa falhará.
Nota-
Se você tiver várias instâncias do DTS (por exemplo, Instância A e Instância B) que compartilham a mesma origem ou destino, e definir o tempo de nova tentativa de rede para 30 minutos para a Instância A e 60 minutos para a Instância B, o DTS usará a duração mais curta de 30 minutos para ambas.
-
Como o DTS cobra pelo tempo de execução da tarefa durante o período de nova tentativa de conexão, personalize a duração da nova tentativa com base nas necessidades do seu negócio ou libere a instância do DTS o mais rápido possível após a liberação das instâncias de banco de dados de origem e de destino.
Retry Time for Other Issues
Após o início da tarefa de sincronização, se ocorrerem outros problemas não relacionados à conectividade com o banco de dados de origem ou de destino (como exceções de execução de DDL ou DML), o DTS relatará um erro e iniciará imediatamente operações contínuas de nova tentativa. A duração padrão da nova tentativa é de 10 minutos. Personalize a duração da nova tentativa dentro do intervalo de 1 a 1.440 minutos. Defina-a para 10 minutos ou mais. Se as operações relevantes forem bem-sucedidas dentro da duração de nova tentativa definida, a tarefa de sincronização será retomada automaticamente. Caso contrário, a tarefa falhará.
ImportanteO valor para Retry Time for Other Issues deve ser menor que o valor para Retry Time for Failed Connections.
Enable Throttling for Full Data Synchronization
Durante a fase de sincronização completa, o DTS consome recursos de leitura e gravação dos bancos de dados de origem e de destino, o que pode aumentar a carga do banco de dados. Para reduzir a carga nos bancos de dados de origem e de destino, defina um limite de taxa para a tarefa de sincronização completa configurando os parâmetros Queries per second (QPS) to the source database, RPS of Full Data Migration e Data migration speed for full migration (MB/s).
Nota-
Este item de configuração está disponível apenas quando Synchronization Types está definido como Full Data Synchronization.
-
Ajuste o adjust the full synchronization rate após a instância de sincronização estar em execução.
Enable Throttling for Incremental Data Synchronization
Defina um limite de taxa para a tarefa de sincronização incremental. Para aliviar a pressão no banco de dados de destino, defina RPS of Incremental Data Synchronization e Data synchronization speed for incremental synchronization (MB/s).
Environment Tag
Selecione uma tag de ambiente para identificar a instância de acordo com seus requisitos.
Shard Configuration
Defina o número de shards primários e shards de réplica para o índice com base na configuração máxima de shards dos índices na instância Elasticsearch de destino.
String Index
Especifica como indexar strings sincronizadas com a instância Elasticsearch de destino.
-
analyzed: A string é analisada antes de ser indexada. Selecione um analisador específico. Para mais informações sobre os tipos de analisadores e suas funções, consulte Analyzers.
-
not_analyzed: A string é indexada com seu valor original, sem análise.
-
no: A string não é indexada.
Time Zone
Quando o DTS sincroniza tipos de dados relacionados ao tempo, como DATETIME e TIMESTAMP, com a instância Elasticsearch de destino, selecione o fuso horário a ser incluído.
NotaSe os tipos de dados relacionados ao tempo na instância de destino não exigirem um fuso horário, defina previamente o tipo de documento (type) para esses tipos de dados na instância de destino.
DOCID
O DOCID tem como padrão a chave primária da tabela. Se a tabela não tiver chave primária, o DOCID será uma coluna de ID que a instância Elasticsearch gera automaticamente.
Configure ETL
escolha se deseja ativar o recurso de extração, transformação e carga (ETL). Para mais informações, consulte What is ETL? Valores válidos:
-
Yes: Ativa o recurso ETL. insira instruções de processamento de dados no editor de código. Para mais informações, consulte Configure ETL in a data migration or data synchronization task.
-
No: Desativa o recurso ETL.
Monitoring and Alerting
especifique se deseja configurar alertas. Se a sincronização falhar ou a latência exceder o limiar especificado, o DTS enviará uma notificação para um contato de alerta.
-
No: Não configura alertas.
-
Yes: Configure alertas definindo um limiar de alerta e especificando um notificação de alerta. Para mais informações, consulte Configure monitoring and alerting during task configuration.
-
-
Após concluir as configurações anteriores, clique em Next: Configure Database and Table Fields na parte inferior da página. Em seguida, defina a política _routing e o valor _id para as tabelas que você deseja sincronizar com a instância Elasticsearch de destino.
Tipo
Descrição
Set _routing
Use o recurso _routing para armazenar um documento em um shard específico da instância Elasticsearch de destino. Para mais informações, consulte _routing.
-
Se você selecionar Yes, especifique uma coluna personalizada para roteamento.
-
Se você selecionar No, o DTS usará o valor de _id para roteamento.
NotaSe a instância Elasticsearch de destino executar a versão 7.x, selecione No.
_routing Column
Selecione a coluna a ser usada para roteamento.
NotaEste parâmetro é necessário apenas se você definir Set _routing como Yes.
Value of _id
Selecione a coluna a ser usada como ID do documento.
-
-
-
salve a tarefa e execute uma pré-verificação.
Para visualize os parâmetros da API para configurar esta instância, passe o mouse sobre o botão Next: Save Task Settings and Precheck e clique em Preview OpenAPI parameters na dica.
Se você terminou de visualizar os parâmetros da API, clique em Next: Save Task Settings and Precheck na parte inferior da página.
NotaAntes do início do trabalho de sincronização, o DTS executa uma pré-verificação. O DTS só iniciará o trabalho após a aprovação de todos os itens de pré-verificação.
Se a pré-verificação falhar, clique em View Details para o item com falha. Corrija o problema conforme instruído e, em seguida, execute a pré-verificação novamente.
-
Se a pré-verificação retornar um aviso:
Se um item de verificação falhar e não puder ser ignorado, clique em View Details ao lado do item. Siga as instruções para corrigir o problema e, em seguida, execute a pré-verificação novamente.
Para itens de verificação que podem ser ignorados, clique em Confirm Alert Details, Ignore, OK e Precheck Again em sequência para ignorar o aviso e executar a pré-verificação novamente. Se você optar por ocultar o item de aviso, isso poderá causar problemas como inconsistência de dados e representar riscos para o seu negócio.
-
Adquira a instância.
Quando a Success Rate for de 100%, clique em Next: Purchase Instance.
-
Na página Purchase, selecione o método de faturamento e a especificação do link para a instância de sincronização de dados. A tabela a seguir descreve esses parâmetros em detalhes.
Categoria
Parâmetro
Descrição
New Instance Class
Método de faturamento
-
Assinatura: Você paga ao criar a instância. Isso é adequado para necessidades de longo prazo e é mais econômico do que o pagamento conforme o uso. Quanto maior a duração da assinatura, maior o desconto.
-
Pagamento conforme o uso: A cobrança ocorre por hora. Isso é adequado para necessidades de curto prazo. Libere a instância imediatamente após o uso para economizar custos.
Configuração do grupo de recursos
O grupo de recursos ao qual a instância pertence. O padrão é o grupo de recursos padrão (default resource group). Para mais informações, consulte What is Resource Management?.
Especificação do link
O DTS fornece especificações de sincronização com diferentes níveis de desempenho. A especificação do link de sincronização afeta a taxa de sincronização. escolha uma especificação com base no seu cenário de negócio. Para mais informações, consulte Data synchronization link specifications.
Duração da assinatura
No modo de assinatura, selecione a duração e a quantidade para a instância de assinatura. Escolha uma assinatura mensal de 1 a 9 meses, ou uma assinatura anual de 1, 2, 3 ou 5 anos.
NotaEsta opção está disponível apenas quando o método de faturamento é Subscription.
-
Após concluir a configuração, leia e selecione Data Transmission Service (Pay-as-you-go) Service Terms.
-
Clique em Buy and Start. Na caixa de diálogo OK, clique em OK.
Visualize o progresso da tarefa na página Data Synchronization.