E-MapReduce:Gunakan SQL Editor untuk mengoperasikan instans StarRocks

Prasyarat

Sebelum memulai, pastikan Anda telah memiliki:

• Instans EMR Serverless StarRocks

• Kredensial instans (username dan password yang ditetapkan saat pembuatan instans)

Hubungkan ke SQL editor

1. Masuk ke Konsol EMR.

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

3. Pada bilah navigasi atas, pilih wilayah tempat instans Anda berada.

4. Pada tab Instances, temukan instans Anda dan klik Connect di kolom Actions.

5. Hubungkan ke instans tersebut. Jika ini pertama kalinya Anda menghubungkan ke instans ini, buat koneksi baru. Jika sebelumnya sudah pernah terhubung, gunakan koneksi yang sudah ada.

   Create a new connection

   1. Pada tab New Connection, konfigurasikan parameter berikut.

      

      Parameter	Description	Example
      Region	Wilayah tempat instans EMR Serverless StarRocks berada.	China (Hangzhou)
      Instance	Nama instans EMR Serverless StarRocks.	StarRocks_Serverlesss
      Connection Name	Nama kustom untuk koneksi ini. Harus terdiri dari 1–64 karakter dan dapat berisi huruf, angka, tanda hubung (-), serta garis bawah (_).	Connection_Serverlesss
      Username	Username untuk masuk ke instans. Username awal default adalah admin. Anda juga dapat membuat pengguna lain sesuai kebutuhan bisnis.	admin
      Password	Password yang ditetapkan saat Anda membuat instans.	—

   2. Klik Test Network Connectivity.

   3. Setelah pengujian konektivitas berhasil, klik OK.

   Use an existing connection

   Penting

   Jika instans EMR Serverless StarRocks yang terkait dengan koneksi tersimpan telah dihapus, buat koneksi baru sebagai gantinya.

   Pada tab Existing Connections, temukan koneksi tersebut dan klik Connect di kolom Actions.

   

Jalankan kueri SQL

Langkah-langkah berikut memandu Anda dalam membuat database dan tabel, memasukkan data, serta melakukan kueri menggunakan SQL Editor.

1. Pada panel navigasi kiri, klik SQL Editor. Pada tab Queries, klik File atau ikon untuk membuat file. Pada kotak dialog Create File, konfigurasikan parameter dan klik Confirm.

2. Pada editor kode, tempel 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 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;

1. Hasil kueri ditampilkan pada tab Output result. Gambar berikut menunjukkan contohnya.

   

Langkah berikutnya

Untuk mengetahui seluruh kemampuan EMR StarRocks Manager — termasuk manajemen data, diagnostik dan analitik, serta konfigurasi izin keamanan — lihat SQL editor.