Data Transmission Service:Criar uma tarefa de assinatura de dados do Oracle

Pré-requisitos

• O banco de dados Oracle autogerenciado deve estar na versão 9i, 10g ou 11g. Não há suporte para instâncias do Real Application Clusters (RAC) e do Pluggable Database (PDB).

• O supplemental logging deve estar ativado para o banco de dados Oracle de origem, assim como os parâmetros supplemental_log_data_pk e supplemental_log_data_ui. Para obter mais informações, consulte Supplemental Logging.

• O banco de dados Oracle de origem deve estar no modo ARCHIVELOG. Os logs arquivados precisam ter um período de retenção adequado e estar acessíveis. Para mais informações, consulte ARCHIVELOG.

• Crie uma Virtual Private Cloud (VPC) and a vSwitch para a instância de assinatura de dados.

Limitações

Antes de começar

Acesse o banco de dados Oracle de origem, crie uma conta de banco de dados para a tarefa do Data Subscription e conceda permissões de DBA a ela. Para mais informações, consulte CREATE USER e GRANT USER.

1. Ative o archive logging e o supplemental logging.

   Tipo	Procedimento
   Archive logging	Execute as seguintes instruções para ativar o archive logging: shutdown immediate; startup mount; alter database archivelog; alter database open; archive log list;
   Supplemental logging	Ative o supplemental logging no nível do banco de dados ou da tabela: Nota Ative o supplemental logging no nível do banco de dados para garantir a estabilidade das tarefas do DTS. Para reduzir o uso de disco do banco de dados Oracle de origem, ative-o no nível da tabela. Ative o supplemental logging no nível do banco de dados Ative o supplemental logging mínimo: alter database add supplemental log data; Ative o supplemental logging de chave primária e índice exclusivo no nível do banco de dados: alter database add supplemental log data (primary key,unique index) columns; Ative o supplemental logging no nível da tabela Ative o supplemental logging mínimo: alter database add supplemental log data; Ative o supplemental logging no nível da tabela usando um dos seguintes métodos: Ative o supplemental logging de chave primária no nível da tabela: alter table table_name add supplemental log data (primary key) columns; Ative o supplemental logging no nível da tabela para todas as colunas: alter table tb_name add supplemental log data (all) columns ;

2. Conceda permissões refinadas a uma conta de banco de dados Oracle.

   Versões do Oracle 9i a 11g

   # Create a database account, for example, rdsdt_dtsacct, and grant permissions to the account.
   create user rdsdt_dtsacct IDENTIFIED BY rdsdt_dtsacct;
   grant create session to rdsdt_dtsacct;
   grant connect to rdsdt_dtsacct;
   grant resource to rdsdt_dtsacct;
   grant execute on sys.dbms_logmnr to rdsdt_dtsacct;
   grant select on V_$LOGMNR_LOGS to rdsdt_dtsacct;
   grant select on all_objects to rdsdt_dtsacct;
   grant select on all_tab_cols to rdsdt_dtsacct;
   grant select on dba_registry to rdsdt_dtsacct;
   grant select any table to rdsdt_dtsacct;
   grant select any transaction to rdsdt_dtsacct;
   -- v$log privileges
   grant select on v_$log to rdsdt_dtsacct;
   -- v$logfile privileges
   grant select on v_$logfile to rdsdt_dtsacct;
   -- v$archived_log privileges
   grant select on v_$archived_log to rdsdt_dtsacct;
   -- v$parameter privileges
   grant select on v_$parameter to rdsdt_dtsacct;
   -- v$database privileges
   grant select on v_$database to rdsdt_dtsacct;
   -- v$active_instances privileges
   grant select on v_$active_instances to rdsdt_dtsacct;
   -- v$instance privileges
   grant select on v_$instance to rdsdt_dtsacct;
   -- v$logmnr_contents privileges
   grant select on v_$logmnr_contents to rdsdt_dtsacct;
   -- system tables
   grant select on sys.USER$ to rdsdt_dtsacct;
   grant select on SYS.OBJ$ to rdsdt_dtsacct;
   grant select on SYS.COL$ to rdsdt_dtsacct;
   grant select on SYS.IND$ to rdsdt_dtsacct;
   grant select on SYS.ICOL$ to rdsdt_dtsacct;
   grant select on SYS.CDEF$ to rdsdt_dtsacct;
   grant select on SYS.CCOL$ to rdsdt_dtsacct;
   grant select on SYS.TABPART$ to rdsdt_dtsacct;
   grant select on SYS.TABSUBPART$ to rdsdt_dtsacct;
   grant select on SYS.TABCOMPART$ to rdsdt_dtsacct;

Procedimento

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

   DTS console

   1. Acesse o 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 de acordo com o modo e o layout do DMS console. Para mais informações, consulte Simple mode console e Customize DMS console layout and style.

   1. Acesse o 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 para acessar 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, leia os Limits exibidos na parte superior da página. Caso contrário, a tarefa poderá falhar ou não será possível consumir os dados rastreados.

   Categoria	Parâmetro	Descrição
   N/A	Task Name	O nome da tarefa de change tracking. O DTS atribui automaticamente um nome à tarefa. Especifique um nome descritivo que facilite a identificação da tarefa. Não é necessário usar um nome exclusivo.
   Source Database	Select Existing Connection	Para usar uma instância de banco de dados que esteja Manage database connections ao sistema (seja recém-criada ou salva anteriormente), selecione-a na lista suspensa. As informações do banco de dados serão preenchidas automaticamente. Nota No DMS console, essa configuração tem o rótulo Select a DMS database instance. Se a instância de banco de dados não estiver no sistema ou se não for do seu interesse usar uma existente, configure as informações do banco de dados manualmente.
   	Database Type	Selecione Oracle.
   	Access Method	Selecione o método de acesso com base no tipo de instância de origem. Este exemplo usa Self-managed Database on ECS. Nota Se o banco de dados de origem for autogerenciado, conclua a preparação do banco de dados. Para mais informações, consulte Preparation overview.
   	Instance Region	Selecione a região onde o banco de dados Oracle autogerenciado está localizado.
   	ECS Instance ID	Selecione o ID da instância ECS que hospeda o banco de dados Oracle autogerenciado.
   	Port	Insira a porta de serviço do banco de dados Oracle autogerenciado. O valor padrão é 1521.
   	Oracle Type	Non-RAC Instance: Se selecionar esta opção, especifique também o SID. RAC or PDB Instance: Se selecionar esta opção, insira também o Service Name. Importante Não há suporte para instâncias RAC e PDB. Este exemplo usa uma Non-RAC Instance.
   	Database Account	Insira a conta do banco de dados Oracle autogerenciado. Para requisitos de permissão, consulte Before you begin.
   	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, não é possível alterar as configurações na seção Consumer Network Type. Se o cliente de change tracking estiver implantado em uma VPC, selecione a mesma VPC e o mesmo vSwitch conectados ao cliente. Ao rastrear alterações de dados em redes internas, a latência da rede é mínima.

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	Os Data Change Types ficam marcados por padrão e não podem ser modificados. Data Update O DTS rastreia atualizações de dados dos objetos selecionados, incluindo as operações INSERT, DELETE e UPDATE. Schema Update O DTS rastreia as operações de criação, exclusão e modificação realizadas em todos os esquemas de objetos da instância de origem. Use o cliente de change tracking para filtrar os dados a serem rastreados.
      Source Objects	Selecione um ou mais objetos na seção Source Objects e clique no ícone para adicioná-los à seção Selected Objects. Nota Selecione tabelas ou bancos de dados como objetos para o change tracking. Se selecionar um banco de dados como objeto, o DTS rastreará dados incrementais de todos os objetos, incluindo novos objetos no banco de dados. Se selecionar uma tabela como objeto, o DTS rastreará apenas os dados incrementais dessa tabela. Nesse caso, para rastrear alterações de dados de outra tabela, adicione-a à lista de objetos. Para mais informações, consulte Modify the objects for change tracking.

   2. Clique em Next: Advanced Settings para configurar 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 é necessário configurar este parâmetro. Compre clusters dedicados com 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 para tentar novamente conexões com falha. Se a tarefa de change tracking falhar, o DTS tentará imediatamente uma nova conexão dentro desse intervalo. 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 especificado, ele retomará a tarefa de change tracking. Caso contrário, a tarefa falhará. Nota Se houver várias tarefas de change tracking configuradas para uma instância de banco de dados, o menor intervalo de tempo para nova tentativa terá precedência. Por exemplo, se a Tarefa A e a Tarefa B estiverem configuradas para a mesma instância, com intervalos de 30 e 60 minutos, respectivamente, o intervalo de 30 minutos terá precedência. A tentativa de nova conexão pelo DTS gera cobrança de taxas. Especifique o intervalo de tempo para nova tentativa com base nos requisitos do seu negócio ou libere a instância do DTS o mais rápido possível após liberar a instância do banco de dados de origem.
      Retry Time for Other Issues	O intervalo de tempo para tentar novamente em caso de outros problemas. Por exemplo, se as operações DDL ou DML falharem após o início da tarefa de change tracking, o DTS tentará executá-las novamente dentro desse intervalo. 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 especificado, o DTS retomará a tarefa. Caso contrário, a tarefa 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	Opcional. Selecione uma tag de ambiente para identificar a instância.
      Monitoring and Alerting	Define se o alerta para a tarefa de change tracking deve ser ativado. Se o alerta estiver configurado e a tarefa falhar ou a latência exceder o limiar, o sistema enviará notificações de alerta. Valores válidos: No: não ativa o alerta. Yes: ativa o alerta. Nesse caso, configure também o limiar de alerta e as 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.

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

   • Se não for necessário visualizar os parâmetros ou se você já os tiver visualizado, 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. Só é possível iniciar a tarefa após a aprovação na pré-verificação.

   • Se a tarefa não for aprovada na pré-verificação, clique em View Details ao lado de cada item com falha. Solucione os problemas com base na mensagem de erro e execute a pré-verificação novamente.

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

     • Se não for possível ignorar um item de alerta, clique em View Details ao lado do item com falha e solucione os problemas. Em seguida, execute a pré-verificação novamente.

     • Se for possível ignorar o item de alerta, clique em Confirm Alert Details. Na caixa de diálogo View Details, clique em Ignore. Na mensagem exibida, clique em OK. Em seguida, clique em Precheck Again para executar a pré-verificação novamente. Ignorar o item de alerta pode causar inconsistência de dados e expor seu negócio 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: o pagamento é feito no momento da criação da instância. O método de faturamento por assinatura é mais econômico que o pagamento conforme o uso para longo prazo. Há preços mais baixos para durações de assinatura mais longas. Pagamento conforme o uso: a instância é faturada por hora. Selecione o método de pagamento conforme o uso para curto prazo. Se a instância não for mais necessária, libere-a 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 selecionar o método de faturamento por assinatura, defina a duração da assinatura e o número de instâncias a serem criadas. 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 o método de faturamento selecionado for 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 os 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