import requests

import json



# API配置

api_url = "http://localhost:8082/v1/workflows/run"

api_key = "app-6Ef8WnCL1rB4oMtvPgaLBSJy"



# 请求头

headers = {

    'Authorization': f'Bearer {api_key}',

    'Content-Type': 'application/json',

}



# 请求体

payload = {

    "inputs": {

        "text": "14:39:30: 记住以下几个关键点。14:39:30: 第一个关键点。14:39:36: 考虑的是模型如何通过。14:39:39: ITN。14:39:40: 或者说是。14:39:48: 标点符号模型。14:39:52: 或者是。14:39:57: 热词添加。14:40:00: 或者是。14:40:09: 前端和后端的传输音频格式。14:40:13: 包括但不限于。14:40:19: 通道数。14:40:24: 采样频率。14:40:26: 位深度。14:40:32: 还有音频的。14:40:34: 文件格式。14:40:38: 有什么限制？"

    },

    "response_mode": "blocking",  # 可改为streaming获取流式响应

    "user": "abc-123"

}



# 发送请求

try:

    response = requests.post(

        api_url,

        headers=headers,

        data=json.dumps(payload),

        timeout=100  # 设置超时时间

    )

     if response.status_code == 200:

        result = response.json()

        if result.get("data", {}).get("status") == "succeeded":

            output_data = result["data"]["outputs"]["output"]

            print(json.dumps(output_data, indent=2, ensure_ascii=False))

            outputs = result["data"].get("outputs", {})