Запланированные события (Events)

В PostgreSQL для автоматического выполнения задач используется расширение pg_cron. Это расширение позволяет планировать SQL-команды с использованием синтаксиса cron (как в Unix-системах).

Для использования запланированных задач в PostgreSQL нужно установить расширение pg_cron:

MySQL 8.1
CREATE EXTENSION IF NOT EXISTS pg_cron;

Важно: Расширение pg_cron может требовать прав суперпользователя и дополнительной настройки PostgreSQL. В облачных сервисах (AWS RDS, Azure) оно может быть уже предустановлено.

MySQL 8.1
SELECT cron.schedule(
    'cleanup_old_logs',
    '0 3 * * *',
    'DELETE FROM logs WHERE created_at < NOW() - INTERVAL ''30 days'''
);

Это событие будет выполняться каждый день в 3:00 утра и удалять записи логов старше 30 дней.

Разберём синтаксис:

• cron.schedule() — функция для создания запланированной задачи
• 'cleanup_old_logs' — имя задачи
• '0 3 * * *' — расписание в формате cron (минута час день месяц день_недели)
• Последний параметр — SQL-команда для выполнения

Формат cron расписания:

MySQL 8.1
SELECT cron.schedule(
    'update_statistics_hourly',
    '0 * * * *',
    $$
    UPDATE product_stats SET
        total_sales = (SELECT SUM(amount) FROM orders WHERE product_id = product_stats.product_id),
        last_updated = NOW()
    $$
);

Это событие будет обновлять статистику продаж каждый час (в начале каждого часа).

Примеры расписаний:

• '*/5 * * * *' — каждые 5 минут
• '0 * * * *' — каждый час (в начале часа)
• '0 0 * * *' — каждый день в полночь
• '0 0 * * 0' — каждое воскресенье в полночь
• '0 9 1 * *' — первого числа каждого месяца в 9:00

В pg_cron нет встроенной поддержки автоматического завершения задач, но можно включить проверку даты в саму команду:

MySQL 8.1
SELECT cron.schedule(
    'seasonal_discount',
    '0 0 * * *',
    $$
    UPDATE products
    SET price = price * 0.9
    WHERE category = 'seasonal'
      AND CURRENT_DATE BETWEEN '2025-12-01' AND '2025-12-31'
    $$
);

Альтернативно, можно создать задачу на удаление события в конце периода:

MySQL 8.1
SELECT cron.schedule(
    'remove_seasonal_discount',
    '0 0 1 1 *',  -- 1 января в полночь
    $$SELECT cron.unschedule('seasonal_discount')$$
);

Чтобы увидеть все запланированные задачи:

MySQL 8.1
SELECT * FROM cron.job;

Это вернёт таблицу со всеми задачами, включая их расписание и команды.

Для просмотра истории выполнения задач:

MySQL 8.1
SELECT * FROM cron.job_run_details
ORDER BY start_time DESC
LIMIT 10;

Удаление запланированной задачи:

MySQL 8.1
SELECT cron.unschedule('cleanup_old_logs');

Или по ID задачи:

MySQL 8.1
SELECT cron.unschedule(42);  -- где 42 - это jobid из таблицы cron.job

Изменение задачи:

В pg_cron нельзя изменить существующую задачу напрямую. Нужно удалить старую и создать новую:

MySQL 8.1
-- Удаляем старую
SELECT cron.unschedule('cleanup_old_logs');

-- Создаём новую с обновлённым расписанием
SELECT cron.schedule(
    'cleanup_old_logs',
    '0 */2 * * *',  -- Каждые 2 часа
    'DELETE FROM logs WHERE created_at < NOW() - INTERVAL ''30 days'''
);

1. Права доступа: Для использования pg_cron обычно требуются права суперпользователя или специальная настройка.

2. Временная зона: Задачи pg_cron выполняются по временной зоне PostgreSQL (можно проверить через SHOW timezone;).

3. Производительность: Pg_cron проверяет расписание каждую секунду, поэтому минимальная точность — 1 минута.

4. Логирование: Все выполнения задач сохраняются в таблице cron.job_run_details, что полезно для отладки.