Replicar Dados do HeatWave no OCI para o Google Cloud Storage

Saiba como usar o OCI GoldenGate para replicar dados do HeatWave no OCI para o Google Cloud Storage.

Antes de começar

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

Tarefa 0: Configurar o ambiente

Para configurar o ambiente para esse Início Rápido:
  1. Faça download do script dos dados de amostra e, em seguida, execute o script no HeatWave do banco de Dados do OCI para criar o banco de Dados e carregar os dados.
  2. Crie um usuário ggadmin usando o script a seguir. Lembre 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, pelo qual o OCI GoldenGate pode estabelecer conexão.
    1. Na console do Oracle Cloud, localize a sub-rede que o HeatWave no banco de dados do OCI usa.
    2. Na lista de segurança da sub-rede, crie uma regra de Entrada para port TCP/3306.

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. Abra o menu de navegação e selecione Configuração.
  5. Verifique as credenciais da conexão do MySQL Database Server. Anote o Domínio e o Alias.
  6. Retorne à página Visão Geral do Serviço de Administração.
  7. Na página Visão Geral do Serviço de Administração, clique em Adicionar Extract (ícone de mais).
  8. Na página Tipo de Extract, selecione Extract de Captura de Dados de Alteração e clique em Próximo.
  9. Preencha as Opções de Extract da seguinte forma e clique em Próximo:
    1. Para Nome do Processo, digite um nome para o Extract, como CDCEXT.
    2. Para Domínio da Credencial, selecione o domínio na Etapa 5.
    3. Para Alias da Credencial, selecione o alias na Etapa 5.
    4. Para Nome da Trilha, digite um nome de trilha com dois caracteres, como C1.
  10. Ative Remoto se estiver capturando de um MySQL Database que não esteja usando identificadores de transação global (GTIDs).
  11. Na página Parâmetros do Processo de Extract, adicione o seguinte:
    TABLE SRC_OCIGGLL.*;
  12. Clique em Criar e Executar.

    Você retornará à página Visão Geral do Serviço de Administração, na qual poderá observar o início do processo de Extract.

Tarefa 3: Criar o Caminho de Distribuição para a implantação de Big Data de destino

  1. Na página Implantações, selecione a implantação do Big Data de destino.
  2. Na página de detalhes da implantação, clique em Iniciar Console.
  3. Crie um usuário para o Caminho de Distribuição:
    1. Abra o menu de navegação e clique em Administrador.
    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 do MySQL de origem, crie uma credencial para o usuário criado na etapa anterior.
    1. Abra o menu de navegação e selecione Configuração.
    2. Clique em Adicionar Credencial (ícone de mais), preencha os campos da seguinte forma e clique em Submeter:
      • Para Domínio da Credencial, digite GGSNetwork.
      • Para Alias da Credencial, digite dpuser.
      • Para Nome do Banco de Dados, você pode digitar qualquer nome e deixar os campos Servidor de Banco de Dados e Porta em branco ou usar os valores padrão.
      • Para ID do Usuário, digite ggsnet.
      • Para Senha, digite a mesma senha usada na etapa anterior.
  5. Criar um Caminho de Distribuição:
    1. Na console de implantação de origem MySQL, clique em Serviço de Distribuição e, em seguida, clique em Adicionar Caminho (ícone de mais).
    2. Preencha os seguintes campos e clique em Criar e Executar:
    • Para Nome do Caminho, digite um nome para esse caminho.
    • Para Extract de Origem, selecione Alterar Extract de Captura de Dados (CDCEXT).
    • Para Nome da Trilha, selecione o arquivo de trilha do processo de Extract de Captura de Dados de Alteração (C1).
    • Para Método de Autenticação de Destino, selecione Alias do ID do Usuário.
    • Para Destino, selecione wss.
    • Para Host de Destino, digite o URL da console de implantação do OCI GoldenGate de destino, sem https:// ou qualquer barra à direita.
    • Para Número da Porta, digite 443.
    • Para Nome da Trilha, digite C1.
    • Para Domínio, digite o nome do domínio criado na etapa anterior.
    • Para Alias, digite o alias criado na etapa anterior.

    Você retornará à página Visão Geral do Serviço de Distribuição, na qual poderá verificar o caminho criado.

  6. Na console de implantação do Big Data do OCI GoldenGate de destino, verifique o caminho do Recebedor criado como resultado do caminho de Distribuição:
    1. Clique em Serviço do Receptor.
    2. Verifique os detalhes do caminho do Receptor.

Tarefa 4: Adicionar um Replicat para o Google Cloud Storage

  1. Na implantação do Big Data, clique em Administration Service e, em seguida, clique em Adicionar Replicat (ícone de mais).
  2. Adicione um Replicat com os seguintes valores:
    1. Na página Informações de Replicat, em tipo Replicat, selecione Classic Replicat e informe um Nome de Processo.
    2. Na página Opções Replicat:
      • Para Nome, digite o nome da Trilha da Tarefa 2.
      • Para Destino, selecione Google Cloud Storage.
      • Para Alias, selecione a conexão do Google Cloud Storage criada na Tarefa 1.
    3. Na página Parâmetros Replicat, deixe o padrão.
    4. Na página Arquivo de Propriedades, procure gg.eventhandler.gcs.bucketMappingTemplate=<gcs bucket> e substitua <gcs bucket> pelo nome do bucket. Se você não tiver um bucket, o OCI GoldenGate criará um para você.
    5. Clique em Criar e Executar.

Tarefa 5: Verificar Replicação de Dados do HeatWave no OCI para o Google Cloud Storage

Execute atualizações na origem HeatWave no banco de dados do OCI para verificar a replicação no Google Cloud Storage.
  1. No OCI Bastion, crie uma sessão de encaminhamento de porta SSH usando o IP MySQL e o port 3306. Adicione a chave SSH pública.
  2. Conecte-se ao MySQL no Cloud Shell usando sua chave privada e o port 3306.
  3. Após a conexão bem-sucedida, execute o seguinte comando:
    mysqlsh admin@localhost:3306 --sql
  4. Execute o seguinte script para executar inserções no HeatWave no banco de dados do OCI:
    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 MySQL de origem, selecione o nome Change Data Capture Extract (ECDC) e clique em Estatísticas. Verifique se SRC_OCIGGLL.SRC_CITY tem 10 inserções.
  6. Na console de implantação do Big Data de destino, selecione o Nome Replicat e clique em Estatísticas. Verifique se SRC_OCIGGLL.SRC_CITY tem 10 inserções.
  7. No Google Cloud Storage, você pode verificar as mensagens no stream de dados de destino/visualizador de dados.