ApsaraDB RDS:pg_cron 拡張機能の使用

スケジュールされたタスクのスケジュールで指定された時刻は、デフォルトで UTC です。必要に応じて、データベースの TIMEZONE パラメータに基づいて時刻を変換してください。スケジュールされたタスクがトリガーされない場合は、次のコマンドを実行して、毎分実行されるタスクを設定し、拡張機能が正常に動作するかどうかを確認してください。

SELECT cron.schedule('* * * * *', 'SELECT 1;');

設定したスケジュールされたタスクは、postgres という名前のデフォルトデータベースに保存されます。これらのスケジュールされたタスクは、他のデータベースからクエリできます。

従来の pg_cron 拡張機能は、PostgreSQL 10、PostgreSQL 11、または PostgreSQL 12 を実行し、20201130 より前のマイナーエンジンバージョンを使用する RDS インスタンスでサポートされています。ただし、アップグレードされたバージョンの pg_cron を使用するには、RDS インスタンスのマイナーエンジンバージョンを最新バージョンに更新することを推奨します。詳細については、「マイナーエンジンバージョンの更新」をご参照ください。マイナーエンジンバージョンの更新前に pg_cron を使用していた場合は、pg_cron を再作成して新機能を利用してください。拡張機能を再作成すると、pg_cron を使用して設定したスケジュールされたタスクは失われますのでご注意ください。

拡張機能の作成

• 拡張機能管理機能による拡張機能のインストール

  1. ApsaraDB RDS コンソールにログインし、インスタンス ページに移動します。上部のナビゲーションバーで、対象の RDS インスタンスが所在するリージョンを選択します。次に、対象の RDS インスタンスを見つけて、インスタンス ID をクリックします。

  2. 左側のナビゲーションペインで、[プラグイン] をクリックします。

  3. 表示されたページで、[拡張機能の管理] タブ、次に [未インストールの拡張機能] タブをクリックします。次に、pg_cron 拡張機能を検索し、拡張機能をインストールするデータベースを選択して、[操作] 列の [インストール] をクリックします。

  4. 表示されたダイアログボックスで、特権アカウントを選択し、[OK] をクリックして、必要なデータベースに拡張機能をインストールします。

     拡張機能のインストール中、RDS インスタンスのステータスは[インスタンスのメンテナンス中]に変更されます。 RDS インスタンスのステータスが[実行中]に変更されると、拡張機能のインストールは完了です。

• SQL ステートメントの実行による拡張機能のインストール

  1. ApsaraDB RDS コンソールで、必要なパラメーターを変更して、shared_preload_libraries パラメーターの [実行中の値] に pg_cron を追加します。 たとえば、このパラメーターの [実行中の値] を 'pg_stat_statements,auto_explain,pg_cron' に変更できます。 詳細については、「インスタンスパラメーターの設定」をご参照ください。

  2. 特権アカウントを使用して対象のデータベースに接続し、次のステートメントを実行します。

     CREATE EXTENSION pg_cron;

     説明

     SELECT * FROM pg_extension ステートメントを実行すると、インストール済みの拡張機能を表示できます。

ジョブのスケジューリング

SELECT cron.schedule('<ジョブ名>','<スケジュール>', '<アクション>');

例：

-- 毎週土曜日の午前 3:30 (UTC) に期限切れのデータを削除します。
SELECT cron.schedule('30 3 * * 6', $$DELETE FROM events WHERE event_time < now() - interval '1 week'$$);

----------

-- 毎日午前 10:00 (UTC) に VACUUM を実行します。
SELECT cron.schedule('0 10 * * *', 'VACUUM');

指定データベースでのジョブのスケジューリング

SELECT cron.schedule_in_database('<ジョブ名>', '<スケジュール>', '<アクション>', '<データベース名>');

RDS for PostgreSQL インスタンスのマイナーエンジンバージョンが 20230530 より前の場合、次のコマンドを使用してスケジュールされたタスクを実行します。 データベースを指定しない場合、タスクは cron.database_name パラメーターで指定されたデータベースで実行されます。 デフォルトでは、このデータベースは postgres です。

SELECT cron.schedule('<スケジュール>', '<アクション>', '<データベース名>')

例：

SELECT cron.schedule_in_database('weekly-vacuum', '0 4 * * 0', 'VACUUM', 'some_other_database');

設定済みジョブの表示

SELECT * FROM cron.job;