如何通过Crontab实现PostgreSQL函数的秒级调度？

Crontab和PostgreSQL自带的定时工具（如pg_cron）默认只支持分钟级调度，要实现秒级执行，可采用以下几种替代方案：

方案一：Crontab + 循环Shell脚本 #

利用Crontab每分钟启动一次脚本，脚本内部循环调用PostgreSQL函数，通过sleep控制秒级间隔。

1. 编写Shell脚本（比如run_pg_func.sh）：

#!/bin/bash
# 执行间隔（秒），按需修改
INTERVAL=5
# 脚本持续执行60秒，刚好匹配Crontab的一分钟间隔，避免重复启动
END_TIME=$((SECONDS + 60))

while [ $SECONDS -lt $END_TIME ]; do
  # 替换为你的数据库账号、库名和目标函数
  psql -U your_db_user -d your_database -c "SELECT your_target_function();"
  sleep $INTERVAL
done

2. 给脚本添加执行权限：

chmod +x /path/to/run_pg_func.sh

3. 配置Crontab：
   执行crontab -e添加以下内容，让脚本每分钟启动一次：

* * * * * /path/to/run_pg_func.sh >> /var/log/pg_task.log 2>&1

方案二：PostgreSQL内部后台循环 #

无需依赖系统定时工具，直接在PostgreSQL内部启动后台循环任务，通过pg_sleep控制秒级间隔。

1. 创建循环执行的函数：

CREATE OR REPLACE FUNCTION run_seconds_task()
RETURNS void AS $$
BEGIN
  LOOP
    -- 调用你的目标函数
    PERFORM your_target_function();
    -- 间隔5秒，按需修改
    PERFORM pg_sleep(5);
    -- 可选：添加停止条件，比如通过控制表标记终止循环
    IF EXISTS (SELECT 1 FROM task_control WHERE stop_flag = true) THEN
      EXIT;
    END IF;
  END LOOP;
END;
$$ LANGUAGE plpgsql;

2. 启动后台进程（避免阻塞当前会话）：

• 若安装了pg_background扩展：

SELECT pg_background_launch('SELECT run_seconds_task();');

• 若使用dblink扩展（需先执行CREATE EXTENSION dblink;）：

SELECT dblink_connect('dbname=your_database user=your_db_user');
SELECT dblink_send_query('SELECT run_seconds_task();');

注意：数据库重启后需重新启动该任务，可配合数据库启动脚本自动触发。

方案三：Systemd定时器（推荐Linux系统） #

Systemd原生支持秒级调度，比Crontab更灵活，适合长期运行的任务。

1. 创建服务文件/etc/systemd/system/pg_func.service：

[Unit]
Description=Execute PostgreSQL function periodically

[Service]
Type=oneshot
# 替换为你的数据库信息和函数
ExecStart=/usr/bin/psql -U your_db_user -d your_database -c "SELECT your_target_function();"

2. 创建定时器文件/etc/systemd/system/pg_func.timer：

[Unit]
Description=Timer for PostgreSQL seconds task

[Timer]
# 系统启动后立即执行一次
OnBootSec=0
# 每5秒执行一次，按需修改
OnUnitActiveSec=5
# 持久化配置，确保重启后继续执行
Persistent=true

[Install]
WantedBy=timers.target

3. 启用并启动定时器：

systemctl daemon-reload
systemctl enable --now pg_func.timer

可通过systemctl list-timers查看定时器状态，journalctl -u pg_func.service查看执行日志。

内容的提问来源于stack exchange，提问作者Prachita Raut