Todos os produtos
Search

Este produto

    Realtime Compute for Apache Flink:Modelos de sincronização de dados

    Central de documentação

    Realtime Compute for Apache Flink:Modelos de sincronização de dados

    Última atualização: Jun 27, 2026

    Escrever Flink SQL do zero para sincronizar dados do MySQL com o Hologres exige conhecimento da sintaxe das instruções CDAS e CTAS, tratamento manual de alterações de schema e gerenciamento de server IDs para conectores CDC. Os modelos de sincronização de dados geram esse SQL automaticamente: basta selecionar os catálogos de origem e destino, escolher um método de sincronização e o modelo produz um arquivo Flink SQL pronto para implantação, cobrindo dados completos, dados incrementais e alterações de schema.

    Métodos de sincronização

    Há dois métodos disponíveis. Escolha conforme a estrutura dos seus dados de origem:

    Método

    Quando usar

    SQL gerado

    Sincronização multi-banco multi-tabela

    Para sincronizar uma ou mais tabelas de um ou mais bancos de dados para um único banco de dados de destino

    CREATE DATABASE AS (CDAS)

    Fusão de dados fragmentados

    Para consolidar várias tabelas fragmentadas com schema semelhante em uma única tabela de destino

    CREATE TABLE AS (CTAS)

    Ambos os métodos usam conectores Flink Change Data Capture (CDC) para sincronizar automaticamente dados completos, dados incrementais e alterações de schema (como adição de colunas) de cada tabela de origem para o destino.

    Limitações

    Os modelos de sincronização de dados aceitam apenas MySQL como origem e Hologres como destino.

    Pré-requisitos

    Antes de começar, verifique se você tem:

    Criação de tabela: O Realtime Compute for Apache Flink cria automaticamente a tabela de destino no Hologres. Se a tabela já existir, a sincronização dos dados usará o banco de dados e a tabela de destino selecionados durante a criação do plano.

    Alteração de tipo de dados: O Hologres não permite alterar tipos de dados de colunas. Se o tipo de dados de um campo de origem diferir do tipo na tabela Hologres existente, a gravação falhará. Altere o tipo de dados da coluna e sincronize novamente.

    Nomenclatura padrão: O modelo cria o banco de dados e a tabela de destino com os mesmos nomes do catálogo de origem e os sincroniza por padrão no schema public. Para alterar o nome do banco de dados, da tabela ou do schema, use instruções SQL. Consulte CREATE TABLE AS (CTAS) e CREATE DATABASE AS (CDAS).

    Sincronizar dados usando um modelo

    1. Faça login no console do Realtime Compute for Apache Flink.

    2. Localize o workspace e clique em Console na coluna Actions.

    3. No painel de navegação à esquerda, clique em Development > ETL. Clique no ícone image e selecione New Draft with Template.

    4. Na caixa de diálogo New Draft, clique na aba Flink CDC. Selecione o cartão Data Synchronization from MySQL to Hologres e clique em Next.

    5. Configure a origem e o destino: clique em Next.

      CategoriaParâmetroDescrição
      OrigemMySQL CatalogSelecione um catálogo MySQL existente. Se não houver nenhum, clique em Create Catalog. Consulte Gerenciar catálogos MySQL.
      OrigemMySQL server-idInsira um ID exclusivo para cada cliente de banco de dados MySQL. Valores válidos: 5400–6400. Você também pode especificar um intervalo (por exemplo, 5400-5408). Se a leitura paralela estiver ativada no modo de leitura incremental, especifique um intervalo para atribuir um server ID exclusivo a cada thread paralela.
      Importante

      Não use o mesmo server-id para diferentes implantações ou serviços que acessam o banco de dados.

      DestinoHologres CatalogSelecione um catálogo Hologres existente. Se não houver nenhum, clique em Create Catalog. Consulte Gerenciar catálogo Hologres.

      选择源和目标

    6. Crie um plano. Siga as etapas correspondentes ao método de sincronização escolhido:

      • Sincronização multi-banco multi-tabela

        1. Na aba To Single Database, selecione o banco de dados e a tabela de origem. 数据模板中文

        2. Clique em Save Plan. O plano aparecerá na lista de planos. 计划列表

          Nota

          O modelo cria um banco de dados e uma tabela no catálogo de destino com os mesmos nomes da origem e os sincroniza por padrão no schema public. Para personalizar o nome do banco de dados, da tabela ou do schema, use instruções SQL. Consulte CREATE TABLE AS (CTAS) e CREATE DATABASE AS (CDAS).

        3. Clique em Next.

        4. Revise o SQL gerado. Modifique Name, Location ou Engine Version conforme necessário. 多库多表SQL预览

      • Fusão de dados fragmentados

        1. Na aba To Multiple Databases, selecione os bancos de dados e as tabelas de origem ou insira os nomes do banco de dados e da tabela de destino. 分库分表 Recomendamos usar expressões regulares para especificar os bancos de dados e as tabelas de origem.

        2. Clique em Save Plan. O plano aparecerá na lista de planos. 计划列表 É possível criar vários planos — para sincronização multi-banco multi-tabela e fusão de dados fragmentados — em um único rascunho. 多个执行计划

        3. Clique em Next.

        4. Revise o SQL gerado. Modifique Name, Location ou Engine Version conforme necessário. 分库分表SQL预览

    7. Clique em Create. O sistema redireciona você para a página do Editor SQL. A partir daí, o fluxo de trabalho segue o padrão de uma implantação comum. Consulte Mapa de desenvolvimento de jobs e Iniciar uma implantação de job.

    Próximos passos