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

时间:2024-12-04 14:31:01

定时任务管理

  1. 创建测试表。

    1
    gaussdb=# CREATE TABLE test(id int, time date);
    

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

    1
    CREATE TABLE
    

  2. 创建自定义存储过程。

    1
    2
    3
    4
    5
    6
    7
    8
    9
    gaussdb=# CREATE OR REPLACE PROCEDURE PRC_JOB_1()
    AS
    N_NUM integer :=1;
    BEGIN
    FOR I IN 1..1000 LOOP
    INSERT INTO test VALUES(I,SYSDATE);
    END LOOP;
    END;
    /
    

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

    1
    CREATE PROCEDURE
    

  3. 创建任务。

    • 新创建的任务(未指定job_id)表示每隔1分钟执行一次存储过程PRC_JOB_1。
      1
      2
      3
      4
      5
      gaussdb=# call dbe_task.submit('call public.prc_job_1(); ', sysdate, 'interval ''1 minute''', :a);
      id
      -----
      1
      (1 row)
      
    • 指定job_id创建任务,其中job_id可用范围为1~32767。
      1
      2
      3
      4
      5
      gaussdb=# call dbe_task.id_submit(1,'call public.prc_job_1(); ', sysdate, 'interval ''1 minute''');
      id_submit
      ----------
      
      (1 row)
      

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

    1
    2
    3
    4
    5
    gaussdb=# 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 | testdb   | 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)
    

  5. 停止任务。

    1
    2
    3
    4
    5
    gaussdb=# call dbe_task.finish(1,true);
    finish
    --------
    
    (1 row)
    

  6. 启动任务。

    1
    2
    3
    4
    5
    gaussdb=# call dbe_task.finish(1,false);
    finish
    --------
    
    (1 row)
    

  7. 修改任务属性。

    • 修改JOB的next_time参数信息。
      1
      2
      3
      4
      5
      6
      --修改Job1的next_time为1小时以后开始执行。
      gaussdb=# call dbe_task.next_time(1, sysdate+1.0/24);
      next_time
      -----------
      
      (1 row)
      
    • 修改JOB的Interval参数信息。
      1
      2
      3
      4
      5
      6
      --修改Job1的Interval为每隔1小时执行一次。
      gaussdb=# call dbe_task.interval(1,'sysdate + 1.0/24');
      interval
      ----------
      
      (1 row)
      
    • 修改JOB的What参数信息。
      1
      2
      3
      4
      5
      6
      --修改Job1的What为执行SQL语句“insert into public.test values(333, sysdate+5);”。
      gaussdb=# call dbe_task.content(1,'insert into public.test values(333, sysdate+5);');
      content
      ------
      
      (1 row)
      
    • 同时修改JOB的Next_date、Interval、What等多个参数信息。
      1
      2
      3
      4
      5
      gaussdb=# call dbe_task.update(1, 'call public.prc_job_1();', sysdate, 'interval ''1 minute''');
      update
      --------
      
      (1 row)
      

  8. 删除JOB。

    1
    2
    3
    4
    5
    gaussdb=# call dbe_task.cancel(1);
    cancel
    --------
    
    (1 row)
    

  9. 查看JOB执行情况。

    当JOB自动执行时,如果JOB执行失败(即job_status状态值为'f')时,请联系管理员查看gs_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 

  10. 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记录。

  11. JOB的并发控制管理。

    用户可以通过配置GUC参数job_queue_processes调整并发同时执行的JOB数目。
    • job_queue_processes为0时,表示不启用定时任务功能,任何job都不会被执行。
    • job_queue_processes为大于0时,表示启用定时任务功能且系统能够并发处理的最大任务数。

    由于并行运行的任务数太多会消耗更多的系统资源,因此需要设置系统并发处理的任务数,当前并发的任务数达到job_queue_processes时,且此时又有任务到期,那么这些任务本次得不到执行而延期到下一轮询周期。因此,建议用户需要根据每个任务的执行时长合理的设置任务的时间间隔(即submit接口中的interval参数),来避免由于任务执行时间太长而导致下个轮询周期无法正常执行。

    注:对于不使用JOB的集群中,用户可以通过在集群安装初始化完成后,通过设置job_queue_processes为0来关闭JOB功能,减少系统资源的消耗。

support.huaweicloud.com/distributed-devg-v8-gaussdb/gaussdb-12-0040.html