Realtime Compute for Apache Flink:Gerencie catálogos do MySQL

Console (recommended)

1. Acesse a página Data Management.

   1. Faça login no console do Realtime Compute for Apache Flink. Na coluna Actions do workspace a ser gerenciado, clique em Console.

   2. No painel de navegação à esquerda, clique em Data Management.

2. Clique em Create Catalog, selecione MySQL e, em seguida, clique em Next.

3. Configure os parâmetros.

   Importante

   Não modifique esses parâmetros de configuração após a criação. Para fazer alterações, exclua e recrie o catálogo.

   Parâmetro	Descrição	Obrigatório
   catalogname	Nome do catálogo do MySQL.	Sim
   hostname	Endereço IP ou hostname do banco de dados MySQL. Nota Para conectar VPCs diferentes ou acessar pela internet, estabeleça a conectividade de rede. Para mais informações, consulte network connectivity.	Sim
   port	Número da porta do banco de dados MySQL. Padrão: 3306.	Não
   default-database	Nome do banco de dados MySQL padrão.	Sim
   username	Nome de usuário do banco de dados MySQL.	Sim
   password	Senha do banco de dados MySQL. Para evitar a exposição de segredos em texto simples, recomendamos usar uma variável. O exemplo usa uma variável chamada mysqlpw. Para mais informações, consulte Create a variable.	Sim

4. Clique em OK.

   O catálogo criado aparece na área Catalogs, à esquerda.

SQL command

1. Acesse a página Scripts.

   1. Faça login no console do Realtime Compute for Apache Flink. Na coluna Actions do workspace a ser gerenciado, clique em Console.

   2. No painel de navegação à esquerda, clique em Development > Scripts.

2. Clique em , clique em New Script, insira o File Name e o Storage Location e, em seguida, clique em Save.

3. Insira o seguinte código.

   CREATE CATALOG YourCatalogName WITH(
     'type' = 'mysql',
     'hostname' = 'rm-bp1gcn0q0j0******.mysql.rds.aliyuncs.com',
     'port' = '3306',
     'username' = 'usertest',
     'password' = '${secret_values.mysqlpw}',
     'default-database' = 'flinktest',
     'catalog.table.metadata-columns'='table_name'
   );

   Parâmetro	Descrição	Obrigatório
   YourCatalogName	Nome do catálogo do MySQL.	Sim
   type	Tipo do catálogo. Defina como mysql.	Sim
   hostname	Endereço IP ou hostname do banco de dados MySQL. Nota Para conectar VPCs diferentes ou acessar pela internet, estabeleça a conectividade de rede. Para mais informações, consulte network connectivity.	Sim
   port	Número da porta do banco de dados MySQL. Padrão: 3306.	Não
   default-database	Nome do banco de dados MySQL padrão.	Sim
   username	Nome de usuário do banco de dados MySQL.	Sim
   password	Senha do banco de dados MySQL. Para evitar a exposição de segredos em texto simples, recomendamos usar uma variável. O exemplo usa uma variável chamada mysqlpw. Para mais informações, consulte Create a variable.	Sim
   property-version	Versão do esquema de propriedades do catálogo. Defina como 0 (padrão) ou 1 (recomendado). Diferentes versões podem ter suporte a propriedades e valores padrão distintos. Consulte as descrições das propriedades para mais detalhes. Nota Compatível apenas com o VVR 8.0.6 e versões posteriores. No VVR 11.1 e versões posteriores, o valor padrão é 1.	Não
   catalog.table.metadata-columns	Especifique as colunas de metadados de uma tabela de origem CDC do MySQL a serem adicionadas ao esquema da tabela durante a consulta. Por padrão, nenhuma coluna de metadados é adicionada. Separe várias colunas de metadados com ponto e vírgula (;), por exemplo: op_ts;table_name;database_name. Nota Compatível apenas com o VVR 6.0.5 e versões posteriores. Definir esta propriedade adiciona as colunas de metadados especificadas ao esquema. Como essas colunas são específicas de tabelas de origem CDC do MySQL, use tabelas deste catálogo apenas como tabelas de origem, e não como tabelas de destino ou de dimensão.	Não
   catalog.table.treat-tinyint1-as-boolean	Ao buscar um esquema de tabela, especifica se os tipos TinyInt(1) e Boolean do MySQL devem ser mapeados para Boolean do Flink. Valores válidos: true: mapeia para Boolean. false: mapeia para TINYINT. Valor padrão: Se property-version for 0, o valor padrão é true. Se property-version for 1, o valor padrão é false. Nota Compatível apenas com o VVR 8.0.4 e versões posteriores. Não recomendamos usar TinyInt(1) no MySQL para armazenar valores diferentes de 0 e 1. Escolha um mapeamento de tipo apropriado. Para mais informações, consulte Type mapping.	Não

4. Selecione a instrução CREATE CATALOG e clique em Run ao lado do número da linha à esquerda.

   A mensagem The following statement has been executed successfully! indica que o catálogo foi criado.

   A instrução SQL no editor, CREATE CATALOG myCatalog, tem parâmetros de configuração que incluem type=mysql, hostname=rm-bp1gcn0q0j0.mysql.rds.aliyuncs.com, port=3306, username=usertest, password=${secret_values.mysqlpw} (referência a uma variável), default-database=flinktest e catalog.table.metadata-columns=table_name.

Console (recommended)

Na página Data Management, visualize o Name e o Type dos catálogos criados na Catalog List.

• Visualize: na coluna Actions do catálogo, clique em View para ver os bancos de dados e as tabelas do catálogo.

  Os detalhes do esquema da tabela não exibem comentários de campos.

• Exclua: na coluna Actions do catálogo, clique em Delete.

  Esta operação exclui apenas o catálogo, e não as tabelas subjacentes no service associado. As implantações ativas que usam tabelas do catálogo não são afetadas. No entanto, reimplantar ou reiniciar essas implantações causará um erro, pois as tabelas não serão mais encontradas. Prossiga com cautela.

SQL command

1. No editor da página Scripts, insira os seguintes comandos.

   -- View the table schema in Flink. Field comments are not displayed.
   DESCRIBE `<catalogname>`.`<dbname>`.`<tablename>`;
   -- Delete the catalog.
   DROP CATALOG `<catalogname>`;

   Nota

   Esta operação exclui apenas o catálogo, e não as tabelas subjacentes no service associado. As implantações em execução que usam tabelas do catálogo não são afetadas. No entanto, se você reimplantar ou reiniciar uma implantação, um erro será relatado, pois a tabela não poderá ser encontrada. Prossiga com cautela.

2. Selecione o comando, clique com o botão direito e escolha Run.

   A execução da instrução DESCRIBE retorna o esquema de uma tabela, incluindo campos como orderkey, custkey, order_status e total_price, juntamente com seus tipos de dados e propriedades.