E-MapReduce：Gunakan EMR StarRocks Manager untuk terhubung ke instance StarRocks EMR Serverless

Informasi latar belakang

Editor SQL adalah editor query interaktif yang disediakan oleh EMR StarRocks Manager. Anda dapat menulis, menjalankan, dan mengelola pernyataan query SQL di Editor SQL EMR StarRocks Manager tanpa perlu mengunduh atau menginstal perangkat lunak klien lokal apa pun. Ini membantu analis data dan pengembang untuk meminta dan menganalisis data secara real-time, serta meningkatkan efisiensi kerja. Untuk informasi lebih lanjut, lihat Editor SQL.

Prosedur

1. Pergi ke tab Instances.

   1. Masuk ke Konsol EMR.

   2. Di panel navigasi di sebelah kiri, pilih EMR Serverless > StarRocks.

   3. Di bilah navigasi atas, pilih wilayah sesuai dengan kebutuhan bisnis Anda.

2. Di tab Instances, temukan instance StarRocks EMR Serverless yang telah dibuat dan klik Connect di kolom Actions.

3. Terhubung ke instance StarRocks EMR Serverless.

   Buat koneksi

   1. Di tab New Connection, konfigurasikan parameter yang dijelaskan dalam tabel berikut.

      

      Parameter	Contoh	Deskripsi
      Region	Tiongkok (Hangzhou)	Wilayah tempat instance StarRocks EMR Serverless berada.
      Instance	StarRocks_Serverlesss	Nama instance StarRocks EMR Serverless.
      Connection Name	Connection_Serverlesss	Nama kustom untuk koneksi. Nama harus memiliki panjang 1 hingga 64 karakter, dan dapat berisi huruf, angka, tanda hubung (-), dan garis bawah (_).
      Username	Nama pengguna yang digunakan untuk masuk ke instance StarRocks EMR Serverless.	Nama pengguna awal default adalah admin. Anda dapat menggunakan nama pengguna ini untuk terhubung ke instance StarRocks EMR Serverless atau membuat pengguna lain berdasarkan kebutuhan bisnis Anda.
      Password	Kata sandi yang digunakan untuk masuk ke instance StarRocks EMR Serverless.	Kata sandi ditentukan saat Anda membuat instance StarRocks EMR Serverless.

   2. Klik Test Network Connectivity.

   3. Setelah tes konektivitas berhasil, klik OK.

   Gunakan koneksi yang ada

   null

   Jika Anda menggunakan koneksi yang ada, pastikan bahwa instance StarRocks EMR Serverless yang terhubung masih tersedia. Jika instance StarRocks EMR Serverless dihapus, buat koneksi baru.

   Di tab Existing Connections, temukan koneksi yang ingin digunakan dan klik Connect di kolom Actions.

   

4. Opsional. Lakukan operasi pada instance StarRocks EMR Serverless.

   1. Di panel navigasi sebelah kiri, klik SQL Editor. Pada tab Queries, klik File atau ikon untuk membuat file. Dalam kotak dialog Create File, atur parameter yang diperlukan dan klik Confirm.

   2. Di editor kode, masukkan pernyataan SQL berikut dan klik Run:

/* Buat database. */create database test_sql_editor_db;/* Gunakan database. */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 ke dalam tabel. */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 query ditampilkan di tab Output Result. Gambar berikut menunjukkan contohnya.