Platform For AI：彈性Job服務功能介紹

服務部署

部署推理服務

類似於建立非同步推理服務，參照以下樣本內容準備服務組態檔：

{ 
  "containers": [
    {
      "image": "registry-vpc.cn-shanghai.aliyuncs.com/eas/eas-container-deploy-test:202010091755",
      "command": "/data/eas/ENV/bin/python /data/eas/app.py"
      "port": 8000,
    }
  ],
  "metadata": {
    "name": "scalablejob",
    "type": "ScalableJob",
    "rpc.worker_threads": 4,
    "instance": 1,
  }
}

其中：將type配置為ScalableJob，推理服務就會以彈性Job服務的形式部署。其他參數配置詳情，請參見服務模型所有相關參數說明。關於如何部署推理服務，請參見部署寫真相機線上推理服務。

服務部署成功後，會自動建立佇列服務和彈性Job服務，同時預設啟用Autoscaler（水平自動擴縮容）的功能。

部署訓練服務

支援整合部署與獨立部署兩種方式。具體的實現邏輯和配置詳情說明如下，具體部署方法，請參見部署Auto Scaling的Kohya訓練服務。

• 實現邏輯

  

  • 整合部署：EAS除了建立佇列服務和彈性Job服務外，還會建立一個前端服務。前端服務主要負責接收使用者請求，並將使用者請求轉寄到佇列服務中。您可以將前端服務理解成彈性Job服務的用戶端。在此模式下，彈性Job服務會被綁定到唯一的前端服務上，此時彈性Job服務只能執行當前前端服務下發的訓練任務。

  • 獨立部署：獨立部署適用於多使用者情境，在此模式下彈性Job服務作為公用的後端服務，可以和多個前端服務綁定，每個使用者都可以在自己的前端服務下發訓練任務，後端Job服務會建立對應的Job執行個體來執行訓練任務，並且每個Job執行個體可以依次執行不同的訓練任務，實現多個使用者共用訓練資源。不用多次建立訓練任務，有效降低使用成本。

• 配置說明

  在部署彈性Job服務時，您需要提供一個自訂鏡像環境（kohya情境可以直接使用EAS預置的kohya_ss鏡像）。該鏡像需包含執行訓練任務的所有依賴，只是作為訓練任務的執行環境，因此不需要配置啟動命令和連接埠號碼。如果您需要在訓練任務開始前執行一些初始化任務，可以配置初始化命令，EAS會在執行個體（Job）內部單獨建立一個進程來執行初始化任務。如何準備自訂鏡像，請參見服務部署：自訂鏡像。EAS的預置鏡像如下所示：

   "containers": [
      {
        "image": "eas-registry-vpc.cn-shanghai.cr.aliyuncs.com/pai-eas/kohya_ss:2.2"
      }
    ]

  整合部署

  參照下方樣本內容準備服務組態檔，以EAS提供的預置鏡像（kohya_ss）為例：

  {
    "containers": [
      {
        "image": "eas-registry-vpc.cn-shanghai.cr.aliyuncs.com/pai-eas/kohya_ss:2.2"
      }
    ],
    "metadata": {
      "cpu": 4,
      "enable_webservice": true,
      "gpu": 1,
      "instance": 1,
      "memory": 15000,
      "name": "kohya_job",
      "type": "ScalableJobService"
    },
    "front_end": {
      "image": "eas-registry-vpc.cn-shanghai.cr.aliyuncs.com/pai-eas/kohya_ss:2.2",
      "port": 8001,
      "script": "python -u kohya_gui.py --listen 0.0.0.0 --server_port 8001 --data-dir /workspace --headless --just-ui --job-service"
    }
  }

  其中關鍵配置說明如下，其他參數配置說明，請參見服務模型所有相關參數說明。

  • 將type配置為ScalableJobService。

  • 前端服務使用的資源群組預設和彈性Job服務相同，系統預設分配的資源為2核CPU和8 GB記憶體。

    • 參考以下樣本自訂配置資源群組或資源：

      {
          "front_end": {
            "resource": "",   # 修改前端服務使用專屬資源群組。
            "cpu": 4,
            "memory": 8000
          }
      }

    • 參考以下樣本自訂配置部署的機型：

      {
          "front_end": {
            "instance_type": "ecs.c6.large"
          }
      }

  獨立部署

  參照以下樣本準備服務組態檔，以EAS提供的預置鏡像（kohya_ss）為例：

  {
    "containers": [
      {
        "image": "eas-registry-vpc.cn-shanghai.cr.aliyuncs.com/pai-eas/kohya_ss:2.2"
      }
    ],
    "metadata": {
      "cpu": 4,
      "enable_webservice": true,
      "gpu": 1,
      "instance": 1,
      "memory": 15000,
      "name": "kohya_job",
      "type": "ScalableJob"
    }
  }

  其中type需要配置為ScalableJob，其他參數配置說明，請參見服務模型所有相關參數說明。

  在此模式下，需要使用者手動部署前端服務，並且在前端服務內部實現請求的代理，將接收到的請求轉寄到彈性Job服務的隊列內部，完成前端服務和後端Job服務的綁定，詳情請參見向佇列服務發送資料。

服務調用

為了區分訓練情境和推理情境，在調用彈性Job服務時，需要通過設定taskType：command/query來標識。其中：

• command：用來標識訓練服務。

• query：用來標識推理服務。

通過HTTP或SDK調用服務時，需要顯式指定taskType，樣本如下：

• HTTP調用時需要將taskType指定為query。

  curl http://166233998075****.cn-shanghai.pai-eas.aliyuncs.com/api/predict/scalablejob?taskType={Wanted_TaskType} -H 'Authorization: xxx' -D 'xxx'

• SDK調用時需要指定tags，通過該參數來配置taskType。

  # 建立輸入隊列，用於發送任務或請求。
  queue_client = QueueClient('166233998075****.cn-shanghai.pai-eas.aliyuncs.com', 'scalabejob')
  queue_client.set_token('xxx')
  queue_client.init()
  
  tags = {"taskType": "wanted_task_type"}
  # 向輸入隊列發送任務或請求。
  index, request_id = inputQueue.put(cmd, tags)

擷取調用結果：

• 推理服務：通過EAS佇列服務的SDK來擷取輸出隊列的結果，詳情請參見佇列服務訂閱推送。

• 訓練服務：建議部署服務時配置OSS掛載，將訓練結果直接儲存到OSS路徑中做持久化儲存，詳情請參見部署Auto Scaling的Kohya訓練服務。

配置日誌收集

EAS彈性Job服務提供了enable_write_log_to_queue配置，通過該配置擷取即時日誌。

{
  "scalable_job": {
    "enable_write_log_to_queue": true
  }
}

• 在訓練情境中，該配置預設開啟，系統會將即時日誌回寫到輸出隊列，您可以通過EAS佇列服務的SDK即時擷取訓練日誌。詳情請參見自訂前端服務鏡像調用彈性Job服務。

• 在推理情境中，該配置預設關閉，日誌只能通過stdout輸出。

相關文檔

關於EAS彈性Job服務更詳細的使用情境介紹，請參見：

• 部署Auto Scaling的Kohya訓練服務

• 部署寫真相機線上推理服務