Platform For AI：AI視頻產生-ComfyUI部署

線上調試

在模型線上服務（EAS）頁面，單擊目標服務操作列下的線上調試，進入線上調試頁面。

1. 發送POST請求，擷取Prompt ID。

   1. 在調試頁面的線上調試請求參數地區的Body處填寫已準備好的請求體。並在請求URL文本編輯框中添加/prompt。

   2. 單擊發送請求，即可在調試資訊地區查看返回結果，樣本如下。

2. 發送GET請求，根據Prompt ID擷取推理結果。

   1. 在線上調試請求參數地區中，將要求方法修改為GET，並在文字框中配置/history/<prompt id>，樣本如下。

      其中<prompt id>需要替換為步驟1擷取的Prompt ID。

   2. 單擊發送請求，即可擷取推理結果。

      您可以在掛載儲存的output目錄中，查看產生的推理結果。

同步調用

1. 查看調用資訊。

   1. 在推理服務頁簽，單擊目標服務名稱進入概覽頁面，在基本資料地區單擊查看調用資訊。

   2. 在調用資訊面板，可擷取訪問地址和Token。根據您的實際情況選擇公網或VPC地址，後續使用<EAS_ENDPOINT>和<EAS_TOKEN>指代這兩個值。

      

2. 發送POST請求，擷取Prompt ID。

   • HTTP請求方式：POST。

   • 請求路徑（URL）：<EAS_ENDPOINT>/prompt。其中<EAS_ENDPOINT>如地址末尾有/，請刪除。最終URL如http://comfyui****.175805416243****.cn-beijing.pai-eas.aliyuncs.com/prompt。

   • 要求標頭部（Headers）：

     頭部	值	描述
     Authorization	<EAS_TOKEN>	授權識別碼。
     Content-Type	application/json	指定請求體格式。

   程式碼範例：

   cURL

   curl --location --request POST '<EAS_ENDPOINT>/prompt' \
   --header 'Authorization: <EAS_TOKEN>' \
   --header 'Content-Type: application/json' \
   --data-raw '{
       "prompt":
       ...省略
   }'

   其中，--data-raw 為請求體。

   Python

   程式碼範例如下：

   import requests
   import json
   
   # <EAS_ENDPOINT> 和 <EAS_TOKEN> 替換為步驟1擷取的地址和token。
   service_url = "<EAS_ENDPOINT>"
   token = "<EAS_TOKEN>"
   
   if service_url[-1] == "/":
       service_url = service_url[:-1]
   
   # 請求體，將payload中的prompt的值配置為工作流程對應的JSON檔案內容。
   payload = """{
       "prompt":
       ...省略
   }"""
   payload = json.loads(payload)
   
   session = requests.session()
   session.headers.update({"Authorization": token})
     
   response = session.post(url=f'{service_url}/prompt', json=payload)
   if response.status_code != 200:
       raise Exception(response.content)
   
   data = response.json()
   print(data)

   返回結果樣本如下：

   {
       "prompt_id": "021ebc5b-e245-4e37-8bd3-00f7b949****",
       "number": 5,
       "node_errors": {}
   }

   您可以從返回結果中擷取Prompt ID。

3. 發送請求，擷取推理結果。

   • HTTP請求方式：GET

   • 請求URL：<EAS_ENDPOINT>/history/<prompt_id>，其中<prompt_id>替換為步驟1中擷取的prompt_id。

   • 要求標頭部：

     頭部	值	描述
     Authorization	<EAS_TOKEN>	授權識別碼，步驟1中擷取。

   程式碼範例：

   cURL

   curl --location --request GET '<EAS_ENDPOINT>/history/<prompt_id>' \
        --header 'Authorization: <EAS_TOKEN>'

   Python

   import requests
   
   # <EAS_ENDPOINT> 和 <EAS_TOKEN> 替換為步驟1擷取的地址和token。
   # <prompt_id>替換為步驟2中擷取的prompt_id
   service_url = "<EAS_ENDPOINT>"
   token = "<EAS_TOKEN>"
   prompt_id = "<prompt_id>"
   
   if service_url[-1] == "/":
       service_url = service_url[:-1]
   
   session = requests.session()
   session.headers.update({"Authorization": token})
   
   response = session.get(url=f'{service_url}/history/{prompt_id}')
   
   if response.status_code != 200:
       raise Exception(response.content)
   
   data = response.json()
   print(data)

   返回結果樣本如下：

   單擊查看返回結果樣本

   {
       "130bcd6b-5bb5-496c-9c8c-3a1359a0****": {
           "prompt": ...省略,
           "outputs": {
               "9": {
                   "images": [
                       {
                           "filename": "ComfyUI_1712645398_18dba34d-df87-4735-a577-c63d5506a6a1_.png",
                           "subfolder": "",
                           "type": "output"
                       }
                   ]
               },
               "15": {
                   "images": [
                       {
                           "filename": "ComfyUI_1712645867_.webp",
                           "subfolder": "",
                           "type": "output"
                       }
                   ],
                   "animated": [
                       true
                   ]
               },
               "19": {
                   "gifs": [
                       {
                           "filename": "comfyUI_00002.mp4",
                           "subfolder": "",
                           "type": "output",
                           "format": "video/h264-mp4"
                       }
                   ]
               }
           },
           "status": {
               "status_str": "success",
               "completed": true,
               "messages": ...省略,
           }
       }
   }
   

   在本樣本返回的outputs中提供了prompt產生的映像、webp檔案和mp4視頻，您可以在掛載儲存的output目錄中，根據檔案名稱來尋找這些檔案。

非同步呼叫

1. 查看調用資訊。

   在推理服務頁簽，單擊目標服務名稱進入概覽頁面，在基本資料地區單擊查看調用資訊。在調用資訊對話方塊的非同步呼叫頁簽，查看服務訪問地址和Token。

   

   下文使用<EAS_ENDPOINT>指代公網輸入調用地址（如果調用端與EAS處於同一VPC，可使用VPC輸入調用地址），<EAS_TOKEN>指代Token。

2. 推送請求。

   程式碼範例如下：

   import requests,io,base64
   from PIL import Image, PngImagePlugin
   import json
   
   service_url = "<EAS_ENDPOINT>"
   token = "<EAS_TOKEN>"
   
   if service_url[-1] == "/":
       service_url = service_url[:-1]
   
   session = requests.session()
   session.headers.update({"Authorization":token})
   
   # 請求體，工作流程JSON檔案內容。使用 """ """ 將其定義為多行字串，否則需要將工作流程JSON中布爾值（true和false）的首字母改為大寫。
   payload = """{
       '3': 
       ...省略
     }
     """
   payload = json.loads(payload)
   
   for i in range(5):
     # task_id是標識請求和結果的關鍵標誌，請給每個請求分配一個唯一的值，以對應後面的隊列結果
     response = session.post(url=f'{service_url}/api_prompt?task_id=txt2img_{i}', json=payload)
     if response.status_code != 200:
       exit(f"send request error:{response.content}")
     else:
       print(f"send {i} success, index is {response.content}")

3. 訂閱結果。

   1. 執行以下命令安裝eas_prediction SDK。

      pip install eas_prediction  --user

   2. 執行以下代碼，擷取返回結果。

      from eas_prediction import QueueClient
      from urllib.parse import urlparse, urlunparse
      
      service_url     = "<EAS_ENDPOINT>"
      token           = "<EAS_TOKEN>"
      
      def parse_service_url(service_url):
          parsed = urlparse(service_url)
          service_domain = f"{parsed.scheme}://{parsed.netloc}"
          path_parts = [p for p in parsed.path.strip('/').split('/') if p]
          service_name = path_parts[-1]
          return service_domain, service_name
      
      service_domain, service_name = parse_service_url(service_url)
      print(f"service_domain: {service_domain}, service_name: {service_name}.")
          
      sink_queue = QueueClient(service_domain, f'{service_name}/sink')
      sink_queue.set_token(token)
      sink_queue.init()
      
      watcher = sink_queue.watch(0, 5, auto_commit=False)
      for x in watcher.run():
          if 'task_id' in x.tags:
              print('index {} task_id is {}'.format(x.index, x.tags['task_id']))
          print(f'index {x.index} data is {x.data}')
          sink_queue.commit(x.index)

      返回結果樣本如下：

      index 42 task_id is txt2img_0
      index 42 data is b'[{"type": "executed", "data": {"node": "9", "output": {"images": [{"filename": "ComfyUI_1712647318_8e7f3c93-d2a8-4377-92d5-8eb552adc172_.png", "subfolder": "", "type": "output"}]}, "prompt_id": "c3c983b6-f92b-4dd5-b4dc-442db4d1736f"}}, {"type": "executed", "data": {"node": "15", "output": {"images": [{"filename": "ComfyUI_1712647895_.webp", "subfolder": "", "type": "output"}], "animated": [true]}, "prompt_id": "c3c983b6-f92b-4dd5-b4dc-442db4d1736f"}}, {"type": "executed", "data": {"node": "19", "output": {"gifs": [{"filename": "comfyUI_00001.mp4", "subfolder": "", "type": "output", "format": "video/h264-mp4"}]}, "prompt_id": "c3c983b6-f92b-4dd5-b4dc-442db4d1736f"}}, {"9": {"images": [{"filename": "ComfyUI_1712647318_8e7f3c93-d2a8-4377-92d5-8eb552adc172_.png", "subfolder": "", "type": "output"}]}, "15": {"images": [{"filename": "ComfyUI_1712647895_.webp", "subfolder": "", "type": "output"}], "animated": [true]}, "19": {"gifs": [{"filename": "comfyUI_00001.mp4", "subfolder": "", "type": "output", "format": "video/h264-mp4"}]}}]'
      index 43 task_id is txt2img_1
      index 43 data is b'[{"9": {"images": [{"filename": "ComfyUI_1712647318_8e7f3c93-d2a8-4377-92d5-8eb552adc172_.png", "subfolder": "", "type": "output"}]}, "15": {"images": [{"filename": "ComfyUI_1712647895_.webp", "subfolder": "", "type": "output"}], "animated": [true]}, "19": {"gifs": [{"filename": "comfyUI_00001.mp4", "subfolder": "", "type": "output", "format": "video/h264-mp4"}]}}]'
      index 44 task_id is txt2img_2
      index 44 data is b'[{"9": {"images": [{"filename": "ComfyUI_1712647318_8e7f3c93-d2a8-4377-92d5-8eb552adc172_.png", "subfolder": "", "type": "output"}]}, "15": {"images": [{"filename": "ComfyUI_1712647895_.webp", "subfolder": "", "type": "output"}], "animated": [true]}, "19": {"gifs": [{"filename": "comfyUI_00001.mp4", "subfolder": "", "type": "output", "format": "video/h264-mp4"}]}}]'
      index 45 task_id is txt2img_3
      index 45 data is b'[{"9": {"images": [{"filename": "ComfyUI_1712647318_8e7f3c93-d2a8-4377-92d5-8eb552adc172_.png", "subfolder": "", "type": "output"}]}, "15": {"images": [{"filename": "ComfyUI_1712647895_.webp", "subfolder": "", "type": "output"}], "animated": [true]}, "19": {"gifs": [{"filename": "comfyUI_00001.mp4", "subfolder": "", "type": "output", "format": "video/h264-mp4"}]}}]'
      index 46 task_id is txt2img_4
      index 46 data is b'[{"9": {"images": [{"filename": "ComfyUI_1712647318_8e7f3c93-d2a8-4377-92d5-8eb552adc172_.png", "subfolder": "", "type": "output"}]}, "15": {"images": [{"filename": "ComfyUI_1712647895_.webp", "subfolder": "", "type": "output"}], "animated": [true]}, "19": {"gifs": [{"filename": "comfyUI_00001.mp4", "subfolder": "", "type": "output", "format": "video/h264-mp4"}]}}]'

      您可以在掛載儲存的output目錄中，查看推理結果檔案。