ApsaraDB RDS:スケジュールされたタスク (pg_cron)

デフォルトでは、スケジュールされたタスクは協定世界時 (UTC) で実行されます。タスクを設定する際は、データベースの `TIMEZONE` パラメーターに基づいて時間を変換する必要があります。スケジュールされたタスクが期待どおりにトリガーされない場合は、毎分実行されるタスクを設定して、拡張機能の可用性を確認できます。例：

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

スケジュールされたタスクは、デフォルトの `postgres` データベースに保存されます。ただし、他のデータベースからスケジュールされたタスクをクエリすることは可能です。

pg_cron 拡張機能は、マイナーエンジンバージョンが 20201130 より前の ApsaraDB RDS for PostgreSQL 10、11、または 12 を実行しているインスタンスでサポートされています。ただし、拡張機能はアップグレードされています。マイナーエンジンバージョンを最新バージョンにアップグレードすることを推奨します。アップグレード前に pg_cron を使用していた場合、新しい機能を使用するには拡張機能を再作成する必要があります。注意：拡張機能を再作成すると、既存のスケジュールされたタスクは削除されます。

拡張機能の作成

• コンソールからの拡張機能のインストール

  1. インスタンスページに移動します。上部のナビゲーションバーで、インスタンスが配置されているリージョンを選択します。次に、インスタンスを見つけてその ID をクリックします。

  2. 左側のナビゲーションウィンドウで、[拡張機能の管理] をクリックします。

  3. [拡張機能の管理] > [アンインストール済みの拡張機能] ページで、pg_cron 拡張機能を見つけます。拡張機能をインストールするデータベースを選択し、[インストール] をクリックします。

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

     インストール中、インスタンスのステータスは [インスタンスのメンテナンス中] に変わります。ステータスが [実行中] に変わると、拡張機能は正常にインストールされています。

• SQL コマンドを使用した拡張機能のインストール

  1. インスタンスパラメーターを設定します。shared_preload_libraries パラメーターの [実行中のパラメーター値] に pg_cron を追加します。たとえば、[実行中のパラメーター値] を 'pg_stat_statements, auto_explain, pg_cron' に変更します。

  2. 特権アカウントを使用してターゲットデータベースに接続し、次の SQL 文を実行します。

     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('<タスク名>', '<スケジュール>', '<アクション>', '<データベース>');

ご利用の ApsaraDB 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;