作业流

本文介绍作业流功能的使用场景、操作流程和关键配置,帮助用户完成日常管理与业务操作。

查询作业流

点击作业流菜单,查看租户中的作业流列表 支持作业流名称、备注搜索

20241219172017

作业流支持发布、下线、删除、编辑操作

  • 发布:作业流可配置调度时间,发布操作,可实现作业流的定时调度,同时刷新下次执行时间
  • 下线:将调度中的作业流,停止调度
  • 删除:删除作业流,包括作业流中的作业和作业配置
  • 编辑:编辑作业流的名称和备注

新建作业流

点击添加作业流按钮,添加新的作业流 注意:作业流的数量受限于许可证的作业流数和当前租户内配置的作业流数

20241220145832

  • 名称:必填,作业流的名称,租户内名称唯一
  • 备注:非必填

查询作业列表

点击作业流名称,可进入作业流的编辑页面

20240518103336

工具栏支持运行、中止、重跑、保存、配置、发布、下线、拖拽操作

  • 运行:运行作业流画布中的作业,按照拖拽的逻辑运行
  • 中止:将运行中的作业流中止
  • 重跑:重跑作业流中的作业
  • 保存:保存作业流中的作业和画布配置
  • 配置:可配置作业流的调度、基线告警、外部调用
  • 发布:发布操作,可实现作业流的定时调度,同时刷新下次执行时间
  • 下线:将调度中的作业流,停止调度
  • 拖拽:可自由的将左边列表中的作业,任意拖拽到右侧的画布中

作业流快速切换

通过作业流名称右侧的切换按钮,可快速切换开发的作业流

20241220152702

配置作业流

点击工具栏中的配置按钮,可对作业流进行配置

20241220150258

配置项说明

调度配置

配置作业流的调度时间 支持两种模式:单一调度、离散调度

  • 单一调度:仅需要对作业流进行调度时间配置,作业的调度时间以作业流配置的时间为准
  • 离散调度:需要对作业流和作业进行单独的调度配置,作业的运行以各自配置的调度时间为准

注意:离散调度模式,推荐作业流的调度时间小于作业的配置时间,先运行作业流,然后运行子作业 注意:修改调度时间后,一定要通过先下线再发布的方式,让调度配置生效

  • 高级定义:支持用户手动填写cron表达式配置调度时间,参考地址:https://cron.qqe2.com/

20241220151404

基线告警

对作业流调度过程中的事件进行通知 支持事件包括:作业流开始运行、作业流结束运行、作业流运行异常、作业流运行成功

外部调用

支持作业流通过接口的方式被第三方触发,类似以下curl调用内容 注意:作业流需要重新发布,外部调用才会生效,token当前有效期时间为1年

curl -s 'http://zhiqingyun-demo.isxcode.com/workflow/open/invokeWorkflow' \
   -H 'Content-Type: application/json;charset=UTF-8' \
   -H 'Accept: application/json, text/plain, */*' \
   --data '{"workflowId":"sy_1854732390999683072","token":"eyJhbGciOiJIUzI1NiJ9.eyJDTEFJTSI6IjFyWUxkVitHTlo0cGZINVNReURqQXI3b2QyM3A3TTNOUmpjVmcwZ3RJSXVtMmhYaElESGdjbEpGQ2hJOHJyOTg1Tnl6bk90OVgwWnFsWGY5MUp5ZUJucHE0VXd6NDEvTDNENlZlYW5aRitOdGxidkZMRUdNL0Q3N1prdHZ3dVdCV2twd0pMWS8rQXFzNS9YbU5rakNIMlRObmN6VmY0VG5jc3MrUWtlekk5WmtuRTlpUEthZGRPTDEyY0haTFVEOSIsImlhdCI6MTczNDY3ODE2NSwianRpIjoiNjRiY2QwNWMtNzFiNi00YjIwLWJjMTctOWNmNzRjMzE5NzAyIiwiZXhwIjoxNzY2MjE0MTY1fQ.VFw_L-sNOgg6_OkMR2dFbAkGUZ7-IEmalAB5MM-HXAI"}'

系统参数

用法:${ 参数 } 参数不满足需求,欢迎提issue

参数类型说明
${qing.current_date}Stringyyyy-MM-dd 2024-12-12
${qing.current_year}Stringyyyy 2024
${qing.current_month}StringMM 12
${qing.current_date1}StringyyyyMMdd 20241212

案例

select '${qing.current_date}'

系统函数

用法:#[[ 函数 ]] 支持与系统参数混合使用 函数不满足需求,欢迎提issue

函数名返回参数说明
now()Date当前时间
add_day(Date date, int days)Date当前时间加减天数
add_month(Date date, int months)Date当前时间加减月数
date_to_str(Date date, String format)String将时间转成字符串

案例

 select '#[[ date_to_str(add_day(now(),1),'YYYY-MM-dd hh:mm:ss') ]]'