設定作業

本節涵蓋工作的建立與組態。

關於作業

任務是簡短的功能性程式碼區塊,您可以在工作或自我提升時,將程式碼組合成流程。

任務是 Oracle AI Data Platform Workbench 中所有工作流程的主要建構區塊。任務類型決定其使用的代碼類型。在工作中,您會連線任務以決定其在工作執行時的順序和優先順序。

工作類型 描述
筆記型電腦工作 已儲存至記事本的工作,您可以存取
Python 工作 使用 Python 程式語言程式碼片段的任務
If/else 條件 使用 if/else 條件的作業
巢狀工作作業 使用現有工作及其任務作為巢狀任務的任務
Jar 作業 可執行編譯為 Java Archive (JAR) 檔案之 Scala 或 Java 程式碼的工作。

當您有多個任務時,可以建立任務相依性的集合,其中一項任務的成功或失敗可以依序觸發後續任務。您只能在具有多個作業的工作中建立相依性。請參閱建立記事本工作

任務可以彼此平行執行。您可以根據相同工作流程中另一個任務的成功或失敗,讓兩個或多個任務同時執行,以達到此目的。

作業可能會因為暫時性問題 (例如網路中斷、資源無法使用或暫時服務失敗) 而失敗。在這些情況下,AI Data Platform Workbench 會根據您在建立任務時設定的重試原則自動重試任務。您可以在下列原則中定義:

  • 重試計數:重試嘗試的次數上限。
  • 重試間隔:重試之間的等待時間。

除了標準任務重試之外,AI Data Platform Workbench 也支援逾時時重試。如果工作因資源限制或處理速度緩慢而超過其執行時間限制,而您只想針對這些案例重試,您可以選擇自動觸發重試。這些重試原則可增強工作流程韌性,確保工作有更高的成功執行機會,無須手動介入。

運算日誌的使用時機和方式

如果您的工作因資源或系統相關錯誤而失敗 (例如記憶體不足錯誤或 CPU 使用超過限制),您應該查看運算日誌。

如果您看到較長的等待時間、未預期的重試或工作效能瓶頸,請複查 Spark 日誌。這些日誌提供支援您作業之運算叢集的驅動程式和工作節點的洞察分析,並且可協助識別可能問題的來源。

如需如何檢查日誌的指引,請參閱監督特定工作執行

您必須具備適當的運算層級 RBAC 權限,才能檢視與工作關聯之運算執行處理的描述資料和日誌。如果您無法檢視運算日誌,請洽詢管理員以取得這些權限。如需更多資訊,請參閱關於權限

建立 Python 工作

您可以在使用 Python 命令檔的工作流程工作中建立工作。

  1. 在「首頁」上,按一下工作流程
  2. 按一下您要進行任務的工作。
  3. 按一下新增工作
  4. 輸入作業名稱。
  5. 若為工作類型,請選取 Python
  6. 按一下瀏覽,然後瀏覽至您要新增為作業的 Python 命令檔。按一下「選取」
  7. 選取 Python 作業的運算叢集 (如果尚未連附)。
  8. 選取工作失敗時應嘗試的重試次數。如果選取超過 0,您還必須指定工作執行在重試之間應該等待多少時間,以及是否應該在逾時時嘗試重試。

    重試次數大於或等於 1 時的作業重試選項

  9. 相依於中,選取您要讓此任務相依的任何任務。從執行條件性下拉式清單中選取該相依性的條件性回應。
  10. 藉由提供其索引鍵來新增其他參數。按一下新增參數即可提供多個參數。

建立記事本作業

您可以使用已內建於「AI 資料平台工作台」中的記事本來建立任務。

  1. 在「首頁」上,按一下工作流程
  2. 按一下您要進行任務的工作。
  3. 按一下新增工作
  4. 輸入作業名稱。
  5. 若為任務類型,請選取記事本
  6. 按一下瀏覽,然後瀏覽至您要新增為任務的記事本。按一下「選取」
  7. 選取記事本作業的運算叢集 (如果尚未連附)。
  8. 選取工作失敗時應嘗試的重試次數。如果選取超過 0,您還必須指定工作執行在重試之間應該等待多少時間,以及是否應該在逾時時嘗試重試。

    重試次數大於或等於 1 時的作業重試選項

  9. 相依於中,選取您要讓此任務相依的任何任務。從執行條件性下拉式清單中選取該相依性的條件性回應。
  10. 藉由提供其索引鍵來新增其他參數。按一下新增參數即可提供多個參數。

建立巢狀工作作業

您可以使用其他工作流程工作及其包含的工作,作為另一個工作流程中的巢狀工作。

  1. 在「首頁」上,按一下工作流程
  2. 按一下您要進行任務的工作。
  3. 按一下新增工作
  4. 輸入作業名稱。
  5. 任務類型中,選取巢狀工作任務
  6. 工作下拉式清單中,選取您要進行工作的現有工作。
  7. 選取工作失敗時應嘗試的重試次數。如果選取超過 0,您還必須指定工作執行在重試之間應該等待多少時間,以及是否應該在逾時時嘗試重試。

    重試次數大於或等於 1 時的作業重試選項

  8. 相依於中,選取您要讓此任務相依的任何任務。從執行條件性下拉式清單中選取該相依性的條件性回應。
  9. 藉由提供其索引鍵來新增其他參數。按一下新增參數即可提供多個參數。

建立 If/Else 任務

您可以建立根據目錄資料使用 if/else 條件的任務,以決定任務是否觸發。

  1. 在「首頁」上,按一下工作流程
  2. 按一下您要進行任務的工作。
  3. 按一下新增工作
  4. 輸入作業名稱。
  5. 若為任務類型,請選取若 / 否則
  6. 請輸入可決定任務是否觸發的條件。按一下 「新增」圖示 新增以設定多個條件。
  7. 輸入條件表示式。
  8. 選取工作失敗時應嘗試的重試次數。如果選取超過 0,您還必須指定工作執行在重試之間應該等待多少時間,以及是否應該在逾時時嘗試重試。

    重試次數大於或等於 1 時的作業重試選項

  9. 相依於中,選取您要讓此任務相依的任何任務。從執行條件性下拉式清單中選取該相依性的條件性回應。
  10. 藉由提供其索引鍵來新增其他參數。按一下新增參數即可提供多個參數。

建立 Jar 作業

您可以建立執行編譯至 Java Archive (JAR) 檔案之 Scala 或 Java 程式碼的作業。

附註:

相依程式庫檔案在建立時,必須使用與 Oracle AI Data Platform Workbench 叢集程式實際執行相容的 JDK、Scala 或 Spark 版本,以避免發生未預期的行為。
  1. 在「首頁」上,按一下工作流程
  2. 按一下您要進行任務的工作。
  3. 按一下新增工作
  4. 輸入作業名稱。
  5. 對於任務類型,選取 JAR 任務
  6. 對於 Main 類別名稱,指定包含您要執行之 main 方法的類別完整名稱。例如, ProcessTransaction 。這個類別必須包含在新增為相依程式庫的其中一個檔案中。
  7. 在「相依程式庫」中,按一下「新增」。
  8. 選取相依程式庫檔案的來源。至少必須包含一個包含以上指定之主要類別方法的程式庫。
    • 工作區磁碟區中,瀏覽您的「AI 資料平台工作台」工作區或磁碟區,選取您要新增為程式庫的一或多個檔案,然後按一下新增
    • 若為上傳檔案至工作區,請瀏覽您的本機機器,尋找要上傳為程式庫的一或多個檔案,然後按一下新增
  9. 命令行引數中,提供要傳送到主要類別的以空格區隔引數。
  10. 選取工作失敗時應嘗試的重試次數。如果選取超過 0,您還必須指定工作執行在重試之間應該等待多少時間,以及是否應該在逾時時嘗試重試。

    重試次數大於或等於 1 時的作業重試選項

  11. 相依於中,選取您要讓此任務相依的任何任務。從執行條件性下拉式清單中選取該相依性的條件性回應。
  12. 藉由提供其索引鍵來新增其他參數。按一下新增參數即可提供多個參數。

修改作業

您可以變更工作的現有屬性,例如名稱、類型和參數,以改變它在工作中的運作方式。

  1. 在「首頁」上,按一下工作流程
  2. 按一下您要設定任務的工作。
  3. 任務頁籤中,按一下您要編輯的任務。
  4. 在右側的任務詳細資料窗格中,視需要修改任務屬性。系統會自動儲存變更。

檢視任務日誌

您可以檢視工作中個別工作的執行日誌。

  1. 在「首頁」上,按一下工作流程
  2. 按一下工作執行
  3. 按一下您要查看其任務日誌的工作。
  4. 按一下工作節點,即可查看該工作的日誌。

刪除作業

您可以從工作移除工作節點,以刪除工作。

  1. 在「首頁」上,按一下工作流程
  2. 按一下要從中刪除任務的工作。
  3. 在任務節點上,按一下動作,然後按一下移除節點
  4. 按一下「刪除」