PolarDB:pg_squeeze (表領域の再編成)

ステップ 1：クラスターパラメーターの設定

1. PolarDB コンソールにログインします。クラスター ページで、対象のクラスターを見つけてその ID をクリックします。

2. 左側のナビゲーションウィンドウで、設定と管理 > パラメーター を選択します。

3. パラメーター ページで、次のパラメーターを変更します：

   • wal_level：logical に設定します。これは論理デコーディングを使用するための前提条件であり、WAL の生成がわずかに増加します。

   • max_replication_slots：十分なスロットが利用可能であることを確認します。pg_squeeze は、有効化された各データベースで少なくとも 1 + squeeze.workers_per_database 個のレプリケーションスロットを必要とします。現在の値を少なくとも 2 増やすことを推奨します (例：10 から 12 へ)。

   • shared_preload_libraries：既存の値に ,pg_squeeze を追加します。例えば、元の値が pg_stat_statements の場合、pg_stat_statements,pg_squeeze に変更します。

4. パラメーター設定が有効になるまで、クラスターが再起動するのを待ちます。

ステップ 2：拡張機能のインストールと起動

表領域を再編成したい対象のデータベースで pg_squeeze を有効にします。

1. 対象のデータベースに接続します。

2. 次の SQL ステートメントを実行して拡張機能を作成し、スケジューラワーカーを起動します。このプロセスは、squeeze.tables の設定に基づいて定期的にコンパクションタスクをチェックし、開始します。

   -- 対象のデータベースに拡張機能を作成
   CREATE EXTENSION pg_squeeze;
   
   -- バックグラウンドスケジューラプロセスを開始
   -- この操作は、pg_squeeze を使用する各データベースで一度だけ実行する必要があります
   SELECT squeeze.start_worker();

3. (オプション) 次の SQL ステートメントを実行して、バックグラウンドプロセスが正常に開始されたことを確認します。application_name が squeeze scheduler のプロセスが表示されれば、プロセスは正常に開始されています。

   SELECT * FROM pg_stat_activity WHERE application_name LIKE 'squeeze%';

ステップ 3：処理対象テーブルの設定

pg_squeeze が管理するテーブルを指定し、それらのチェックおよびコンパクションポリシーを定義します。

1. テーブルに レプリカ ID があることを確認します：pg_squeeze は、古いテーブルと新しいテーブルの間で行の変更を照合するための一意の識別子を必要とします。プライマリキーは自動的に レプリカ ID として使用されます。

   • 確認：\d+ your_table_name コマンドを使用して、テーブルの レプリカ ID プロパティが DEFAULT または FULL であるかを確認します。

   • 設定：テーブルにプライマリキーがないが、一意なインデックス (例：your_table_uidx) がある場合、次のコマンドを実行してそれを レプリカ ID として設定できます。

     ALTER TABLE your_table_name REPLICA IDENTITY USING INDEX your_table_uidx;

2. テーブルを squeeze.tables に登録します：テーブル情報とスケジューリングポリシーを squeeze.tables 設定テーブルに挿入します。schedule フィールドは、Cron 式に似た形式でチェック時間を定義します。

   -- 例 1：毎日午前 2:30 に public.foo テーブルをチェック
   INSERT INTO squeeze.tables (tabschema, tabname, schedule)
   VALUES ('public', 'foo', ROW(ARRAY[30], ARRAY[2], NULL, NULL, NULL)::squeeze.schedule);
   
   -- 例 2：毎週日曜日の午前 4:00 に public.bar テーブルをチェックし、コンパクション後にプライマリキーでソート
   INSERT INTO squeeze.tables (tabschema, tabname, schedule, clustering_index)
   VALUES ('public', 'bar', ROW(ARRAY[0], ARRAY[4], NULL, NULL, ARRAY[0])::squeeze.schedule, 'bar_pkey');

   schedule フィールドの構造は (分, 時, 日, 月, 曜日) です。NULL は任意の値を示します。その他の設定オプションについては、「付録：squeeze.tables 設定テーブル」をご参照ください。

ステップ 4：モニタリングと検証

コンパクションタスクが期待どおりに実行されているか、成功または失敗したかを確認します。pg_squeeze が提供するビューとテーブルをクエリすることで、タスクの状態を監視できます。

-- 現在のデータベースでアクティブなコンパクションタスクを表示
SELECT * FROM squeeze.get_active_workers();

-- 最新 10 件の成功したコンパクション履歴レコードを表示
SELECT * FROM squeeze.log ORDER BY finished DESC LIMIT 10;

-- 失敗したコンパクションレコードとその原因を表示
SELECT * FROM squeeze.errors;

ステップ 5：(オプション) 定期コンパクションの無効化

特定のテーブルが定期的なコンパクションを必要としなくなった場合は、squeeze.tables テーブルから対応する行を削除するだけです。

DELETE FROM squeeze.tables WHERE tabschema = 'public' AND tabname = 'foo';

同時実行数とロック動作の調整

ビジネスワークロードに影響を与えないように、コンパクションプロセスを微調整します。squeeze.max_xlock_time パラメーターを設定することで、コンパクションの最終フェーズで排他ロックが保持される最大時間を制限し、サービスでの長時間のブロックを防ぐことができます。

-- 最大排他ロック保持時間を 100 ミリ秒に設定
SET squeeze.max_xlock_time TO 100;

ロック保持時間がこの制限を超えた場合、pg_squeeze はロックを解放し、その間に発生したデータ変更を処理してから、再度ロックの取得を試みます。繰り返しの試行がタイムアウトした場合、タスクはエラーで失敗します。ロックのタイムアウトが頻繁に発生する場合は、まずタスクをオフピーク時間帯にスケジュールしてみてください。それが不可能な場合は、このパラメーター値を増やすことを検討してください。

同時ワーカーの設定

多くのテーブルを同時に処理する必要がある場合、ワーカープロセスの数を増やしてコンパクションスループットを向上させることができます。squeeze.workers_per_database パラメーターを 1 より大きい値に設定すると、単一のデータベース内で複数のテーブルの並列コンパクションタスクが可能になります。

-- データベースごとに最大 2 つの同時コンパクションワーカープロセスを許可
SET squeeze.workers_per_database = 2;