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 necessidade de instalar software cliente. Esse recurso simplifica a consulta e a análise de dados em tempo real, aumentando a eficiência de analistas de dados e desenvolvedores. Para mais informações, consulte Editor SQL.

Pré-requisitos

Crie uma instância EMR Serverless StarRocks. Para mais informações, consulte Criar uma instância.

Procedimento

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

   1. Faça login no console 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 sua 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 onde a instância EMR Serverless StarRocks está localizada.
      Instance	StarRocks_Serverlesss	Selecione o nome da sua instância EMR Serverless StarRocks.
      Name	Connection_Serverlesss	Nome personalizado para a 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 esse nome de usuário para se conectar ou criar outros usuários.
      Password	Insira conforme necessário	Senha correspondente ao nome de usuário especificado na instância StarRocks.

   2. Clique em Test Connectivity.

   3. Após o teste bem-sucedido, clique em OK.

   Conexões existentes

   Importante

   Certifique-se de que 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 seguintes instruções SQL 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 aparecem abaixo.