SQL エディターを使用した StarRocks インスタンスへの接続 - E-MapReduce

背景情報

SQL エディターは EMR StarRocks Manager のインタラクティブクエリツールであり、クライアントソフトウェアをインストールすることなく、コンソールから直接 SQL クエリを作成、実行、管理できます。この機能により、リアルタイムのデータクエリと分析が簡素化され、データアナリストや開発者の効率が向上します。詳細については、「SQL エディター」をご参照ください。

前提条件

EMR Serverless StarRocks インスタンスを作成済みであること。詳細については、「インスタンスの作成」をご参照ください。

操作手順

インスタンスリストページに移動します。
1. E-MapReduce コンソールにログインします。
2. 左側メニューで、[EMR Serverless] > StarRocks を選択します。
3. 上部メニューで、要件に基づいてリージョンを選択します。
インスタンスのリスト ページで、対象のインスタンスを見つけ、操作列の インスタンスの接続 をクリックします。

StarRocks インスタンスに接続します。

新しい接続

New Connection タブで、次のパラメーターを設定します。

パラメーター	例	説明
[Region]	China (Hangzhou)	EMR Serverless StarRocks インスタンスが配置されているリージョン。
[インスタンス]	StarRocks_Serverlesss	EMR Serverless StarRocks インスタンスの名前。
[Name]	Connection_Serverlesss	接続のカスタム名。名前は 1～64 文字で、漢字、英字、数字、ハイフン (-)、アンダースコア (_) を使用できます。
[ユーザー名]	必要に応じて入力	デフォルトのユーザー名は admin です。このユーザー名を使用して接続するか、他のユーザーを作成できます。
[Password]	必要に応じて入力	StarRocks インスタンスで指定されたユーザー名のパスワード。

Test Connectivity をクリックします。
テストが成功したら、OK をクリックします。

既存の接続

重要

対象のインスタンスが存在することを確認してください。インスタンスが削除された場合は、新しい接続を作成する必要があります。

Existing Connections タブで、目的の接続を見つけ、操作列の Connectivity をクリックします。

(任意) StarRocks インスタンスで操作を実行します。

[SQL editor] の Queries ページで、ファイル または右側のペインにあるアイコンをクリックし、Confirm をクリックして新しいファイルを作成します。

新しいファイルに次の SQL 文を入力し、実行をクリックします。

/* データベースを作成します。*/
create database test_sql_editor_db;
/* データベースを使用します。*/
use test_sql_editor_db;
/* テーブルを作成します。*/
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 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,
        'fcf9ac58-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'
    );
/* テーブル情報を表示します。*/
select * from test_sql_editor_db.emr_query_logs;

クエリ結果は以下のとおりです。