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. 查看调用信息。

   单击API版服务的服务方式列下的调用信息，在调用信息配置面板的异步调用页签，查看服务访问地址和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目录中，查看推理结果文件。