ログストリームの作成

ユーザーはビジネスニーズに応じて、UNIT_GROUP（同種ゾーンモード）またはUNIT_LIST（異種ゾーンモード）上にログストリームを作成し、各サービスノード上のテナントのログストリーム数を手動で調整できます。

背景

現在のバージョンでは、同種ゾーンモードと異種ゾーンモードのテナントをサポートしています。ここで、それぞれのモードについて説明します。

• 同種ゾーンモードでは、Unit Groupを指定してログストリームを作成する必要があります。

• 異種ゾーンモードでは、UNIT_LISTを指定してログストリームを作成する必要があります。

同種ゾーンモードと異種ゾーンモードの詳細な違いについては、データ分散を参照してください。

注意事項

ログストリームの作成操作を実行する前に、以下の点にご注意ください：

• 現在は通常のユーザーログストリームのみの作成がサポートされており、ブロードキャストログストリームの作成はサポートされていません。

• ログストリームの作成操作はプライマリテナントでのみ実行できます。また、ログストリームを作成する対象テナントの STATUS と SWITCHOVER_STATUS は NORMAL でなければなりません。

• ログストリームを作成する際：

  • 同一ゾーンモードでは、ターゲット UNIT_GROUP の状態が ACTIVE である必要があり、ビュー DBA_OB_UNITS 内のターゲット UNIT_GROUP_ID の値が0であってはなりません。

  • 異種ゾーンモードでは、ターゲット UNIT_LIST の状態が ACTIVE である必要があり、指定したターゲット UNIT_LIST は空にしてはなりません。

• 作成予定のログストリームに PRIMARY_ZONE を指定する場合、指定したゾーンがテナントの ZONE_LIST に含まれていることを確認する必要があります。ログストリームの PRIMARY_ZONE の設定は、テナントの PRIMARY_ZONE の設定とは若干異なります。ログストリームではゾーンを1つのみ指定でき、例えば z1 または z2 とします。テナントのように z1,z2、z1; z2、または RANDOM といった指定はできません。

• ロードバランシング関連のパラメータは、値を False に設定し、無効の状態に保つことを推奨します。その理由は以下の通りです：

  • テナントレベルのパラメータ enable_rebalance が有効、すなわち値が True の場合、作成されたログストリームはシステムによってターゲットの UNIT_GROUP/UNIT_LIST から他の UNIT_GROUP/UNIT_LIST へ移動されます。

  • テナントレベルのパラメータ enable_transfer が有効、すなわち値が True の場合、作成されたログストリームは削除される可能性があります。

ステップ１：作成前の確認

1. 管理者ユーザーがクラスタのsysテナントまたはユーザーテナントにログインします。

   接続例は以下のとおりです。データベースへの接続時は、実際の環境に準じてください。

   obclient -h10.xx.xx.xx -P2883 -uroot@sys#obdemo -p***** -A
   

2. テナントの状態、PRIMARY_ZONE、およびローカリティに関する情報を照会します。

   ログストリームを作成する際、テナントのSTATUSとSWITCHOVER_STATUSはどちらもNORMALである必要があります。また、ログストリームのPRIMARY_ZONEを指定する場合は、指定したZoneがテナントのZONE_LISTに含まれていることを確認する必要があります。テナントのZONE_LISTは、テナントのローカリティに含まれるZoneを参照することで確認できます。

   • システムテナント

     obclient(root@sys)[oceanbase]> SELECT TENANT_ID, TENANT_NAME, STATUS, SWITCHOVER_STATUS, TENANT_ROLE, PRIMARY_ZONE, LOCALITY FROM oceanbase.DBA_OB_TENANTS WHERE tenant_name = 'mq_t1';
     

   • ユーザーテナント

     MySQLモード

     Oracleモード

     MySQLモードでは、以下のコマンドを実行してテナントの状態を確認します。

     obclient> SELECT TENANT_ID, TENANT_NAME, STATUS, SWITCHOVER_STATUS, TENANT_ROLE, PRIMARY_ZONE, LOCALITY FROM oceanbase.DBA_OB_TENANTS;
     

     Oracleモードでは、以下のコマンドを実行して、テナントの状態を確認します。

     obclient> SELECT TENANT_ID, TENANT_NAME, STATUS, SWITCHOVER_STATUS, TENANT_ROLE, PRIMARY_ZONE, LOCALITY FROM SYS.DBA_OB_TENANTS;
     

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

   +-----------+-------------+--------+-------------------+-------------+--------------+-------------------------------------+
   | TENANT_ID | TENANT_NAME | STATUS | SWITCHOVER_STATUS | TENANT_ROLE | PRIMARY_ZONE | LOCALITY                            |
   +-----------+-------------+--------+-------------------+-------------+--------------+-------------------------------------+
   |      1002 | mq_t1       | NORMAL | NORMAL            | PRIMARY     | RANDOM       | FULL{1}@z1, FULL{1}@z2, FULL{1}@z3  |
   +-----------+-------------+--------+-------------------+-------------+--------------+-------------------------------------+
   1 row in set
   

3. テナントのUnit情報を照会し、対象のUNIT_GROUP（同種ゾーンモード）/UNIT_LIST（異種ゾーンモード）の状態がACTIVEであることを確認します。

   システムテナントで以下のコマンドを実行し、テナントのUnit情報を照会します。

   obclient(root@sys)[oceanbase]> SELECT UNIT_GROUP_ID, UNIT_ID, ZONE, SVR_IP, SVR_PORT FROM oceanbase.DBA_OB_UNITS WHERE TENANT_ID=1002 AND STATUS = 'ACTIVE' ORDER BY UNIT_GROUP_ID;
   

   クエリ結果は次のとおりです：

   +---------------+---------+------+----------------+----------+
   | UNIT_GROUP_ID | UNIT_ID | ZONE | SVR_IP         | SVR_PORT |
   +---------------+---------+------+----------------+----------+
   |          1001 |    1001 | z1   | xxx.xx.xxx.198 |     2882 |
   |          1001 |    1002 | z2   | xxx.xx.xxx.196 |     2882 |
   |          1001 |    1003 | z3   | xxx.xx.xxx.204 |     2882 |
   |          1002 |    1004 | z1   | xxx.xx.xxx.194 |     2882 |
   |          1002 |    1005 | z2   | xxx.xx.xxx.192 |     2882 |
   |          1002 |    1006 | z3   | xxx.xx.xxx.197 |     2882 |
   +---------------+---------+------+----------------+----------+
   6 rows in set
   

4. 構成パラメータenable_rebalanceとenable_transferが無効な状態、つまり値がFalseであることを確認します。

   ユーザーテナントで以下のコマンドを実行し、構成パラメータの値を照会します。

   obclient> SHOW PARAMETERS LIKE '%enable_rebalance%';
   

   obclient> SHOW PARAMETERS LIKE '%enable_transfer%';
   

   値がTrueの場合は、以下のコマンドを実行して、それぞれの値をFalseに変更できます。

   obclient> ALTER SYSTEM SET enable_rebalance = False;
   

   obclient> ALTER SYSTEM SET enable_transfer = False;
   

ステップ2：ログストリームの作成

各項目のチェックが要件を満たしていることを確認した後、業務状況に応じて適切な操作を選択し、テナントのログストリームを作成します。

システムテナントがユーザーテナントのためにログストリームを作成する

1. root ユーザーでクラスタの sys テナントにログインします。

   接続例は以下のとおりです。データベースへの接続時は、実際の環境に準じてください。

   obclient -h10.xx.xx.xx -P2883 -uroot@sys#obdemo -p***** -A
   

2. ログストリームを作成します。

   システムテナントがユーザーテナントのためにログストリームを作成するSQLステートメントは以下のとおりです：

   ALTER SYSTEM CREATE LS {UNIT_GROUP [=] unit_group_id} | {UNIT_LIST [=] (unit_id_list) }[, PRIMARY_ZONE [=] 'zone_name'] TENANT [=] 'tenant_name';
   

   ステートメントの関連説明は以下のとおりです：

   • unit_group_id：作成対象のログストリームのターゲット UNIT_GROUP のIDを指定します。これは同種ゾーンモードのテナントにのみ適用されます。unit_group_id はシステムテナントで oceanbase.DBA_OB_UNITS ビューをクエリすることで取得できます。

   • unit_id_list：作成するログストリームが配置されるUnitのリストを指定します。これは異種ゾーンモードのテナントにのみ適用されます。unit_id_list はシステムテナントで oceanbase.DBA_OB_UNITS ビューをクエリすることで取得できます。各ゾーンに配置されるUnitは最大1つです。

   • zone_name：ターゲットゾーンの名前です。PRIMARY_ZONE を指定しない場合、システムがテナント内の同一 UNIT_GROUP（同種ゾーンモード）/UNIT_LIST（異種ゾーンモード）内の PRIMARY_ZONE を均等に分散するルールに基づいて割り当てます。

   • tenant_name：作成対象のログストリームのターゲットテナント名です。

   例：

   同種ゾーンモード

   異種ゾーンモード

   • IDが1001のUNIT_GROUPにログストリームを作成します。

     obclient(root@sys)[(none)]> ALTER SYSTEM CREATE LS UNIT_GROUP 1001 TENANT = mq_t1;
     

     ステートメント実行後、システムは指定されたUNIT_GROUP_IDが1001のUNIT_GROUP（対応するUnitはそれぞれ1001、1002、1003）にログストリームを作成します。

   • IDが1001のUNIT_GROUPにログストリームを作成し、そのログストリームのPRIMARY_ZONEをz1に設定します。

     obclient(root@sys)[(none)]> ALTER SYSTEM CREATE LS UNIT_GROUP 1001, PRIMARY_ZONE 'z1' TENANT = mq_t1;
     

     ステートメント実行後、システムは指定されたUNIT_GROUP_IDが1001のUNIT_GROUP（対応するUnitはそれぞれ1001、1002、1003）にログストリームを作成し、そのプライマリZoneをz1に設定します。

   • UNIT_ID がそれぞれ1001、1002、1003の UNIT_LIST に対して、ログストリームを作成します。

     obclient(root@sys)[(none)]> ALTER SYSTEM CREATE LS UNIT_LIST (1001,1002,1003) TENANT = mq_t1;
     

     ステートメント実行後、システムは指定された1001、1002、1003の UNIT_LIST にログストリームを作成します。

   • UNIT_ID がそれぞれ1001、1002、1003の UNIT_LIST に対してログストリームを作成し、そのログストリームの PRIMARY_ZONE を z1 に設定します。

     obclient(root@sys)[(none)]> ALTER SYSTEM CREATE LS UNIT_LIST (1001,1002,1003), PRIMARY_ZONE 'z1' TENANT = mq_t1;
     

     ステートメント実行後、システムは指定された1001、1002、1003の UNIT_LIST にログストリームを作成し、そのプライマリゾーンを z1 に設定します。

3. 作成されたログストリームを確認します。

   1. 新規作成されたログストリームの LS_ID を取得します。

      obclient(root@sys)[oceanbase]> SELECT * FROM oceanbase.CDB_OB_TENANT_EVENT_HISTORY WHERE EVENT='CREATE LS' AND TENANT_ID=1002 ORDER BY TIMESTAMP DESC LIMIT 1\G
      

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

      *************************** 1. row ***************************
       TENANT_ID: 1002
       TIMESTAMP: 2026-01-09 11:31:14.284278
          MODULE: LS COMMAND
           EVENT: CREATE LS
           NAME1: ARGS
          VALUE1: {op:1, op str:"CREATE LS", tenant_id:1002, ls_id:{id:-1}, unit_group_id:1001, ls_primary_zone:"z1"}
           NAME2: LS_ID
          VALUE2: 1003
           NAME3: LS_GROUP_ID
          VALUE3: 1002
           NAME4: UNIT_GROUP_ID
          VALUE4: 1001
           NAME5: PRIMARY_ZONE
          VALUE5: z1
           NAME6: NULL
          VALUE6:
      EXTRA_INFO: NULL
          SVR_IP: 6.xx.xxx.xxx
        SVR_PORT: 13324
        TRACE_ID: Y3xxxxxxxxxxx-xxxxxxxxxxxxxxx-x-x
       COST_TIME: 19407
        RET_CODE: 0
       ERROR_MSG: NULL
      1 row in set
      

      クエリ結果によると、新規作成されたログストリームの LS_ID は1003です。

   2. 新規作成されたログストリームの詳細情報を確認します。

      obclient(root@sys)[oceanbase]> SELECT LS_ID, STATUS, PRIMARY_ZONE, LS_GROUP_ID, UNIT_LIST FROM oceanbase.CDB_OB_LS WHERE TENANT_ID=1002 AND LS_ID = 1003;
      

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

      +-------+--------+--------------+-------------+----------------+
      | LS_ID | STATUS | PRIMARY_ZONE | LS_GROUP_ID | UNIT_LIST      |
      +-------+--------+--------------+-------------+----------------+
      |  1003 | NORMAL | z1;z2,z3     |        1001 | 1001,1002,1003 |
      +-------+--------+--------------+-------------+----------------+
      1 row in set
      

      クエリ結果によると、新規作成されたログストリームの状態は NORMAL、プライマリゾーンは z1 であり、1001、1002、1003 の UNIT_LIST に配置されています（同種ゾーンモードでは、UNIT_GROUP_ID が同じUnitのグループに対応）。これは期待された結果と一致し、ログストリームの作成は成功しました。

ユーザーテナントが自身のテナントにログストリームを作成する

1. MySQLテナントまたはOracleテナントのテナント管理者がデータベースに接続します。

   接続例は以下のとおりです。データベースへの接続時は、実際の環境に準じてください。

   obclient -h10.xx.xx.xx -P2883 -uroot@mq_t1#obdemo -p***** -A
   

2. ログストリームを作成します。

   ユーザーテナントがログストリームを作成するSQLステートメントは以下のとおりです：

   ALTER SYSTEM CREATE LS {UNIT_GROUP [=] unit_group_id} | {UNIT_LIST [=] (unit_id_list) }[, PRIMARY_ZONE [=] 'zone_name'];
   
   

   ステートメントの関連説明は以下のとおりです：

   • unit_group_id：作成するログストリームの対象 UNIT_GROUP のIDを指定します。これは同種ゾーンモードのテナントにのみ適用されます。unit_group_id はシステムテナントで、oceanbase.DBA_OB_UNITS ビューをクエリすることで取得できます。

   • unit_id_list：作成するログストリームが配置されるUnitのリストを指定します。これは異種ゾーンモードのテナントにのみ適用されます。unit_id_list はシステムテナントで、oceanbase.DBA_OB_UNITS ビューをクエリすることで取得できます。各ゾーンに配置されるUnitは最大1つです。

   • zone_name：対象ゾーンの名前です。PRIMARY_ZONE を指定しない場合、システムがテナント内の同一 UNIT_GROUP（同種ゾーンモード）/UNIT_LIST（異種ゾーンモード）内の PRIMARY_ZONE を均等に分散させるルールに基づいて自動的に割り当てます。

   例：

   同種ゾーンモード

   異種ゾーンモード

   • IDが1001のUNIT_GROUPにログストリームを作成します。

     obclient> ALTER SYSTEM CREATE LS UNIT_GROUP 1001;
     

     ステートメント実行後、システムは指定されたUNIT_GROUP_IDが1001（対応するUnitはそれぞれ1001、1002、1003）の上にログストリームを作成します。

   • IDが1001のUNIT_GROUPにログストリームを作成し、そのログストリームのPRIMARY_ZONEをz1に設定します。

     obclient> ALTER SYSTEM CREATE LS UNIT_GROUP 1001, PRIMARY_ZONE 'z1';
     

     ステートメント実行後、システムは指定されたUNIT_GROUP_IDが1001（対応するUnitはそれぞれ1001、1002、1003）の上にログストリームを作成し、そのプライマリゾーンをz1に設定します。

   • UNIT_ID がそれぞれ1001、1002、1003の UNIT_LIST に対して、ログストリームを作成します。

     obclient> ALTER SYSTEM CREATE LS UNIT_LIST (1001,1002,1003);
     

     ステートメント実行後、システムは指定された1001、1002、1003の UNIT_LIST にログストリームを作成します。

   • UNIT_ID がそれぞれ1001、1002、1003の UNIT_LIST に対して、ログストリームを作成するとともに、そのログストリームの PRIMARY_ZONE を z1 に設定します。

     obclient> ALTER SYSTEM CREATE LS UNIT_LIST (1001,1002,1003), PRIMARY_ZONE 'z1';
     

     ステートメント実行後、システムは指定された1001、1002、1003の UNIT_LIST にログストリームを作成し、そのプライマリゾーンを z1 に設定します。

3. 作成したログストリームを確認します。

   MySQLテナントを例に、操作は以下のとおりです。

   1. 新規作成されたログストリームの LS_ID を取得します。

      obclient> SELECT * FROM oceanbase.DBA_OB_TENANT_EVENT_HISTORY WHERE EVENT='CREATE LS' ORDER BY TIMESTAMP DESC LIMIT 1\G
      

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

      *************************** 1. row ***************************
       TENANT_ID: 1002
       TIMESTAMP: 2026-01-09 11:31:14.284278
          MODULE: LS COMMAND
           EVENT: CREATE LS
           NAME1: ARGS
          VALUE1: {op:1, op str:"CREATE LS", tenant_id:1002, ls_id:{id:-1}, unit_group_id:1001, ls_primary_zone:"z1"}
           NAME2: LS_ID
          VALUE2: 1003
           NAME3: LS_GROUP_ID
          VALUE3: 1002
           NAME4: UNIT_GROUP_ID
          VALUE4: 1001
           NAME5: PRIMARY_ZONE
          VALUE5: z1
           NAME6: NULL
          VALUE6:
      EXTRA_INFO: NULL
          SVR_IP: 6.xx.xxx.xxx
        SVR_PORT: 13324
        TRACE_ID: Y3xxxxxxxxxxx-xxxxxxxxxxxxxxx-x-x
       COST_TIME: 19407
        RET_CODE: 0
       ERROR_MSG: NULL
      1 row in set
      

      クエリ結果から、新規作成されたログストリームの LS_ID は1003であることがわかります。

   2. 新規作成されたログストリームの詳細情報を確認します。

      obclient> SELECT LS_ID, STATUS, PRIMARY_ZONE, LS_GROUP_ID, UNIT_LIST FROM oceanbase.DBA_OB_LS WHERE LS_ID = 1003;
      

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

      +-------+--------+--------------+-------------+----------------+
      | LS_ID | STATUS | PRIMARY_ZONE | LS_GROUP_ID | UNIT_LIST      |
      +-------+--------+--------------+-------------+----------------+
      |  1003 | NORMAL | z1;z2,z3     |        1001 | 1001,1002,1003 |
      +-------+--------+--------------+-------------+----------------+
      1 row in set
      

      クエリ結果から、新規作成されたログストリームの状態は NORMAL、プライマリゾーンは z1 であり、1001、1002、1003 の UNIT_LIST に分散配置されていることがわかります（同種ゾーンモードでは、UNIT_GROUP_ID が同じUnitのグループに対応）。これは期待された結果と一致し、ログストリームの作成は成功です。