Replicar dados de HeatWave para o Autonomous Data Warehouse

Saiba como usar o OCI GoldenGate para replicar dados de HeatWave para o Autonomous Data Warehouse.

Antes de começar

Para concluir esse início rápido com sucesso, você deve ter:

  • O OCI Bastion, para estabelecer conexão com HeatWave, carregar o banco de dados de amostra e executar inserções
  • Um banco de dados HeatWave para servir como o banco de dados de origem
  • Uma instância do Autonomous Data Warehouse para servir de banco de dados de destino

Configuração do ambiente: HeatWave

Para configurar o ambiente para esse Início Rápido:
  1. Faça download do script de dados de amostra e, em seguida, execute o script no banco de dados HeatWave para criar o banco de dados e carregar os dados.
  2. Crie um usuário ggadmin usando o script a seguir. Lembre-se de substituir <ggadmin-password> por uma senha válida:
    CREATE USER 'ggadmin' IDENTIFIED BY '<ggadmin-password>';
    GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT, CREATE,CREATE VIEW, EVENT, INSERT, UPDATE, DROP,EXECUTE, DELETE ON *.* TO 'ggadmin';
  3. Abra port 3306, por meio do qual o OCI GoldenGate pode estabelecer conexão.
    1. Na console do Oracle Cloud, localize a sub-rede que o banco de dados HeatWave usa.
    2. Na lista de segurança da sub-rede, crie uma regra de Entrada para port TCP/3306.
  4. Faça download dos scripts do esquema de destino e, em seguida, execute os scripts na instância do Autonomous Data Warehouse para criar o esquema e as tabelas. Você pode usar a ferramenta SQL do Autonomous Data Warehouse Database Actions para executar os scripts:
    1. Na console do Oracle Cloud, abra a página de detalhes do banco de dados Autonomous Data Warehouse e clique em Database Actions.
    2. No Database Actions, em Desenvolvimento, clique em SQL.
    3. Na ferramenta SQL, copie e cole o script de OCIGGLL_OCIGGS_SETUP_USERS_ADW.sql na planilha SQL e clique em Executar Script. Se a execução for bem-sucedida, a guia Saída do Script exibirá mensagens de confirmação.
    4. Limpe a planilha SQL e copie e cole somente os scripts Criar Tabela de OCIGGLL_OCIGGS_SRC_MIRROR_USER_SEED_DATA.sql. Os dados serão carregados em uma tarefa posterior.

      Dica:

      Talvez seja necessário executar cada instrução Criar Tabela separadamente para que a ferramenta SQL execute os scripts com sucesso.
    5. Para verificar se as tabelas foram criadas com sucesso, feche a janela SQL e reabra-a novamente. Na guia Navegador, procure o esquema SRC_OCIGGLL e selecione as tabelas em suas respectivas listas drop-down.

Tarefa 2: Criar os processos de Extract

  1. Na página Implantações, selecione a implantação do MySQL criada na Tarefa 1.
  2. Na página de detalhes da implantação, clique em Iniciar Console.
  3. Acesse a console de implantação do MySQL de origem usando as credenciais de Administrador especificadas quando você criou a implantação na Tarefa 1.
  4. No menu de navegação, selecione Conexões de BD.
  5. Verifique as credenciais da conexão HeatWave. Anote o Domínio e o Alias.
  6. Adicione e execute um Change Data Capture Extract com os seguintes valores:
    • Para Tipo Extract, selecione Change Data Capture.
    • Em Nome do Processo, informe um nome para o processo Extract.
    • Para Domínio, selecione o domínio.
    • Em Alias, selecione o alias.
    • Para Extract Nome da Trilha, informe um nome para o arquivo de Trilha.
    • Na página Arquivo de Parâmetros, adicione o seguinte:
      TABLE SRC_OCIGGLL.*;
  7. Adicione e execute uma Extração de Carga Inicial com os seguintes valores:
    • Para Tipo Extract, selecione Initial Load Extract.
    • Para Nome do Processo, informe um nome.
    • Na página Arquivo de Parâmetros, adicione o seguinte:
      TABLE SRC_OCIGGLL.*;

Tarefa 3: Criar o Distribution Path para um Initial Load Extract

  1. Na página Implantações, selecione a implantação do Autonomous Database de destino.
  2. Na página de detalhes da implantação, clique em Iniciar Console e faça log-in como o usuário administrador.
  3. Se estiver usando o armazenamento de credenciais do IAM, prossiga para a etapa Criar um Distribution Path. Se estiver usando o armazenamento de credenciais GoldenGate, crie um usuário com o qual a origem GoldenGate use para estabelecer conexão com o destino GoldenGate.
    1. No menu de navegação, clique em Administração de Usuários.
    2. Clique em Adicionar Novo Usuário (ícone de mais), preencha os campos da seguinte forma e clique em Submeter:
      • Para Nome do Usuário, digite ggsnet.
      • Para Atribuição, selecione Operador.
      • Digite a senha duas vezes para verificação.
  4. Na console de implantação de origem PostgreSQL, crie uma Conexão de Caminho para o usuário criado na etapa anterior.
    1. No menu de navegação, clique em Conexões de Caminho.
    2. Clique em Adicionar Conexão de Caminho (ícone de mais), preencha os campos a seguir e clique em Submeter:
      • Para o Alias de Credencial, digite dpuser.
      • Para ID do Usuário, digite ggsnet
      • Para Senha, digite a mesma senha usada na etapa anterior.
  5. Criar um Distribution Path.
    1. Na barra de menu de serviço, clique em Distribution Service e, em seguida, clique em Adicionar Distribution Path (ícone de mais).
    2. Complete o formulário Adicionar caminho da seguinte forma:
      • Na página Informações do Caminho:
        1. Para Nome do Caminho, digite um nome para esse caminho.
        2. Clique em Próximo.
      • Na página Opções de Origem:
        1. Para Origem Extract, deixe em branco.
        2. Para Nome da Trilha, digite o nome da trilha Initial Load Extract (I1).
        3. Clique em Próximo.
      • Na página Opções Alvo:
        1. Para Alvo, selecione wss.
        2. Para Host de Destino, digite o URL de implantação de destino, sem https:// ou qualquer barra à direita.
        3. Para Port Number, digite 443.
        4. Para Nome da Trilha, digite I1.
        5. Para Destinar Método de Autenticação, selecione UserID Alias.
        6. Para Domínio, digite o nome do domínio criado na etapa anterior.
        7. Para Alias, digite o alias criado na etapa anterior (dpuser).
        8. Clique em Próximo.
    3. Clique em Criar e Executar.
    Você retorna à página Distribution Service, na qual pode verificar o caminho criado.
  6. Analise o Distribution Path:
    1. Clique em Receiver Service.
    2. Verifique os detalhes de Distribution Path.

Tarefa 4: Adicione um Replicat para o Initial Load Extract

  1. Na console de implantação do OCI GoldenGate de destino, adicione uma tabela de checkpoint.
    1. Abra o menu de navegação e clique em Conexões de BD.
    2. Clique em Estabelecer conexão com o banco de dados SourceATP.
    3. No menu de navegação, clique em Ponto de Verificação.
    4. Na página Checkpoint, clique em Adicionar Checkpoint (ícone de mais).
    5. Para Tabela de Checkpoint, digite SRCMIRROR_OCIGGLL.CHECKTABLE.
    6. Clique em Enviar.

      Dica:

      A tela não será atualizada no envio. Para confirmar que a tabela de checkpoint foi adicionada, digite SRCMIRROR_OCIGGLL.CHECKTABLE no campo de pesquisa e clique em Pesquisar.
  2. Adicione o Replicat:
    1. Clique em Administrator Service e, em seguida, clique em Adicionar Replicat (ícone de mais).
    2. Na página Adicionar Replicat, preencha os seguintes campos do formulário e clique em Próximo.
      • Para o tipo de Replicat, selecione Nonintegrated Replicat.
      • Em Nome do Processo, digite um nome, como RIL.
    3. Na página Opções de Replicat, preencha os seguintes campos do formulário e clique em Próximo:
      • Para Nome, digite o nome da Trilha da Tarefa 2 (I1).
      • Para Domínio, selecione o domínio da conexão do Autonomous Database.
      • Para Alias, selecione o alias da conexão do Autonomous Database.
      • Para Tabela de Checkpoint, selecione a tabela de Checkpoint criada na Etapa 1.
    4. Na página Opções Gerenciadas, deixe os campos como estão e clique em Próximo.
    5. Na página Parâmetros Replicat, adicione o mapeamento a seguir e clique em Criar e executar:
      MAP SRC_OCIGGLL.*, TARGET SRCMIRROR_OCIGGLL.*;
    Você retornará à página Visão Geral, na qual poderá revisar os detalhes de Replicat.
  3. Selecione o Replicat (RIL) e exiba seus Detalhes.
  4. Clique em Estatísticas e verifique o número de Inserções. Atualize a página.
    • Se o número de Inserções não for alterado, todos os registros do Initial Load terão sido carregados e você poderá interromper o Replicat (RIL)
    • Se o número de Inserções continuar a aumentar, mantenha a atualização da página até que os registros de Carga Inicial sejam todos carregados antes de continuar.

Tarefa 5: Verificar a carga inicial

  1. Na console do Oracle Cloud, abra Database Actions na página de detalhes do banco de dados Autonomous Data Warehouse.
  2. No Database Actions, em Desenvolvimento, clique em SQL.
  3. Na ferramenta SQL, digite cada uma das seguintes instruções na planilha e clique em Executar Instrução:
    SELECT * FROM SRCMIRROR_OCIGGLL.SRC_CITY;
    SELECT * FROM SRCMIRROR_OCIGGLL.SRC_CUSTOMER;
A saída deve retornar os dados que foram carregados nas tabelas do banco de dados de destino como resultado da Carga Inicial.

Tarefa 6: Criar um Distribution Path para um Change Data Capture

  1. Na console de implantação de origem, clique em Distribution Service.
  2. Clique em Adicionar Distribution Path.
  3. Complete o formulário Adicionar caminho da seguinte forma:
    1. Na página Informações do Caminho:
      1. Para Nome do Caminho, digite um nome.
      2. Clique em Próximo.
    2. Na página Opções de Origem:
      1. Para Origem Extract, selecione o Change Data Capture Extract (ECDC).
      2. Para Nome da Trilha, selecione o arquivo de trilha Change Data Capture (C1).
      3. Clique em Próximo.
    3. Na página Opções Alvo:
      1. Para Alvo, selecione wss.
      2. Para Host de Destino, digite o URL da console de implantação de destino (você pode encontrá-lo na página de detalhes da implantação, sem https:// ou qualquer barra à direita.
      3. Para Port Number, digite 443.
      4. Para Nome da Trilha, digite C1.
      5. Para Destinar Método de Autenticação, selecione UserID Alias.
      6. Em Domínio, digite o nome do domínio.
      7. Para Alias, insira o alias.
    4. Clique em Criar Caminho e Executar.
  4. Na console de implantação de destino, clique em Receiver Service e verifique o Receiver path criado.

Tarefa 7: Adicione um Replicat para Change Data Capture

  1. Adicione Replicat com os seguintes valores:
    1. Na página Informações de Replicat:
      • Para Tipo Replicat, selecione Coordinated Replicat.
      • Em Nome do Processo, digite um nome, como RCDC.
    2. Na página Opções Replicat:
      • Para Trilha Replicat, digite o nome da Trilha da Tarefa 2 (C1).
      • Para Domínio, selecione o domínio da conexão do Autonomous Database.
      • Para Alias, informe o Alias da Credencial.
      • Para Tabela de Checkpoint, selecione a tabela de Checkpoint criada.
    3. Na página Parâmetros Replicat, adicione o mapeamento a seguir e clique em Criar e executar:
      MAP SRC_OCIGGLL.*, TARGET SRCMIRROR_OCIGGLL.*;
  2. Na página Visão Geral Administration Service, selecione o Replicat para Initial Load (RIL) e exiba seus Detalhes.
  3. Clique em Estatísticas e verifique o número de Inserções. Atualize a página.
    • Se o número de Inserções não for alterado, todos os registros da Carga Inicial terão sido carregados e você poderá interromper o Replicat (RIL)
    • Se o número de Inserções continuar a aumentar, mantenha a atualização da página até que os registros de Carga Inicial sejam todos carregados antes de continuar.
  4. Volte à página Visão Geral do Serviço de Administração e inicie o Coordinated Replicat (RCDC).
  5. Depois de iniciar o Coordinated Replicat, verifique os Detalhes e as Estatísticas para exibir o número de Inserções.

Tarefa 8: Verificar Change Data Capture

Execute atualizações no banco de dados de origem HeatWave para verificar a replicação no Autonomous Data Warehouse.
  1. No OCI Bastion, crie uma sessão de encaminhamento de porta SSH usando o IP do MySQL e a porta 3306. Adicione a chave SSH pública.
  2. Conecte-se ao MySQL no Cloud Shell usando sua chave privada e a porta 3306.
  3. Após a conexão bem-sucedida, execute o seguinte comando:
    mysqlsh admin@localhost:3306 --sql
  4. Execute o seguinte script para fazer inserções no banco de dados HeatWave:
    use SRC_OCIGGLL;
    Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1000,'Houston',20,743113);
    Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1001,'Dallas',20,822416);
    Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1002,'San Francisco',21,157574);
    Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1003,'Los Angeles',21,743878);
    Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1004,'San Diego',21,840689);
    Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1005,'Chicago',23,616472);
    Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1006,'Memphis',23,580075);
    Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1007,'New York City',22,124434);
    Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1008,'Boston',22,275581);
    Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1009,'Washington D.C.',22,688002);
    commit;
  5. Na console de implantação do MySQL de origem, selecione o nome do Change Data Capture Extract e clique em Estatísticas. Verifique se SRC_OCIGGLL.SRC_CITY tem 10 inserções.

    Observação:

    Se o Extract não tiver capturado inserções, reinicie o Extract.

Tarefa 9: Monitorar e manter processos

  1. Monitorar o desempenho.
  2. Gerenciar arquivos de Trilha.