Data Transmission Service:Crie uma tarefa de assinatura de dados para o PolarDB for PostgreSQL (Compatible with Oracle)

Pré-requisitos

• Crie um cluster de origem do PolarDB for PostgreSQL (Compatible with Oracle). Para mais informações, consulte Create a PolarDB for PostgreSQL (Compatible with Oracle) cluster.

• Defina o parâmetro wal_level do cluster de origem do PolarDB for PostgreSQL (Compatible with Oracle) como logical. Essa configuração adiciona as informações necessárias para dar suporte à decodificação lógica ao write-ahead logging (WAL). Para mais informações, consulte Set cluster parameters.

• Você criou um Virtual Private Cloud (VPC) and a vSwitch para a instância de assinatura de dados.

Observações de uso

Procedimento

1. Acesse a página Change Tracking Tasks usando um dos métodos a seguir e selecione a região onde a instância de change tracking está localizada.

   DTS console

   1. Faça login no DTS console.

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

   3. No canto superior esquerdo da página, selecione a região onde a instância de change tracking está localizada.

   DMS console

   Nota

   As operações reais podem variar com base no modo e no layout do DMS console. Para mais informações, consulte Simple mode console e Customize DMS console layout and style.

   1. Faça login no DMS console.

   2. Na barra de navegação superior, passe o ponteiro do mouse sobre Data + AI > DTS (DTS) > Change Tracking.

   3. Na lista suspensa à direita de Change Tracking Tasks, selecione a região onde a instância de change tracking está localizada.

2. Clique em Create Task e acesse a página de configuração da tarefa.

3. Configure os parâmetros nas seções Source Database e Consumer Network Type.

   Aviso

   Após especificar a instância do banco de dados de origem, recomendamos que você leia os Limits exibidos na parte superior da página. Caso contrário, a tarefa poderá falhar ou os dados rastreados não poderão ser consumidos.

   Tipo	Parâmetro	Descrição
   N/A	Task Name	O nome da tarefa de change tracking. O DTS atribui automaticamente um nome à tarefa. Recomendamos que você especifique e salve um nome descritivo que facilite a identificação da tarefa. Não é necessário usar um nome de tarefa exclusivo.
   Source Database	Select Existing Connection	Se você quiser usar um Manage database connections com o sistema (recém-criado ou salvo), selecione-o na lista suspensa. O sistema preenche automaticamente as informações de conexão do banco de dados. Nota No DMS console, este parâmetro é chamado de Select a DMS database instance. Se a sua instância de banco de dados não estiver registrada, ou se você não quiser usar uma instância registrada, configure manualmente as informações de conexão do banco de dados abaixo.
   	Database Type	Selecione PolarDB (Compatible with Oracle).
   	Access Method	Este tópico usa Public IP Address como exemplo.
   	Instance Region	Selecione a região onde o cluster do PolarDB for PostgreSQL (Compatible with Oracle) está localizado.
   	Data Sources	Selecione Single Data Source. Em seguida, no campo Domain Name or IP Address, insira o endpoint do nó primário ou o endpoint do cluster do cluster de origem do PolarDB for PostgreSQL (Compatible with Oracle) e especifique a Port.
   	Domain Name or IP Address	Insira o endpoint do nó primário ou o endpoint do cluster.
   	Port	Insira o número da porta de serviço do banco de dados de origem. O valor padrão é 1521.
   	Database Name	Insira o nome do banco de dados que você deseja assinar.
   	Database Account	Insira uma conta privilegiada para o banco de dados PolarDB for PostgreSQL (Compatible with Oracle).
   	Database Password	A senha usada para acessar a instância do banco de dados.
   Consumer Network Type	Network Type	O valor do parâmetro Network Type é fixo como VPC. Selecione uma VPC e um vSwitch. Para mais informações, consulte VPCs. Nota Após a configuração de uma tarefa de change tracking, você não pode alterar as configurações na seção Consumer Network Type. Se o seu cliente de change tracking estiver implantado em uma VPC, recomendamos que você selecione a mesma VPC e o mesmo vSwitch conectados ao cliente. Se você rastrear alterações de dados em redes internas, a latência da rede será mínima.

4. Na parte inferior da página, clique em Test Connectivity and Proceed.

   Nota

   • Certifique-se de que os blocos CIDR dos servidores do DTS possam ser adicionados automática ou manualmente às configurações de segurança dos bancos de dados de origem e de destino para permitir o acesso dos servidores do DTS. Para mais informações, consulte Whitelist DTS server IP addresses.

   • Se o banco de dados de origem for um banco de dados autogerenciado e seu Access Method não estiver definido como Alibaba Cloud Instance, clique em Test Connectivity na caixa de diálogo CIDR Blocks of DTS Servers.

5. Configure os objetos para o change tracking.

   1. Na página Configure Objects, configure os objetos para o change tracking.

      Parâmetro	Descrição
      Data Change Types	A caixa de seleção Data Change Types é selecionada por padrão e você não pode alterá-la. Os tipos de alteração de dados que você deseja rastrear. Selecione apenas Data Update. O DTS rastreia atualizações de dados dos objetos que você seleciona. As atualizações de dados incluem as operações INSERT, DELETE e UPDATE.
      Source Objects	Selecione um ou mais objetos na seção Source Objects e clique no ícone para adicionar os objetos à seção Selected Objects. Nota Você pode selecionar tabelas ou bancos de dados como os objetos para o change tracking. Se você selecionar um banco de dados como objeto, o DTS rastreará dados incrementais de todos os objetos, incluindo novos objetos no banco de dados. Se você selecionar uma tabela como objeto, o DTS rastreará apenas os dados incrementais dessa tabela. Nesse caso, se você quiser rastrear alterações de dados de outra tabela, deverá adicionar a tabela à lista de objetos. Para mais informações, consulte Modifique os objetos para change tracking.

   2. Clique em Next: Advanced Settings e configure as opções avançadas.

      Parâmetro	Descrição
      Dedicated Cluster for Task Scheduling	Por padrão, o DTS agenda a tarefa para um cluster compartilhado. Não configure este parâmetro. Você pode adquirir clusters dedicados de especificações específicas para executar tarefas de change tracking do DTS. Para mais informações, consulte What is a DTS dedicated cluster?.
      Retry Time for Failed Connections	O intervalo de tempo de nova tentativa para conexões com falha. Se a tarefa de change tracking falhar, o DTS tentará imediatamente uma nova conexão dentro do intervalo de tempo. Valores válidos: 10 a 1440. Unidade: minutos. Valor padrão: 720. Defina o parâmetro com um valor maior que 30. Se o DTS for reconectado à instância do banco de dados de origem dentro do intervalo de tempo especificado, o DTS retomará a tarefa de change tracking. Caso contrário, a tarefa de change tracking falhará. Nota Se várias tarefas de change tracking estiverem configuradas para uma instância de banco de dados, o menor intervalo de tempo de nova tentativa terá precedência. Por exemplo, a Tarefa A e a Tarefa B estão configuradas para a mesma instância de banco de dados. A Tarefa A é configurada com um intervalo de tempo de nova tentativa de 30 minutos, e a Tarefa B é configurada com um intervalo de tempo de nova tentativa de 60 minutos. Nesse caso, o intervalo de tempo de nova tentativa de 30 minutos tem precedência. Quando o DTS tenta uma nova conexão, são cobradas taxas. Especifique o intervalo de tempo de nova tentativa com base nos seus requisitos de negócios, ou libere a instância do DTS o mais rápido possível após a liberação da instância do banco de dados de origem.
      Retry Time for Other Issues	O intervalo de tempo de nova tentativa para outros problemas. Por exemplo, se as operações DDL ou DML falharem ao serem executadas após o início da tarefa de change tracking, o DTS tentará imediatamente repetir as operações dentro do intervalo de tempo de nova tentativa. Valores válidos: 1 a 1440. Unidade: minutos. Valor padrão: 10. Defina o parâmetro com um valor maior que 10. Se as operações com falha forem executadas com êxito dentro do intervalo de tempo de nova tentativa especificado, o DTS retomará a tarefa de change tracking. Caso contrário, a tarefa de change tracking falhará. Importante O valor do parâmetro Retry Time for Other Issues deve ser menor que o valor do parâmetro Retry Time for Failed Connections.
      Environment Tag	Você pode selecionar uma tag para identificar o ambiente da instância. Este parâmetro é opcional.
      Monitoring and Alerting	Especifica se deve ativar o alerta para a tarefa de change tracking. Se o alerta estiver configurado e a tarefa falhar ou a latência exceder o limiar, as notificações de alerta serão enviadas. Valores válidos: No: não ative o alerta. Yes: ative o alerta. Nesse caso, você também deve configurar o limiar de alerta e alert notification settings. Para mais informações, consulte Configure alerts during instance configuration.

6. Na parte inferior da página, clique em Next: Save Task Settings and Precheck.

   • Visualize os parâmetros a serem especificados ao chamar a operação de API relevante para configurar a tarefa do DTS. Para isso, passe o ponteiro do mouse sobre Next: Save Task Settings and Precheck e clique em Preview OpenAPI parameters.

   • Se você não precisar visualizar ou já tiver visualizado os parâmetros, clique em Next: Save Task Settings and Precheck na parte inferior da página.

   Nota

   • Antes de iniciar a tarefa de change tracking, o DTS realiza uma pré-verificação. Você só pode iniciar a tarefa de change tracking após a tarefa passar na pré-verificação.

   • Se a tarefa não passar na pré-verificação, clique em View Details ao lado de cada item com falha. Após solucionar os problemas com base na mensagem de erro, execute uma pré-verificação novamente.

   • Se um alerta for gerado para um item durante a pré-verificação, execute as seguintes operações com base no cenário:

     • Se um item de alerta não puder ser ignorado, clique em View Details ao lado do item com falha e solucione os problemas. Em seguida, execute uma pré-verificação novamente.

     • Se o item de alerta puder ser ignorado, clique em Confirm Alert Details. Na caixa de diálogo View Details, clique em Ignore e confirme a ação. Na mensagem que aparece, clique em OK. Em seguida, clique em Precheck Again e execute uma pré-verificação novamente. Se você ignorar o item de alerta, poderá ocorrer inconsistência de dados e seus negócios poderão ficar expostos a riscos potenciais.

7. Adquira a instância.

   1. Aguarde até que a Success Rate se torne 100%. Em seguida, clique em Next: Purchase Instance.

   2. Na página Purchase, especifique o método de faturamento da instância de change tracking. A tabela a seguir descreve os parâmetros.

      Parâmetro	Descrição
      Método de faturamento	Assinatura: Você paga pela sua assinatura ao criar uma instância. O método de faturamento por assinatura é mais econômico do que o método de pagamento conforme o uso para uso a longo prazo. São oferecidos preços mais baixos para durações de assinatura mais longas. Pagamento conforme o uso: Uma instância de pagamento conforme o uso é faturada por hora. Recomendamos que você selecione o método de faturamento de pagamento conforme o uso para uso a curto prazo. Se você não precisar mais de uma instância de pagamento conforme o uso, exclua a instância para reduzir custos.
      Resource Group Settings	O grupo de recursos ao qual a instância pertence. Valor padrão: default resource group. Para mais informações, consulte What is resource management?
      Subscription Duration	Se você selecionar o método de faturamento por assinatura, defina a duração da assinatura e o número de instâncias que deseja criar. A duração da assinatura pode ser de um a nove meses, um ano, dois anos, três anos ou cinco anos. Nota Este parâmetro está disponível apenas se você selecionar o método de faturamento Subscription.

   3. Leia e selecione os Data Transmission Service (Pay-as-you-go) Service Terms.

   4. Clique em Buy and Start para iniciar a tarefa de change tracking. Visualize o progresso da tarefa na lista de tarefas.

Próximos passos

Depois que a tarefa estiver em execução, crie grupos de consumidores e conecte seus clientes downstream para consumir os dados rastreados.

1. Create consumer groups

2. Conecte um cliente para consumir os dados rastreados:

   • Use the SDK demo to consume tracked data

   • Use flink-dts-connector to consume tracked data

   • Use a Kafka client to consume tracked data