文档首页/ 数据智能平台 DataArts Platform/ API参考/ 应用示例/ 异步运行工作流并流式获取运行事件消息
更新时间：2026-10-29 GMT+08:00
查看PDF
分享

异步运行工作流并流式获取运行事件消息

操作场景

本章节指导用户通过调用API异步运行工作流，然后流式获取应用运行的事件消息并查询运行状态。

前提条件

  • 已开通数据智能平台（DataArts Platform）并加入工作空间并具有相应的权限，并根据开通区域确定调用API的Endpoint，详细信息请参见地区与终端节点。
  • 当您使用IAM认证方式完成认证鉴权时，需要获取用户AK/SK，然后使用AK/SK进行签名认证，具体操作请参考认证鉴权。
  • 已在应用开发里开发完成工作流，并已经生产部署。

涉及接口

异步运行及获取运行事件消息和状态涉及以下接口：

操作步骤

  1. 异步运行应用。

    1. 接口相关信息。

      URI格式：POST /v1/{project_id}/applications/{application_id}/submit

      详情请参见异步运行应用。

    2. 请求示例。 
      POST https://{Endpoint}/v1/ddaac8e6a4334e6998b7e1e424c0ff82/applications/f9eed8ea-acb6-401a-b33a-19e6bee21659/submit
{
    "query": "翻译“我们居住在地球村”",
    "response_mode": "streaming"
}
    3. 响应示例。 
      {
    "session_id": "b90e7bcd-5f5c-430a-b36b-1c9465f8c700",
    "run_id": "bdd745f4-03b6-42f4-873d-67fe48a75227",
    "application_id": "f9eed8ea-acb6-401a-b33a-19e6bee21659",
    "message_id": "bdd745f4-03b6-42f4-873d-67fe48a75227",
    "version": "1.0"
}

  2. 流式获取应用异步运行的事件消息。

    1. 接口相关信息。

      URI格式：GET /v1/{project_id}/applications/{application_id}/runs/{run_id}/events

      详情请参见流式获取应用异步运行的事件消息。

    2. 请求示例。 
      GET https://{Endpoint}/v1/096aaaa59ce841f8b4cc2c1305c1d084/applications/f9eed8ea-acb6-401a-b33a-19e6bee21659/runs/bdd745f4-03b6-42f4-873d-67fe48a75227/events
    3. 响应示例。 
      data: {"message_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "run_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "is_finished": false, "role": "user", "event": "message", "session_id": "b90e7bcd-5f5c-430a-b36b-1c9465f8c700", "type": "text", "is_answer": false, "content": "翻译“我们居住在地球村”"}

data: {"message_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "run_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "is_finished": false, "role": "assistant", "version": "0.0", "event": "workflow_started", "session_id": "b90e7bcd-5f5c-430a-b36b-1c9465f8c700", "data": {"inputs": {"sys.query": "翻译“我们居住在地球村”"}, "create_date": "2026-10-08T10:46:25Z"}}

data: {"message_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "run_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "is_finished": false, "role": "assistant", "node_run_id": "126852eb-4419-47d5-bc19-67680eb28e12", "event": "node_started", "session_id": "b90e7bcd-5f5c-430a-b36b-1c9465f8c700", "data": {"node_id": "cc51ed85-9d8a-4bba-8c9a-3eb8119bbfea", "node_type": "START", "node_name": "开始", "seq_id": 1, "inputs": {"sys.query": "翻译“我们居住在地球村”", "sys.files": null}, "create_date": "2026-10-08T10:46:25Z"}}

data: {"message_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "run_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "is_finished": false, "role": "assistant", "node_run_id": "126852eb-4419-47d5-bc19-67680eb28e12", "event": "node_finished", "session_id": "b90e7bcd-5f5c-430a-b36b-1c9465f8c700", "data": {"node_id": "cc51ed85-9d8a-4bba-8c9a-3eb8119bbfea", "node_type": "START", "node_name": "开始", "seq_id": 1, "outputs": {"sys.query": "翻译“我们居住在地球村”", "sys.files": null}, "status": "succeeded", "elapsed_time": 0.002, "create_date": "2026-10-08T10:46:25Z", "finish_date": "2026-10-08T10:46:25Z"}}

data: {"message_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "run_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "is_finished": false, "role": "assistant", "node_run_id": "d20a3a6e-335b-46fc-8016-81b121fd6875", "event": "node_started", "session_id": "b90e7bcd-5f5c-430a-b36b-1c9465f8c700", "data": {"node_id": "c8f3bda1-26cf-483f-98bb-ac66bf9afe7c", "node_type": "AGENT", "node_name": "智能体", "seq_id": 2, "inputs": {"input": "翻译“我们居住在地球村”", "files": null}, "create_date": "2026-10-08T10:46:26Z"}}

data: {"message_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "run_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "is_finished": false, "role": "assistant", "node_run_id": "40cc22e4-186c-4e2a-8428-c7bcddd1e4a5", "node_parent_run_id": "d20a3a6e-335b-46fc-8016-81b121fd6875", "event": "llm_started", "session_id": "b90e7bcd-5f5c-430a-b36b-1c9465f8c700", "data": {"node_id": "8a818250a04c370f01a04c683dcf000f", "node_type": "LLM", "node_name": "deepseek-v4-flash", "seq_id": 3, "inputs": {"messages": [{"content": "你是一个中英翻译助手", "role": "system"}, {"content": "翻译“我们居住在地球村”", "role": "user"}], "model": "deepseek-v4-flash", "temperature": 0.5, "tools": null}, "create_date": "2026-10-08T10:46:26Z", "metadata": {"inter_msg": true}}}

data: ping

data: ping

data: {"message_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "run_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "is_finished": false, "role": "assistant", "node_run_id": "40cc22e4-186c-4e2a-8428-c7bcddd1e4a5", "node_parent_run_id": "d20a3a6e-335b-46fc-8016-81b121fd6875", "event": "llm_finished", "session_id": "b90e7bcd-5f5c-430a-b36b-1c9465f8c700", "data": {"node_id": "8a818250a04c370f01a04c683dcf000f", "node_type": "LLM", "node_name": "deepseek-v4-flash", "seq_id": 3, "outputs": {"content": "We live in the global village.", "usage": {"input_tokens": 57, "output_tokens": 106, "total_tokens": 163, "reasoning_tokens": 97}}, "status": "succeeded", "elapsed_time": 2.361, "create_date": "2026-10-08T10:46:26Z", "finish_date": "2026-10-08T10:46:28Z", "metadata": {"inter_msg": true}}}

data: {"message_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "run_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "is_finished": false, "role": "assistant", "node_run_id": "d20a3a6e-335b-46fc-8016-81b121fd6875", "event": "node_finished", "session_id": "b90e7bcd-5f5c-430a-b36b-1c9465f8c700", "data": {"node_id": "c8f3bda1-26cf-483f-98bb-ac66bf9afe7c", "node_type": "AGENT", "node_name": "智能体", "seq_id": 2, "outputs": {"output": "We live in the global village."}, "status": "succeeded", "elapsed_time": 2.43, "create_date": "2026-10-08T10:46:25Z", "finish_date": "2026-10-08T10:46:28Z", "metadata": {"usage": {"input_tokens": 57, "output_tokens": 106, "total_tokens": 163, "cached_tokens": 0, "reasoning_tokens": 97}}}}

data: {"message_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "run_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "is_finished": false, "role": "assistant", "node_run_id": "3564f438-a783-4ca5-94a6-5b9d81105e72", "event": "node_started", "session_id": "b90e7bcd-5f5c-430a-b36b-1c9465f8c700", "data": {"node_id": "93f1898e-fef7-44a3-878d-6ab3e58ca37e", "node_type": "END", "node_name": "结束", "seq_id": 4, "inputs": {"output": "We live in the global village."}, "create_date": "2026-10-08T10:46:29Z"}}

data: {"message_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "run_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "is_finished": true, "role": "assistant", "event": "message", "session_id": "b90e7bcd-5f5c-430a-b36b-1c9465f8c700", "type": "text", "is_answer": true, "content": "{\"output\": \"We live in the global village.\"}"}

data: {"message_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "run_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "is_finished": true, "role": "assistant", "node_run_id": "3564f438-a783-4ca5-94a6-5b9d81105e72", "event": "node_finished", "session_id": "b90e7bcd-5f5c-430a-b36b-1c9465f8c700", "data": {"node_id": "93f1898e-fef7-44a3-878d-6ab3e58ca37e", "node_type": "END", "node_name": "结束", "seq_id": 4, "outputs": {"output": "We live in the global village."}, "status": "succeeded", "elapsed_time": 0.002, "create_date": "2026-10-08T10:46:25Z", "finish_date": "2026-10-08T10:46:29Z"}}

data: {"message_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "run_id": "bdd745f4-03b6-42f4-873d-67fe48a75227", "is_finished": true, "role": "assistant", "version": "0.0", "event": "workflow_finished", "session_id": "b90e7bcd-5f5c-430a-b36b-1c9465f8c700", "data": {"status": "succeeded", "outputs": {"output": "We live in the global village."}, "elapsed_time": 2.721, "total_steps": 4, "create_user": "z00563731", "create_date": "2026-10-08T10:46:25Z", "finish_date": "2026-10-08T10:46:29Z", "metadata": {"usage": {"input_tokens": 57, "output_tokens": 106, "total_tokens": 163, "cached_tokens": 0, "reasoning_tokens": 97}}}}

      请求异常时，请参见错误码。

  3. 获取应用运行状态。

    1. 接口相关信息。

      URI格式：GET /v1/{project_id}/applications/{application_id}/runs/{run_id}/status

      详情请参见获取异步应用运行的状态。

    2. 请求示例。 
      GET https://{Endpoint}/v1/096aaaa59ce841f8b4cc2c1305c1d084/applications/f9eed8ea-acb6-401a-b33a-19e6bee21659/runs/bdd745f4-03b6-42f4-873d-67fe48a75227/status
    3. 响应示例。 
      {
    "workspace_id": "ff8080817d30ff7b017d3213ba600001",
    "session_id": "b90e7bcd-5f5c-430a-b36b-1c9465f8c700",
    "run_id": "bdd745f4-03b6-42f4-873d-67fe48a75227",
    "application_id": "f9eed8ea-acb6-401a-b33a-19e6bee21659",
    "message_id": "bdd745f4-03b6-42f4-873d-67fe48a75227",
    "version": "1.0",
    "status": "succeeded",
    "inputs": {
        "sys.query": "翻译“我们居住在地球村”"
    },
    "outputs": {
        "output": "We live in a global village"
    },
    "create_date": "2026-10-08T10:46:25Z",
    "finish_date": "2026-10-08T10:46:28Z",
    "user": "test_user1",
    "debug": false
}

      请求异常时，请参见错误码。

父主题： 应用示例

相关文档