Установка и настройка pg_cron в PostgreSQL: Полное руководство

Что такое pg_cron и зачем он нужен

pg_cron — это фоновый worker для PostgreSQL, который позволяет запускать SQL-запросы по расписанию прямо из базы данных. Это как встроенный cron-демон, но с полным доступом к твоим таблицам, функциям и процедурам.

Предварительные требования для установки

Перед началом установки pg_cron убедись, что у тебя есть:

• PostgreSQL версии 9.5 или выше (рекомендуется 12+)
• Права суперпользователя (superuser) в PostgreSQL
• Доступ к командной строке сервера
• Установленные инструменты для сборки (gcc, make, postgresql-server-dev)

Пошаговая установка pg_cron в PostgreSQL

Шаг 1: Установка зависимостей

На Debian/Ubuntu системах:

sudo apt-get update
sudo apt-get install postgresql-server-dev-$(pg_config --version | grep -oP '\d+\.\d+') make gcc

На RHEL/CentOS/Fedora:

sudo yum install postgresql-server-devel make gcc

Шаг 2: Скачивание и компиляция pg_cron

Самый надежный способ — сборка из исходников:

# Скачиваем последнюю версию
wget https://github.com/citusdata/pg_cron/archive/refs/tags/v1.5.2.tar.gz

tar -xzf v1.5.2.tar.gz
cd pg_cron-1.5.2

# Компилируем расширение
make

# Устанавливаем в систему
sudo make install

Шаг 3: Настройка postgresql.conf

Добавь эти строки в конфигурационный файл PostgreSQL:

# В postgresql.conf
shared_preload_libraries = 'pg_cron'
cron.database_name = 'postgres'  # база, где будут храниться задания

# Опционально: настройка логов
cron.log_run = on
cron.log_statement = on

Шаг 4: Перезапуск PostgreSQL и создание расширения

# Перезапускаем PostgreSQL
sudo systemctl restart postgresql

# Подключаемся к базе данных
sudo -u postgres psql

-- Создаем расширение в указанной базе
CREATE EXTENSION pg_cron;

Шаг 5: Проверка установки

-- Проверяем, что расширение установлено
SELECT * FROM pg_extension WHERE extname = 'pg_cron';

-- Смотрим доступные функции
\df cron.*

Практические примеры использования pg_cron

Пример 1: Ежедневная очистка старых записей

-- Удаляем записи старше 30 дней из таблицы logs
SELECT cron.schedule(
    'clean-old-logs',
    '0 2 * * *',  -- каждый день в 2:00
    'DELETE FROM logs WHERE created_at < NOW() - INTERVAL ''30 days'';'
);

Пример 2: Еженедельная агрегация статистики

-- Создаем сводную таблицу каждое воскресенье в 3:00
SELECT cron.schedule(
    'weekly-stats-aggregation',
    '0 3 * * 0',
    $$INSERT INTO weekly_stats 
    SELECT 
        date_trunc(''week'', created_at) as week,
        COUNT(*) as total_orders,
        SUM(amount) as total_amount
    FROM orders 
    WHERE created_at >= NOW() - INTERVAL ''7 days''
    GROUP BY date_trunc(''week'', created_at)$$
);

Пример 3: Вызов хранимой процедуры каждые 5 минут

-- Вызываем процедуру обновления кэша
SELECT cron.schedule(
    'update-cache-procedure',
    '*/5 * * * *',
    'CALL update_system_cache();'
);

Управление заданиями pg_cron

-- Просмотр всех заданий
SELECT * FROM cron.job;

-- Просмотр истории выполнения
SELECT * FROM cron.job_run_details ORDER BY start_time DESC LIMIT 10;

-- Удаление задания
SELECT cron.unschedule('clean-old-logs');

-- Изменение расписания (удалить и создать заново)
SELECT cron.unschedule('weekly-stats-aggregation');
SELECT cron.schedule('weekly-stats-aggregation', '0 4 * * 0', '...');

Таблица: Сравнение pg_cron с альтернативами

Типичные проблемы и решения

FAQ: Часто задаваемые вопросы

Можно ли использовать pg_cron в облачных базах данных?

Да, но с ограничениями. Например, в Amazon RDS pg_cron доступен для PostgreSQL 12.5+ и требует включения через параметры группы. В Google Cloud SQL и Azure Database for PostgreSQL поддержка может отличаться — проверяй документацию провайдера.

Как ограничить доступ к pg_cron для обычных пользователей?

По умолчанию только суперпользователи могут управлять pg_cron. Для делегирования прав можно создать специальную роль с ограниченными привилегиями и использовать SECURITY DEFINER функции.

Что происходит с заданиями при репликации?

Задания pg_cron выполняются только на мастер-ноде. Если используешь логическую репликацию, таблица cron.job будет реплицирована, но сами задания не будут запускаться на репликах.

Можно ли запускать задания в определенной базе данных?

Да, для этого нужно создать расширение pg_cron в каждой базе, где нужны задания, и использовать полное имя таблицы: database_name.schema_name.table_name в SQL-запросе.