mirror of
https://github.com/xbgmsharp/postgsail.git
synced 2025-09-17 11:17:46 +00:00
59 lines
2.8 KiB
SQL
59 lines
2.8 KiB
SQL
---------------------------------------------------------------------------
|
|
-- pg_cron async job
|
|
--
|
|
--CREATE DATABASE cron_database;
|
|
--CREATE SCHEMA IF NOT EXISTS cron;
|
|
--\c cron_database
|
|
\c postgres
|
|
|
|
CREATE EXTENSION IF NOT EXISTS pg_cron; -- provides a simple cron-based job scheduler for PostgreSQL
|
|
-- TRUNCATE table jobs
|
|
TRUNCATE TABLE cron.job CONTINUE IDENTITY RESTRICT;
|
|
|
|
-- Create a every 5 minutes or minute job cron_process_new_logbook_fn ??
|
|
SELECT cron.schedule('cron_new_logbook', '*/5 * * * *', 'select public.cron_process_new_logbook_fn()') ;
|
|
--UPDATE cron.job SET database = 'signalk' where jobname = 'cron_new_logbook';
|
|
|
|
-- Create a every 5 minute job cron_process_new_stay_fn
|
|
SELECT cron.schedule('cron_new_stay', '*/5 * * * *', 'select public.cron_process_new_stay_fn()');
|
|
--UPDATE cron.job SET database = 'signalk' where jobname = 'cron_new_stay';
|
|
|
|
-- Create a every 6 minute job cron_process_new_moorage_fn, delay from stay to give time to generate geo reverse location, eg: name
|
|
SELECT cron.schedule('cron_new_moorage', '*/6 * * * *', 'select public.cron_process_new_moorage_fn()');
|
|
--UPDATE cron.job SET database = 'signalk' where jobname = 'cron_new_moorage';
|
|
|
|
-- Create a every 10 minute job cron_process_monitor_offline_fn
|
|
SELECT cron.schedule('cron_monitor_offline', '*/10 * * * *', 'select public.cron_process_monitor_offline_fn()');
|
|
--UPDATE cron.job SET database = 'signalk' where jobname = 'cron_monitor_offline';
|
|
|
|
-- Create a every 10 minute job cron_process_monitor_online_fn
|
|
SELECT cron.schedule('cron_monitor_online', '*/10 * * * *', 'select public.cron_process_monitor_online_fn()');
|
|
--UPDATE cron.job SET database = 'signalk' where jobname = 'cron_monitor_online';
|
|
|
|
-- Create a every 5 minute job cron_process_new_account_fn
|
|
SELECT cron.schedule('cron_new_account', '*/5 * * * *', 'select public.cron_process_new_account_fn()');
|
|
--UPDATE cron.job SET database = 'signalk' where jobname = 'cron_new_account';
|
|
|
|
-- Create a every 5 minute job cron_process_new_vessel_fn
|
|
SELECT cron.schedule('cron_new_vessel', '*/5 * * * *', 'select public.cron_process_new_vessel_fn()');
|
|
--UPDATE cron.job SET database = 'signalk' where jobname = 'cron_new_vessel';
|
|
|
|
-- Maintenance
|
|
-- Vacuum database at “At 01:01 on Sunday.”
|
|
SELECT cron.schedule('cron_vacumm', '1 1 * * 0', 'select public.cron_vaccum_fn()');
|
|
-- Any other maintenance require?
|
|
|
|
|
|
UPDATE cron.job SET database = 'signalk';
|
|
UPDATE cron.job SET nodename = '/var/run/postgresql/'; -- VS default localhost ??
|
|
-- check job lists
|
|
SELECT * FROM cron.job;
|
|
-- unschedule by job id
|
|
--SELECT cron.unschedule(1);
|
|
-- unschedule by job name
|
|
--SELECT cron.unschedule('cron_new_logbook');
|
|
-- TRUNCATE TABLE cron.job_run_details
|
|
TRUNCATE TABLE cron.job_run_details CONTINUE IDENTITY RESTRICT;
|
|
-- check job log
|
|
select * from cron.job_run_details ORDER BY end_time DESC LIMIT 10;
|