E-MapReduce:Hubungkan ke Serverless StarRocks menggunakan EMR StarRocks Manager

Latar Belakang

Editor SQL adalah alat kueri interaktif di EMR StarRocks Manager yang memungkinkan Anda menulis, menjalankan, dan mengelola kueri SQL langsung dari Konsol tanpa perlu menginstal perangkat lunak klien. Fitur ini menyederhanakan kueri dan analisis data secara real-time, sehingga meningkatkan efisiensi bagi analis data dan pengembang. Untuk informasi selengkapnya, lihat editor SQL.

Prasyarat

Anda telah membuat instans EMR Serverless StarRocks. Untuk informasi selengkapnya, lihat Buat instans.

Prosedur

1. Buka halaman daftar instans.

   1. Masuk ke Konsol E-MapReduce.

   2. Pada panel navigasi kiri, pilih EMR Serverless > StarRocks.

   3. Pada bilah navigasi atas, pilih Wilayah sesuai kebutuhan Anda.

2. Pada halaman Instances, temukan instans Anda dan klik Connect di kolom Actions.

3. Hubungkan ke instans StarRocks.

   New connection

   1. Pada tab New Connection, konfigurasikan parameter berikut.

      Parameter	Contoh	Deskripsi
      Region	China (Hangzhou)	Wilayah tempat instans EMR Serverless StarRocks Anda berada.
      Instance	StarRocks_Serverlesss	Pilih nama instans EMR Serverless StarRocks Anda.
      Name	Connection_Serverlesss	Nama kustom untuk koneksi tersebut. Nama harus terdiri dari 1 hingga 64 karakter dan dapat berisi karakter Tionghoa, huruf, angka, tanda hubung (-), dan garis bawah (_).
      Username	Masukkan sesuai kebutuhan	Username default adalah admin. Anda dapat menggunakan username ini untuk terhubung atau membuat pengguna lain.
      Password	Masukkan sesuai kebutuhan	Password untuk username yang ditentukan dalam instans StarRocks.

   2. Klik Test Connectivity.

   3. Setelah pengujian berhasil, klik OK.

   Existing connections

   Penting

   Pastikan instans tujuan masih ada. Jika instans telah dihapus, Anda harus membuat koneksi baru.

   Pada tab Existing Connections, temukan koneksi yang diinginkan dan klik Connectivity di kolom Actions.

4. (Opsional) Lakukan operasi pada instans StarRocks.

   1. Pada editor SQL, di halaman Queries, klik Configuration File atau ikon di panel kanan, lalu klik Confirm untuk membuat file baru.

   2. Pada file baru tersebut, masukkan Pernyataan SQL berikut dan klik Run.

      /* Buat database. */
      create database test_sql_editor_db;
      /* Gunakan database tersebut. */
      use test_sql_editor_db;
      /* Buat tabel. */
      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"
          );
      /* Masukkan 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'
          );
      /* Lihat informasi tabel. */
      select * from test_sql_editor_db.emr_query_logs;

      Hasil kueri akan ditampilkan di bawah.