云数据库 GaussDB-创建和管理定时任务:定时任务管理

时间：2023-11-01 16:22:49

云数据库 GaussDB

定时任务管理

创建测试表：
1

openGauss=# CREATE TABLE test(id int, time date);
当结果显示为如下信息，则表示创建成功。
1

CREATE TABLE

创建自定义存储过程：

    
         openGauss=# CREATE OR REPLACE PROCEDURE PRC_JOB_1()ASN_NUM integer :=1;BEGINFOR I IN 1..1000 LOOPINSERT INTO test VALUES(I,SYSDATE);END LOOP;END;/

当结果显示为如下信息，则表示创建成功。

    
         CREATE PROCEDURE

创建任务：

新创建的任务（未指定job_id）表示每隔1分钟执行一次存储过程PRC_JOB_1。

      
           openGauss=# call dbe_task.submit('call public.prc_job_1(); ', sysdate, 'interval ''1 minute''', :a);job-----1(1 row)

指定job_id创建任务，其中job_id可用范围为1~32767。

      
           openGauss=# call dbe_task.id_submit(2,'call public.prc_job_1(); ', sysdate, 'interval ''1 minute''');isubmit---------(1 row)

通过视图查看当前用户已创建的任务信息。

    
         openGauss=# select job,dbname,start_date,last_date,this_date,next_date,broken,status,interval,failures,what from my_jobs;job | dbname |     start_date      |         last_date          |         this_date          |      next_date      | broken | status |      interval       | failures |           what-----+--------+---------------------+----------------------------+----------------------------+---------------------+--------+--------+---------------------+----------+---------------------------1 | postgres   | 2017-07-18 11:38:03 | 2017-07-18 13:53:03.607838 | 2017-07-18 13:53:03.607838 | 2017-07-18 13:54:03 | n      | s      | interval '1 minute' |        0 | call public.prc_job_1();(1 row)

停止任务。

    
         openGauss=# call dbe_task.finish(1,true);broken--------(1 row)

启动任务。

    
         openGauss=# call dbe_task.finish(1,false);broken--------(1 row)

修改任务属性：

修改JOB的Next_date参数信息。

--修改Job1的Next_date为1小时以后开始执行。

       
            openGauss=# call dbe_task.next_time(1, sysdate+1.0/24);next_date-----------(1 row)

修改JOB的Interval参数信息。

--修改Job1的Interval为每隔1小时执行一次。

       
            openGauss=# call dbe_task.interval(1,'sysdate + 1.0/24');interval----------(1 row)

修改JOB的What参数信息。

--修改Job1的What为执行SQL语句“insert into public.test values(333, sysdate+5);”。

       
            openGauss=# call dbe_task.content(1,'insert into public.test values(333, sysdate+5);');what------(1 row)

同时修改JOB的Next_date、Interval、What等多个参数信息。

      
           openGauss=# call dbe_task.update(1, 'call public.prc_job_1();', sysdate, 'interval ''1 minute''');change--------(1 row)

删除JOB。

    
         openGauss=# call dbe_task.cancel(1);remove--------(1 row)

查看JOB执行情况。
当JOB自动执行时，如果JOB执行失败（即job_status状态值为'f'）时，用户可以通过查看当前JOB所属CN的数据目录的pg_log子目录下对应时间点的运行日志来查看JOB的失败信息。
日志信息如下所示，从失败信息（detail error msg）中可以查看失败的具体错误。
```
 LOG :  Execute Job Detail:         job_id: 1         what: call public.test();          start_date: 2017-07-19 23:30:47.401818         job_status: failed         detail error msg: relation "test" does not exist         end_date: 2017-07-19 23:30:47.401818         next_run_date: 2017-07-19 23:30:56.855827 
```
JOB的权限控制：
- 当创建一个JOB时，该JOB会和创建该JOB的数据库和用户绑定（即：pg_job系统表新增的JOB记录中的dbname和log_user）。
- 如果当前用户是DBA用户、系统管理员、该JOB的创建用户（即：pg_job中的log_user），那么该用户有权限通过高级包接口remove、change、next_data、what、interval删除或修改JOB的参数信息。否则，会提示当前用户没有权限操作该JOB。
- 如果当前数据库是该JOB创建所属的数据库（即：为pg_job系统表中的dbname），那么连接到当前数据库上可以通过高级包接口cancel、update、next_data、content、interval删除或修改JOB的参数信息。
- 当删除JOB所属的数据库（即：为pg_job系统表中的dbname）时，系统会关联删除该数据库从属的JOB记录。
- 当删除JOB所属的用户（即：为pg_job系统表中的log_user）时，系统会关联删除该用户从属的JOB记录。
JOB的并发控制（当前特性是实验室特性，使用时请联系华为工程师提供技术支持）管理。
用户可以通过配置参数job_queue_processes来调整并发同时执行的JOB数目。
- 当job_queue_processes设置为0值，表示不启用定时任务功能，任何job都不会被执行。
- 当job_queue_processes为大于0时，表示启用定时任务功能且系统能够并发处理的最大任务数。
由于并行运行的任务数太多会消耗更多的系统资源，因此需要设置系统并发处理的任务数，当前并发的任务数达到job_queue_processes时，且此时又有任务到期，那么这些任务本次得不到执行而延期到下一轮询周期。因此，建议用户需要根据每个任务的执行时长合理的设置任务的时间间隔（即submit接口中的interval参数），来避免由于任务执行时间太长而导致下个轮询周期无法正常执行。
注：对于不使用JOB的集群中，用户可以通过在集群安装初始化完成后，通过设置job_queue_processes为0来关闭JOB功能，减少系统资源的消耗。