Hologres:クイックスタート：仮想ウェアハウスの使用

背景情報

仮想ウェアハウスは、リソース分離、弾力性、読み書き分離、およびワークロード分離を提供します。詳細については、「仮想ウェアハウスのアーキテクチャ」をご参照ください。

前提条件

Hologres V2.0.4 以降のバージョンのインスタンスのみが仮想ウェアハウスをサポートします。ご利用のインスタンスのバージョンが V2.0.4 より前の場合は、アップグレード準備中の一般的なエラー をご参照いただくか、Hologres DingTalk グループに参加してサポートを受けてください。詳細については、「オンラインサポートをさらに受けるにはどうすればよいですか？」をご参照ください。

新規仮想ウェアハウスの作成

この例では、読み書き分離のために read_warehouse_1 という名前の仮想ウェアハウスを作成します。init_warehouse は書き込みを処理し、read_warehouse_1 はクエリを処理します。

データベースの作成

1. スーパーユーザーとして HoloWeb にログインし、erp_database という名前のデータベースを作成します。詳細については、「データベースの作成」をご参照ください。

   [データベースを作成] ダイアログボックスで、次のパラメーターを設定します。

   • [インスタンス]：ターゲットインスタンスを選択します。

   • [データベース名]：データベース名を入力します。例：erp_database。

   • [権限ポリシー]：[SPM] を選択します。

   • [すぐにログイン]：[はい] を選択します。データベースにログインすると、現在のデータベースで開いているすべてのページが閉じられます。作業内容を保存したことを確認してください。

   OK をクリックして作成を完了します。

2. データベースに接続し、次の SQL を実行してサンプルデータをインポートします。

   DROP FOREIGN TABLE IF EXISTS odps_customer_10g;
   DROP FOREIGN TABLE IF EXISTS odps_lineitem_10g;
   DROP FOREIGN TABLE IF EXISTS odps_nation_10g;
   DROP FOREIGN TABLE IF EXISTS odps_orders_10g;
   DROP FOREIGN TABLE IF EXISTS odps_part_10g;
   DROP FOREIGN TABLE IF EXISTS odps_partsupp_10g;
   DROP FOREIGN TABLE IF EXISTS odps_region_10g;
   DROP FOREIGN TABLE IF EXISTS odps_supplier_10g;
   
   
   IMPORT FOREIGN SCHEMA "MAXCOMPUTE_PUBLIC_DATA#default" LIMIT to
   (
       odps_customer_10g,
       odps_lineitem_10g,
       odps_nation_10g,
       odps_orders_10g,
       odps_part_10g,
       odps_partsupp_10g,
       odps_region_10g,
       odps_supplier_10g
   ) 
   FROM SERVER odps_server INTO public OPTIONS(if_table_exist'error',if_unsupported_type'error');
   
   DROP TABLE IF EXISTS LINEITEM;
   
   BEGIN;
   CREATE TABLE LINEITEM
   (
       L_ORDERKEY      BIGINT      NOT NULL,
       L_PARTKEY       INT         NOT NULL,
       L_SUPPKEY       INT         NOT NULL,
       L_LINENUMBER    INT         NOT NULL,
       L_QUANTITY      DECIMAL(15,2) NOT NULL,
       L_EXTENDEDPRICE DECIMAL(15,2) NOT NULL,
       L_DISCOUNT      DECIMAL(15,2) NOT NULL,
       L_TAX           DECIMAL(15,2) NOT NULL,
       L_RETURNFLAG    TEXT        NOT NULL,
       L_LINESTATUS    TEXT        NOT NULL,
       L_SHIPDATE      TIMESTAMPTZ NOT NULL,
       L_COMMITDATE    TIMESTAMPTZ NOT NULL,
       L_RECEIPTDATE   TIMESTAMPTZ NOT NULL,
       L_SHIPINSTRUCT  TEXT        NOT NULL,
       L_SHIPMODE      TEXT        NOT NULL,
       L_COMMENT       TEXT        NOT NULL,
       PRIMARY KEY (L_ORDERKEY,L_LINENUMBER)
   );
   CALL set_table_property('LINEITEM', 'clustering_key', 'L_SHIPDATE,L_ORDERKEY');
   CALL set_table_property('LINEITEM', 'segment_key', 'L_SHIPDATE');
   CALL set_table_property('LINEITEM', 'distribution_key', 'L_ORDERKEY');
   CALL set_table_property('LINEITEM', 'bitmap_columns', 'L_ORDERKEY,L_PARTKEY,L_SUPPKEY,L_LINENUMBER,L_RETURNFLAG,L_LINESTATUS,L_SHIPINSTRUCT,L_SHIPMODE,L_COMMENT');
   CALL set_table_property('LINEITEM', 'dictionary_encoding_columns', 'L_RETURNFLAG,L_LINESTATUS,L_SHIPINSTRUCT,L_SHIPMODE,L_COMMENT');
   CALL set_table_property('LINEITEM', 'time_to_live_in_seconds', '31536000');
   COMMIT;
   
   DROP TABLE IF EXISTS ORDERS;
   
   BEGIN;
   CREATE TABLE ORDERS
   (
       O_ORDERKEY      BIGINT      NOT NULL PRIMARY KEY,
       O_CUSTKEY       INT         NOT NULL,
       O_ORDERSTATUS   TEXT        NOT NULL,
       O_TOTALPRICE    DECIMAL(15,2) NOT NULL,
       O_ORDERDATE     timestamptz NOT NULL,
       O_ORDERPRIORITY TEXT        NOT NULL,
       O_CLERK         TEXT        NOT NULL,
       O_SHIPPRIORITY  INT         NOT NULL,
       O_COMMENT       TEXT        NOT NULL
   );
   CALL set_table_property('ORDERS', 'segment_key', 'O_ORDERDATE');
   CALL set_table_property('ORDERS', 'distribution_key', 'O_ORDERKEY');
   CALL set_table_property('ORDERS', 'bitmap_columns', 'O_ORDERKEY,O_CUSTKEY,O_ORDERSTATUS,O_ORDERPRIORITY,O_CLERK,O_SHIPPRIORITY,O_COMMENT');
   CALL set_table_property('ORDERS', 'dictionary_encoding_columns', 'O_ORDERSTATUS,O_ORDERPRIORITY,O_CLERK,O_COMMENT');
   CALL set_table_property('ORDERS', 'time_to_live_in_seconds', '31536000');
   COMMIT;
   
   DROP TABLE IF EXISTS PARTSUPP;
   
   BEGIN;
   CREATE TABLE PARTSUPP
   (
       PS_PARTKEY    INT    NOT NULL,
       PS_SUPPKEY    INT    NOT NULL,
       PS_AVAILQTY   INT    NOT NULL,
       PS_SUPPLYCOST DECIMAL(15,2) NOT NULL,
       PS_COMMENT    TEXT   NOT NULL,
       PRIMARY KEY(PS_PARTKEY,PS_SUPPKEY)
   );
   CALL set_table_property('PARTSUPP', 'distribution_key', 'PS_PARTKEY');
   CALL set_table_property('PARTSUPP', 'colocate_with', 'LINEITEM');
   CALL set_table_property('PARTSUPP', 'bitmap_columns', 'PS_PARTKEY,PS_SUPPKEY,PS_AVAILQTY,PS_COMMENT');
   CALL set_table_property('PARTSUPP', 'dictionary_encoding_columns', 'PS_COMMENT');
   CALL set_table_property('PARTSUPP', 'time_to_live_in_seconds', '31536000');
   COMMIT;
   
   DROP TABLE IF EXISTS PART;
   
   BEGIN;
   CREATE TABLE PART
   (
       P_PARTKEY     INT    NOT NULL PRIMARY KEY,
       P_NAME        TEXT   NOT NULL,
       P_MFGR        TEXT   NOT NULL,
       P_BRAND       TEXT   NOT NULL,
       P_TYPE        TEXT   NOT NULL,
       P_SIZE        INT    NOT NULL,
       P_CONTAINER   TEXT   NOT NULL,
       P_RETAILPRICE DECIMAL(15,2) NOT NULL,
       P_COMMENT     TEXT   NOT NULL
   );
   CALL set_table_property('PART', 'distribution_key', 'P_PARTKEY');
   CALL set_table_property('PART', 'bitmap_columns', 'P_PARTKEY,P_SIZE,P_NAME,P_MFGR,P_BRAND,P_TYPE,P_CONTAINER,P_COMMENT');
   CALL set_table_property('PART', 'dictionary_encoding_columns', 'P_NAME,P_MFGR,P_BRAND,P_TYPE,P_CONTAINER,P_COMMENT');
   CALL set_table_property('PART', 'time_to_live_in_seconds', '31536000');
   COMMIT;
   
   
   
   DROP TABLE IF EXISTS CUSTOMER;
   BEGIN;
   CREATE TABLE CUSTOMER
   (
       C_CUSTKEY    INT    NOT NULL PRIMARY KEY,
       C_NAME       TEXT   NOT NULL,
       C_ADDRESS    TEXT   NOT NULL,
       C_NATIONKEY  INT    NOT NULL,
       C_PHONE      TEXT   NOT NULL,
       C_ACCTBAL    DECIMAL(15,2) NOT NULL,
       C_MKTSEGMENT TEXT   NOT NULL,
       C_COMMENT    TEXT   NOT NULL
   );
   CALL set_table_property('CUSTOMER', 'distribution_key', 'C_CUSTKEY');
   CALL set_table_property('CUSTOMER', 'bitmap_columns', 'C_CUSTKEY,C_NATIONKEY,C_NAME,C_ADDRESS,C_PHONE,C_MKTSEGMENT,C_COMMENT');
   CALL set_table_property('CUSTOMER', 'dictionary_encoding_columns', 'C_NAME,C_ADDRESS,C_PHONE,C_MKTSEGMENT,C_COMMENT');
   CALL set_table_property('CUSTOMER', 'time_to_live_in_seconds', '31536000');
   COMMIT;
   
   DROP TABLE IF EXISTS SUPPLIER;
   
   BEGIN;
   CREATE TABLE SUPPLIER
   (
       S_SUPPKEY   INT    NOT NULL PRIMARY KEY,
       S_NAME      TEXT   NOT NULL,
       S_ADDRESS   TEXT   NOT NULL,
       S_NATIONKEY INT    NOT NULL,
       S_PHONE     TEXT   NOT NULL,
       S_ACCTBAL   DECIMAL(15,2) NOT NULL,
       S_COMMENT   TEXT   NOT NULL
   );
   CALL set_table_property('SUPPLIER', 'distribution_key', 'S_SUPPKEY');
   CALL set_table_property('SUPPLIER', 'bitmap_columns', 'S_SUPPKEY,S_NAME,S_ADDRESS,S_NATIONKEY,S_PHONE,S_COMMENT');
   CALL set_table_property('SUPPLIER', 'dictionary_encoding_columns', 'S_NAME,S_ADDRESS,S_PHONE,S_COMMENT');
   CALL set_table_property('SUPPLIER', 'time_to_live_in_seconds', '31536000');
   COMMIT;
   
   DROP TABLE IF EXISTS NATION;
   
   BEGIN;
   CREATE TABLE NATION(
     N_NATIONKEY INT NOT NULL PRIMARY KEY,
     N_NAME text NOT NULL,
     N_REGIONKEY INT NOT NULL,
     N_COMMENT text NOT NULL
   );
   CALL set_table_property('NATION', 'distribution_key', 'N_NATIONKEY');
   CALL set_table_property('NATION', 'bitmap_columns', 'N_NATIONKEY,N_NAME,N_REGIONKEY,N_COMMENT');
   CALL set_table_property('NATION', 'dictionary_encoding_columns', 'N_NAME,N_COMMENT');
   CALL set_table_property('NATION', 'time_to_live_in_seconds', '31536000');
   COMMIT;
   
   DROP TABLE IF EXISTS REGION;
   
   BEGIN;
   CREATE TABLE REGION
   (
       R_REGIONKEY INT  NOT NULL PRIMARY KEY,
       R_NAME      TEXT NOT NULL,
       R_COMMENT   TEXT
   );
   CALL set_table_property('REGION', 'distribution_key', 'R_REGIONKEY');
   CALL set_table_property('REGION', 'bitmap_columns', 'R_REGIONKEY,R_NAME,R_COMMENT');
   CALL set_table_property('REGION', 'dictionary_encoding_columns', 'R_NAME,R_COMMENT');
   CALL set_table_property('REGION', 'time_to_live_in_seconds', '31536000');
   COMMIT;
   
   INSERT INTO public.customer SELECT * FROM public.odps_customer_10g ;
   INSERT INTO public.lineitem SELECT * FROM public.odps_lineitem_10g ;
   INSERT INTO public.nation SELECT * FROM public.odps_nation_10g ;
   INSERT INTO public.orders SELECT * FROM public.odps_orders_10g ;
   INSERT INTO public.part SELECT * FROM public.odps_part_10g ;
   INSERT INTO public.partsupp SELECT * FROM public.odps_partsupp_10g ;
   INSERT INTO public.region SELECT * FROM public.odps_region_10g ;
   INSERT INTO public.supplier SELECT * FROM public.odps_supplier_10g ;
   
   vacuum nation;
   vacuum region;
   vacuum supplier;
   vacuum customer;
   vacuum part;
   vacuum partsupp;
   vacuum orders;
   vacuum lineitem;
   
   analyze nation;
   analyze region;
   analyze lineitem;
   analyze orders;
   analyze customer;
   analyze part;
   analyze partsupp;
   analyze supplier;
   analyze lineitem (l_orderkey,l_partkey,l_suppkey);
   analyze orders (o_custkey);
   analyze partsupp(ps_partkey,ps_suppkey);

仮想ウェアハウスの作成

1. Hologres コンソールにログインし、ターゲットインスタンスの詳細ページに移動します。

2. 左側のナビゲーションウィンドウで、計算グループ管理 をクリックして、仮想ウェアハウスリソース管理 タブを開きます。

   このページには、インスタンスの予約済みリソースとエラスティックリソースの割り当てが表示され、仮想ウェアハウスを作成するための [仮想ウェアハウスを追加] ボタンがあります。

3. 仮想ウェアハウスの新規追加 をクリックします。ダイアログボックスで、計算グループ名 を入力し、計算グループリソース を選択します。

   このシナリオでは、read_warehouse_1 という名前の仮想ウェアハウスを作成します。

   このシナリオでは、[仮想ウェアハウスリソース] に 32 CU (32 コア 128 GB、ノード数：2) を選択し、OK をクリックして作成を完了します。

4. OK をクリックします。

5. 計算グループ管理 ページで、状態 列のステータスが 現在実行中 になると、仮想ウェアハウスは正常に作成されています。

仮想ウェアハウスへのデータのロード

テーブルグループは Hologres のデータコンテナです。仮想ウェアハウスを介してデータをクエリするには、まず必要なテーブルグループをロードする必要があります。

1. 現在のデータベース内のテーブルグループを表示します。

   次の SQL ステートメントを実行します。

   SELECT tablegroup_name
   FROM hologres.hg_table_group_properties
   GROUP BY tablegroup_name;

   結果の例：クエリ結果は、テーブルグループ名が erp_database_tg_default であることを示しています。

   データベースには 1 つのテーブルグループがあります。

2. 仮想ウェアハウスにテーブルグループをロードします。

   erp_database_tg_default を read_warehouse_1 にロードして、データをクエリできるようにします。

   CALL hg_table_group_load_to_warehouse('erp_database.erp_database_tg_default', 'read_warehouse_1', 1);

3. ロードされたテーブルグループを確認します。

   SELECT * FROM hologres.hg_warehouse_table_groups;

   結果の例：

   read_warehouse_1 には erp_database_tg_default テーブルグループがロードされました。

ユーザー権限の設定

明示的な権限がないと、ユーザーは新しい仮想ウェアハウスにアクセスできません。次の例では、ram_test という名前の RAM ユーザーに read_warehouse_1 へのアクセス権を付与します。

1. ユーザーの仮想ウェアハウス権限を表示します。

   SELECT * FROM hologres.hg_warehouse_users;

2. ユーザーのデフォルトの仮想ウェアハウスを表示します。

   SELECT * FROM hologres.hg_user_default_warehouse;

3. インスタンスにユーザーを追加します。

   HoloWeb の ユーザー管理 ページで、RAM ユーザーを Hologres インスタンスに追加します。詳細については、「ユーザー管理」をご参照ください。

   追加された RAM ユーザーは [ユーザーアカウント] リストに表示され、デフォルトのロールタイプは [Normal] に設定されます。[アクション] 列の [ロールタイプを変更] オプションで権限を調整できます。

4. ram_test ユーザーに erp_database データベースに対するクエリ権限を付与します。

   HoloWeb の [データベース権限付与] ページで、ram_test ユーザーにデータベースのクエリ権限を付与します。詳細については、「RAM ユーザーへの権限付与」をご参照ください。

5. ram_test ユーザーに read_warehouse_1 仮想ウェアハウスへのアクセス権を付与します。

   CALL hg_grant_warehouse_access_privilege ('read_warehouse_1', '"p4_2xxxxxxxxxxxxxxx"');

   ユーザーに仮想ウェアハウスを使用する権限を付与する。

6. read_warehouse_1 を ram_test ユーザーのデフォルトの仮想ウェアハウスとして設定します。

   読み書き分離のため、ram_test は init_warehouse の代わりに read_warehouse_1 を介して接続する必要があります。ram_test ユーザーのデフォルトのウェアハウスを設定します。

   CALL hg_set_user_default_warehouse('"p4_2xxxxxxxxxxxxxxx"', 'read_warehouse_1');

7. 現在のアカウントが使用している仮想ウェアハウスを確認します。

   ram_test として接続した後、アクティブなウェアハウスを確認します。

   SELECT current_warehouse();

仮想ウェアハウス間のトラフィック切り替え

read_warehouse_1 に障害が発生した場合、ram_test のトラフィックを init_warehouse に切り替えます。

1. ram_test ユーザーに init_warehouse 仮想ウェアハウスへのアクセス権を付与します。

   ram_test が init_warehouse へのアクセス権をまだ持っていない場合は、ram_test に権限を付与し、ram_test が init_warehouse のリソースを使用できるようにします:

   CALL hg_grant_warehouse_access_privilege('init_warehouse', '"p4_2xxxxxxxxxxxxxxx"');

2. init_warehouse を ram_test ユーザーのデフォルトの仮想ウェアハウスとして設定します。

   ram_test のデフォルトのウェアハウスを init_warehouse に設定します。新しい接続は init_warehouse を使用します。

   CALL hg_set_user_default_warehouse('"p4_2xxxxxxxxxxxxxxx"', 'init_warehouse');

3. デフォルトの仮想ウェアハウスを使用していない接続を終了します。

   SELECT hg_kill_non_default_warehouse_connections(); 

4. 再接続後、新しい接続はデフォルトの仮想ウェアハウスを使用します。