import requests
import time
 
# 配置
API_KEY = "your_api_key_here"
BASE_URL = "https://api.aicloud.hprtcloud.com"
 
# 请求头
headers = {
    "Authorization": f"Bearer {API_KEY}",
    "Content-Type": "application/json"
}
 
# 1. 创建任务
def create_task():
    url = f"{BASE_URL}/tasks/asr_v1/create_task"
    payload = {
        "audio_url": "https://example.com/audio.mp3",
        "target_language": "zh"
    }
    response = requests.post(url, json=payload, headers=headers)
    return response.json()
 
# 2. 获取任务状态
def get_task_status(task_id):
    url = f"{BASE_URL}/tasks/asr_v1/status/{task_id}"
    response = requests.get(url, headers=headers)
    return response.json()
 
# 3. 执行完整流程
def run_task():
    # 创建任务
    task = create_task()
    task_id = task["task_id"]
    
    # 轮询任务状态
    while True:
        status = get_task_status(task_id)
        if status["status"] == "completed":
            print("任务完成：", status["result"])
            break
        elif status["status"] == "failed":
            print("任务失败：", status["error"])
            break
        print("任务处理中...")
        time.sleep(2)
 
# 运行示例
if __name__ == "__main__":
    run_task()