postgresql pg_cron 扩展设置定时任务

postgresql pg_cron 扩展设置定时任务

原本看起来非常简单的一个扩展以及使用，最后还是遇到一个奇葩的问题，设置好定时任务之后，所有的任务执行时都提示connection failed，最后也找到相应的解决方案。

1. ### 1，编译安装
2. git clone https://github.com/citusdata/pg_cron.git
3. cd pg_cron
4. sudo make && make install
5. 会编译出来一个pg_cron.so到环境变量中设置的postgresql的home路径下
12. ### 2，创建扩展
13. 修改postgresql配置文件，增加shared_preload_libraries参数pg_cron，并重启
14. shared_preload_libraries = 'pg_stat_statements,pg_cron'        # (change requires restart)
16. sudo systemctl restart postgresql9300 (我本地服务名称为postgresql9300)
18. --查看preload_libraries
19. show shared_preload_libraries;
21. --创建扩展，请注意，pg_cron只能安装在postgres库，
22. CREATE EXTENSION pg_cron;
24. select * from pg_catalog.pg_extension where extname = 'pg_cron';
30. ### 3，创建定时任务
31. -- 1，本地任务
32. SELECT cron.schedule(
33.     cron_expression,       -- CRON 表达式，如 '*/5 * * * *'
34.     sql_command            -- 要执行的 SQL 命令（用 $$ 包裹）
35. );
37. -- 2，备注名称+本地任务
38. SELECT cron.schedule(
39.     job_name,              -- 自定义任务名称（PG 13+ 支持）
40.     cron_expression,
41.     sql_command
42. );
44. -- 3，跨库其他库的定时任务
45. SELECT cron.schedule(
46.     job_name,
47.     cron_expression,
48.     sql_command,
49.     database_name           -- 执行任务所在数据库名
50. );
56. ### 4 示例demo
58. -- 设置好权限
59. root@iZ7xv55xixens4mlf4jusqZ:/usr/local/pgsql16# chmod 700 -R /usr/local/pgsql16
60. root@iZ7xv55xixens4mlf4jusqZ:/usr/local/pgsql16# chown -R postgres:postgres /usr/local/pgsql16
62. SELECT cron.schedule_in_database('test bakcup task','*/1 * * * *',
63. ' DO $$
64. DECLARE
65.     ts TEXT;
66.     filepath TEXT;
67. BEGIN
68.     SELECT to_char(now(), ''YYYY-MM-DD_HH24MISS'') INTO ts;
69.     filepath := format(''/usr/local/pgsql16/backup/my_table_%s.csv'', ts);
71.     EXECUTE format(''COPY public.mytable01 TO %L WITH CSV HEADER'', filepath);
72. END;
73. $$; ','db01');
75. SELECT cron.schedule_in_database('VACUUM task','*/5 * * * * ','VACUUM','db01');
82. ### 5，定时任务管理
84. -- 查看任务
85. SELECT * FROM cron.job;
88. SELECT cron.pause(job_id);
90. -- 恢复任务：
91. SELECT cron.resume(job_id);
93. -- 删除任务
94. SELECT cron.unschedule(6);
96. -- 任务历史记录
97. select * from cron.job_run_details order by runid asc;
100. -- 上述定时任务的脚本没有任何问题，但是所有的执行都是失败的，失败信息为connection failed
101. -- 定时任务默认是 localhost+端口号，端口号也有了。不知道跟''有啥区别
102. -- 神奇，nodename修改成127.0.0.1也是connection failed失败，只能为空字符串
103. UPDATE cron.job SET nodename = '';
106. -- 查看历史，定时任务执行成功
107. select * from cron.job_run_details order by runid asc;
110. SELECT cron.unschedule(9);

复制代码

demo中定时任务的脚本没有任何问题，但是所有的执行都是失败的，失败信息为connection failed
定时任务cron.job表的nodename默认是 localhost，端口号字段也有了，默认创建的定时任务一直失败。
后面尝试参考这个https://dba.stackexchange.com/questions/297882/connection-failed-error-for-pg-cron-extension，修改 nodename = ''就好了，神奇，nodename修改成127.0.0.1也是connection failed失败，只能为空字符串

 

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！