Microservices Engine：流程管理

基本操作

1. 工作流程建立完成後，單擊操作列DAG進入工作流程編輯畫布。

2. 從左側功能表列拖拽任務至畫布，完成節點建立。

3. 將滑鼠移至上方於節點右側或下側，出現“+”表徵圖後，拖拽至另一節點的左側或上側，建立依賴關係。

4. 選中節點或連線後單擊滑鼠右鍵，可移除對應元素。

5. 通過滑鼠左鍵雙擊節點，或右鍵點擊節點後選擇編輯，可修改節點配置資訊。

6. 若節點為任務節點，右鍵點擊節點並選擇編輯指令碼，可修改該節點的指令碼內容。

7. 單擊儲存新版本並輸入版本名稱後可儲存當前工作流程的變更。

8. 指定機器：如果應用接入多個執行器，可指定任務節點啟動並執行執行器。

任務節點

邏輯節點

系統變數

自訂變數

工作流程中所有任務節點均可自訂變數，分為IN和OUT兩種類型。

• IN：作為任務節點的輸入變數，當前節點指令碼可直接使用該變數的值。

• OUT：如果下遊節點需要依賴上遊節點輸出的結果，可通過OUT類型變數進行參數傳遞。

舉例說明：

1. 在任務定義中配置如下指令碼。

   #!/bin/bash
   echo "xxl-job: hello shell"
   
   # system variables
   echo "System schedule time (yyyyMMddHHmmss): ${system.schedule.time}"
   echo "System data time (yyyyMMddHHmmss): ${system.data.time}"
   echo "System data date(yyyyMMdd): ${system.biz.curdate}"
   echo "Task Definition Name: ${system.task.definition.name}"
   echo "Task Instance ID: ${system.task.instance.id}"
   echo "Workflow Definition Name: ${system.workflow.definition.name}"
   echo "Workflow Instance ID: ${system.workflow.instance.id}"
   
   # custom variables
   echo "#{setValue(var1=hello)}"
   echo "#{setValue(var2=world)}"
   
   # custom output
   sum=0
   for ((i=1; i<=100; i++))
   do
       echo "hello world $i"
       sum=$((sum + i))
   done
   echo "#{setResult($sum)}"
   
   exit 0

2. 在自訂參數中添加兩個OUT型別參數。

   

3. 此時指令碼最終任務結果為5050，並且在執行過程中為var1和var2分別賦值為hello和world，通過步驟2的自訂參數配置，可將var1和var2作為變數向下遊傳遞，如果未設定自訂參數，var1和var2的賦值僅在此任務節點中生效。

Demo

#!/bin/bash
echo "xxl-job: hello shell"

# system variables
echo "System schedule time (yyyyMMddHHmmss): ${system.schedule.time}"
echo "System data time (yyyyMMddHHmmss): ${system.data.time}"
echo "System data date(yyyyMMdd): ${system.biz.curdate}"
echo "Task Definition Name: ${system.task.definition.name}"
echo "Task Instance ID: ${system.task.instance.id}"
echo "Workflow Definition Name: ${system.workflow.definition.name}"
echo "Workflow Instance ID: ${system.workflow.instance.id}"

# custom variables
echo "#{setValue(var1=hello)}"
echo "#{setValue(var2=world)}"

# custom output
sum=0
for ((i=1; i<=100; i++))
do
    echo "hello world $i"
    sum=$((sum + i))
done
echo "#{setResult($sum)}"

exit 0

工作流程匯出格式說明

匯出格式為JSON格式，總體結構包括工作流程類型、匯出格式、功能版本，以及匯出的工作流程列表。

其中工作流程列表中的每一項對應一個工作流程對象，工作流程對象包括工作流程的定義資訊、節點列表、邊列表。

[
  "kind": "SchedulerXWorkflows", // 類型
  "type": "JSON", // 匯出格式
  "version": "2.0", // 功能版本
  "content": [ // 工作流程列表
    {
      "workflowInfo": {}, // 定義資訊
      "nodes": [], // 節點列表
      "edges": [] // 邊列表
    },
    {...}
  ],
]

工作流程匯出結果樣本

以下圖工作流程為例，匯出具體欄位展示如下：

下圖中的Schedulerx-Root 是系統內建的唯一根節點，節點ID為0（使用者無需手動建立）

{
  "kind": "SchedulerXWorkflows",
  "type": "JSON",
  "version": "2.0",
  "content": [
    {
      "workflowInfo": {
        "appName": "qiacheng-import-test",
        "appType": 1,
        "name": "qiacheng-success",
        "description": "qiacheng-success",
        "currentExecuteStatus": 0,
        "timeConfig": {
          "calendar": "workday",
          "dataOffset": 0,
          "timezone": "Hongkong",
          "timeType": 1,
          "paramMap": {},
          "timeExpression": "0 0 12 * * ?"
        },
        "version": "v1.0",
        "maxConcurrency": 1,
        "status": 0,
        "creator": "xxxxx",
        "updater": "xxxxx"
      },
      "nodes": [
        {
          "name": "script-job1",
          "description": "script-job1",
          "jobType": "script_shell",
          "executeMode": "standalone",
          "attemptInterval": 30,
          "startTimeType": 1,
          "startTime": -1,
          "weight": 1,
          "routeStrategy": 1,
          "priority": 5,
          "contentType": 2,
          "content": "#!/bin/bash\n# system variables\necho \"System schedule time (yyyyMMddHHmmss): ${system.schedule.time}\"\necho \"System data time (yyyyMMddHHmmss): ${system.data.time}\"\necho \"System data date(yyyyMMdd): ${system.biz.curdate}\"\necho \"Task Definition Name: ${system.task.definition.name}\"\necho \"Task Instance ID: ${system.task.instance.id}\"\necho \"Workflow Definition Name: ${system.workflow.definition.name}\"\necho \"Workflow Instance ID: ${system.workflow.instance.id}\"\n\n# custom variables\necho \"#{setValue(var1=hello)}\"\necho \"#{setValue(var2=world)}\"\n\n# task process\nsum=0\nfor ((i=1; i<=100; i++))\ndo\n    echo \"hello world $i\"\n    sum=$((sum + i))\ndone\n\n# custom output result\necho \"#{setResult($sum)}\"\n\n# Returns 0 on success, otherwise returns an error code\nexit 0",
          "maxConcurrency": 1,
          "maxAttempt": 0,
          "xattrs": "{\"executorBlockStrategy\":1}",
          "parameters": "",
          "timeConfig": {
            "calendar": "",
            "dataOffset": 0,
            "paramMap": {},
            "timeType": -1,
            "timeExpression": ""
          },
          "monitorConfigInfo": {
            "endEarlyEnable": false,
            "failLimitTimes": 1,
            "failEnable": true,
            "failRate": 100,
            "timeoutKillEnable": false,
            "endEarly": 30,
            "sendChannel": "",
            "timeout": 300,
            "daysOfDeadline": 0,
            "alarmType": "CustomContacts",
            "missWorkerEnable": true,
            "timeoutEnable": true,
            "successNotice": false
          },
          "contactInfoList": [],
          "coordinate": {
            "x": -176,
            "y": 357
          },
          "dependentStrategy": 1,
          "status": 1
        },
        {
          "name": "script-job2",
          // 類似
        },
        {
          "name": "script-job3",
          // 類似
        },
        {
          "name": "script-job4",
          // 類似
        },
        {
          "name": "condition_branch",
          // 類似
        }
      ],
      "edges": [
        {
          "from": "Schedulerx-Root",
          "to": "script-job2"
        },
        {
          "from": "Schedulerx-Root",
          "to": "script-job1"
        },
        {
          "from": "script-job1",
          "to": "condition_branch"
        },
        {
          "from": "script-job2",
          "to": "condition_branch"
        },
        {
          "from": "condition_branch",
          "to": "script-job4"
        },
        {
          "from": "condition_branch",
          "to": "script-job3"
        }
      ],
      "kind": "SchedulerXWorkflows",
    }
  ]
}