import requests

url = "https://api.dify.ai/v1/workflows/run"

headers = {
    'Authorization': 'Bearer app-KO3Co1e4TaJj0843Br2DQWMy',
    'Content-Type': 'application/json'
}

data = {
    "inputs": {"feedback": "商品的外包装破损了!!??"},
    "response_mode": "streaming",
    "user": "shk-456"
}

try:
    response = requests.post(url, json=data, headers=headers, stream=True)
    response.raise_for_status()  # 检查请求是否成功

    # 处理流式响应
    for line in response.iter_lines():
        if line:
            decoded_line = line.decode('utf-8')
            print(decoded_line)

except requests.exceptions.HTTPError as errh:
    print(f"HTTP错误: {errh}")
except requests.exceptions.ConnectionError as errc:
    print(f"连接错误: {errc}")
except requests.exceptions.Timeout as errt:
    print(f"超时错误: {errt}")
except requests.exceptions.RequestException as err:
    print(f"请求异常: {err}")