E-MapReduce：管理工作流程

前提條件

• 已建立工作空間，詳情請參見管理工作空間。

• 已完成任務開發且任務處於發布狀態。

建立工作流程

1. 進入任務編排頁面。

   1. 登入E-MapReduce控制台。

   2. 在左側導覽列，選擇EMR Serverless > Spark。

   3. 在Spark頁面，單擊目標工作空間名稱。

   4. 在EMR Serverless Spark頁面，單擊左側導覽列中的任務編排。

2. 在任務編排頁面，單擊建立工作流程。

3. 在建立工作流程面板，填寫以下資訊，單擊下一步。

   參數		說明
   工作流程名稱		工作流程名稱在當前空間中必須保持唯一。
   資源隊列		選擇工作流程預設啟動並執行資源隊列。 說明 工作流程節點的資源隊列可以覆蓋該預設隊列。
   其他設定	調度類型	用於定義節點在生產環境的運行方式。支援以下調度類型： 手動（預設）：只能通過手動運行工作流程，觸發一次運行一次。 調度器：根據調度器規則引發工作流程運行，支援按分鐘、小時、天等定時運行。 調度類型選擇為調度器時，還需配置參數調度周期和調度開始時間。
   	調度周期	調度周期即工作流程在調度情境下自動執行的周期數，用於定義在生產環境調度系統中，多久會執行一次工作流程中的代碼邏輯。調度任務會根據調度類型及周期數產生相應的周期執行個體，通過周期執行個體的方式自動調度運行周期任務。僅當調度類型為調度器時需要設定。 支援以下調度周期： 日調度：每天在指定的定時時間運行一次。 小時調度：每天指定的時間段內，調度任務按N*1小時的時間間隔運行一次。 分鐘調度：每天指定的時間段內，調度任務按N*指定分鐘的時間間隔運行一次。
   	調度開始時間	工作流程調度開始的日期和時間。預設為目前時間。僅調度器類型需要設定。 重要 在建立調度器類型的工作流程後，需要在任務編排頁面開啟調度狀態開關，以便在指定的生效時間點觸發運行。
   	失敗重試次數	工作流程節點運行失敗後的重試次數。預設不重試。 說明 工作流程節點的配置仍可以覆蓋該參數。
   	失敗通知	工作流程運行失敗後的通知郵箱。
   	標籤	可以為工作流程設定標籤名和標籤值。

4. 編輯工作流程節點。

   1. 在編輯工作流程頁面，單擊下方的添加節點。

   2. 在彈出的添加節點面板中，配置節點相關參數。

      參數	說明
      來源檔案路徑	工作流程節點所對應的任務路徑，該路徑所對應的任務必須為發行狀態。
      節點類型	工作流程節點的類型。預設情況下，系統會根據路徑所對應的任務推測工作流程節點的類型。
      節點名稱	自訂節點的名稱。會根據任務源自動補齊名稱。
      上遊節點	工作流程節點的上遊節點。上遊節點必須是在當前工作流程中已建立的節點。 首個節點不需要設定上遊節點。
      重試次數	使用工作流程中定義的重試次數。預設不重試。
      逾時時間（秒）	工作流程節點單次啟動並執行逾時時間。預設不限制。
      狀態訂閱	可以指定郵箱來訂閱工作流程節點的指定狀態。
      標籤	工作流程節點的標籤對。預設情況下，每個工作流程節點都會自動包含workflow_name和task_name兩個內建標籤索引值對。
      資源隊列	工作流程節點運行所使用的資源隊列，預設情況下會採用工作流程定義的資源隊列，但是可以通過配置來覆蓋建立工作流程時的資源隊列。 重要 對於已經設定了資源隊列的工作流程節點，如果後續修改了工作流程所對應的資源隊列，系統仍然會以工作流程節點的配置為準。

      說明

      如果您的任務來源為SQL開發，您還需配置任務參數。任務參數預設繼承工作範本，您可以通過修改工作範本來調整預設值，參數詳情請參見管理預設配置。

   3. 單擊儲存。

      初始節點配置完成後，您可以單擊頁面下方的添加節點來添加更多節點。

5. 發布工作流程。

   1. 單擊右上方的發布工作流程。

   2. 在發布對話方塊中，可以輸入發布資訊，然後單擊確定。

運行工作流程

每運行一次工作流程，都會在工作流程詳情頁面的工作流程執行個體列表頁簽產生一個工作流程執行個體。

• 調試運行

  編輯工作流程時，您可以調試運行最新版本的工作流程。

  1. 選擇 > 編輯運行參數。

     

  2. 在編輯運行參數對話方塊中，選擇開發環境的資源隊列，然後單擊儲存。

  3. 單擊調試運行。

• 系統調度

  建立工作流程時配置了調度類型選擇了調度器，建立完成後開啟調度狀態開關，可以在指定的生效時間點觸發工作流程運行。

  

• 手動運行

  在任務編排頁面，單擊目標工作流程的名稱，然後單擊右上方的手動運行，觸發當前工作流程的運行。

  

查看運行狀態

您可以在目標工作流程的工作流程運行狀態和工作流程節點運行狀態列中，查看該工作流程啟動並執行所有工作流程執行個體和節點的運行狀態。

• 工作流程運行狀態

  狀態	說明
  藍色	運行中
  綠色	運行成功
  紅色	運行失敗
  紫色	等待中

• 工作流程節點運行狀態

  狀態	說明
  藍色	運行中
  綠色	運行成功
  紅色	運行失敗
  黃色	重試中
  紫色	等待中

相關文檔

• 任務編排相關概念，詳情請參見基本概念。

• 查看工作流程執行個體、節點執行個體等資訊，詳情請參見管理工作流程執行個體和節點執行個體。