E-MapReduce:Conectar ao Serverless StarRocks usando o EMR StarRocks Manager

Contexto

O editor SQL é uma ferramenta de consulta interativa no EMR StarRocks Manager que permite escrever, executar e gerenciar consultas SQL diretamente do console, sem instalar software cliente. Para mais informações, consulte SQL editor.

Pré-requisitos

Crie uma instância do EMR Serverless StarRocks. Para mais informações, consulte Create an instance.

Procedimento

1. Acesse a página de lista de instâncias.

   1. Faça login no console do E-MapReduce.

   2. No painel de navegação à esquerda, escolha EMR Serverless > StarRocks.

   3. Na barra de navegação superior, selecione a região desejada.

2. Na página Instances, localize a instância e clique em Connect na coluna Actions.

3. Conecte-se à instância StarRocks.

   Nova conexão

   1. Na aba New Connection, configure os seguintes parâmetros.

      Parâmetro	Exemplo	Descrição
      Region	China (Hangzhou)	Região da instância do EMR Serverless StarRocks.
      Instance	StarRocks_Serverlesss	Nome da instância do EMR Serverless StarRocks.
      Name	Connection_Serverlesss	Nome personalizado da conexão. O nome deve ter de 1 a 64 caracteres e pode conter caracteres chineses, letras, dígitos, hifens (-) e sublinhados (_).
      Username	Insira conforme necessário	O nome de usuário padrão é admin. Use-o para se conectar ou criar outros usuários.
      Password	Insira conforme necessário	Senha do nome de usuário especificado na instância StarRocks.

   2. Clique em Test Connectivity.

   3. Se o teste for bem-sucedido, clique em OK.

   Conexões existentes

   Importante

   Verifique se a instância de destino ainda existe. Se a instância foi excluída, crie uma nova conexão.

   Na aba Existing Connections, localize a conexão desejada e clique em Connectivity na coluna Actions.

4. (Opcional) Execute operações na instância StarRocks.

   1. No editor SQL, na página Queries, clique em Configuration File ou no ícone no painel direito e clique em Confirm para criar um novo arquivo.

   2. No novo arquivo, insira as instruções SQL a seguir e clique em Run.

      /* Create a database. */
      create database test_sql_editor_db;
      /* Use the database. */
      use test_sql_editor_db;
      /* Create a table. */
      CREATE TABLE
          `emr_query_logs` (
              `conn_id` varchar(10) NULL COMMENT "",
              `database` varchar(100) NULL COMMENT "",
              `start_time` bigint (20) NULL COMMENT "",
              `end_time` bigint (20) NULL COMMENT "",
              `event_time` bigint (20) NULL COMMENT "",
              `is_query` boolean NULL COMMENT "",
              `latency` int (11) NULL COMMENT "",
              `query_id` varchar(40) NULL COMMENT "",
              `remote_ip` varchar(15) NULL COMMENT "",
              `state` varchar(20) NULL COMMENT "",
              `user` varchar(20) NULL COMMENT ""
          ) ENGINE = OLAP DUPLICATE KEY (`conn_id`) COMMENT "OLAP" DISTRIBUTED BY HASH (`user`) BUCKETS 10 PROPERTIES (
              "replication_num" = "2",
              "in_memory" = "false",
              "storage_format" = "DEFAULT",
              "enable_persistent_index" = "false",
              "compression" = "LZ4"
          );
      /* Insert data. */
      insert into
          test_sql_editor_db.emr_query_logs (
              `conn_id`,
              `database`,
              `start_time`,
              `end_time`,
              `event_time`,
              `is_query`,
              `latency`,
              `query_id`,
              `remote_ip`,
              `state`,
              `user`
          )
      values
          (
              '54656',
              'tpc_h_sf1',
              1691635106990,
              1691635107405,
              1691635107405000000,
              1,
              415,
              'fbec0dd7-3726-11ee-a3ef-720338511ec3',
              '10.0.**.**',
              'FINISHED',
              'admin'
          ),
          (
              '54658',
              'tpc_h_sf1',
              1691635107632,
              1691635107860,
              1691635107860000000,
              1,
              228,
              'fc4e0301-3726-11ee-a3ef-720338511ec3',
              '10.0.**.**',
              'FINISHED',
              'admin'
          ),
          (
              '54659',
              'tpc_h_sf1',
              1691635108757,
              1691635108930,
              1691635108930000000,
              1,
              173,
              'fcf9ac5s8-3726-11ee-a3ef-720338511ec3',
              '10.0.**.**',
              'FINISHED',
              'admin'
          ),
          (
              '54661',
              'tpc_h_sf1',
              1691635108994,
              1691635109137,
              1691635109137000000,
              1,
              143,
              'fd1dd62e-3726-11ee-a3ef-720338511ec3',
              '10.0.**.**',
              'FINISHED',
              'admin'
          ),
          (
              '54663',
              'tpc_h_sf1',
              1691635109445,
              1691635109533,
              1691635109533000000,
              1,
              88,
              'fd62a765-3726-11ee-a3ef-720338511ec3',
              '10.0.**.**',
              'FINISHED',
              'admin'
          ),
          (
              '54664',
              'tpc_h_sf1',
              1691635109724,
              1691635109907,
              1691635109907000000,
              1,
              183,
              'fd8d39d9-3726-11ee-a3ef-720338511ec3',
              '10.0.**.**',
              'FINISHED',
              'admin'
          );
      /* View table information. */
      select * from test_sql_editor_db.emr_query_logs;

      Os resultados da consulta são exibidos abaixo.