From 382f3967bd205feed630b3ec76e9f3906a7452ea Mon Sep 17 00:00:00 2001 From: liuwei Date: Mon, 20 Apr 2026 13:36:56 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=96=97=E9=B1=BC=E6=97=A5?= =?UTF-8?q?=E6=8A=A5Dify=20400=E8=AF=B7=E6=B1=82=E5=B9=B6=E5=A2=9E?= =?UTF-8?q?=E5=BC=BA=E9=94=99=E8=AF=AF=E8=AF=8A=E6=96=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 变更项：\n1. 在斗鱼插件新增 daily_report_include_structured_inputs 配置（默认 false），Dify 入参默认改为精简字段（task_type/query/system_prompt/user_prompt/room_id 等），避免复杂对象输入触发 400。\n2. 调整 _build_dify_daily_report_inputs：仅在 include_structured_inputs=true 时才附带 report_payload_json，大幅降低 Workflow 入参类型不匹配风险。\n3. 在初始化流程中读取 report_api.include_structured_inputs，支持按环境开关结构化入参。\n4. 在 UnifiedLLMClient 的 Dify 调用中新增 HTTPError 细粒度处理，last_error 与日志会追加 response_body 片段，便于快速定位 Dify 侧具体报错原因。\n5. 更新 douyu 配置模板注释，明确复杂输入导致 400 的风险与开关用途，方便后续维护。 --- plugins/douyu/config.toml | 3 +++ plugins/douyu/main.py | 23 ++++++++++++++++++----- utils/ai/unified_llm.py | 18 ++++++++++++++++++ 3 files changed, 39 insertions(+), 5 deletions(-) diff --git a/plugins/douyu/config.toml b/plugins/douyu/config.toml index 3a31dd4..262efcb 100644 --- a/plugins/douyu/config.toml +++ b/plugins/douyu/config.toml @@ -29,3 +29,6 @@ audience_stats_sample_interval_seconds = 0 [Douyu.report_api] # 切换到 Dify 斗鱼日报专用工作流；对应配置位于根目录 config.yaml 的 llm.backends。 backend = "dify_workflow_douyu_daily_report" +# 是否把完整结构化 payload（JSON 大对象）作为输入传给 Dify。 +# 某些 Workflow 对复杂输入类型校验严格，会导致 400，默认关闭以保证可用性。 +include_structured_inputs = false diff --git a/plugins/douyu/main.py b/plugins/douyu/main.py index 03c612c..1c79521 100644 --- a/plugins/douyu/main.py +++ b/plugins/douyu/main.py @@ -523,6 +523,10 @@ class DouyuPlugin(MessagePluginInterface): self._daily_report_max_sessions = 4 self._daily_report_max_length = 1800 self._daily_report_send_image = True + # Dify 入参策略： + # 默认发送精简字段，避免某些 Workflow 对复杂对象输入校验严格导致 400。 + # 如需在工作流中使用完整结构化 payload，可在 report_api 显式开启。 + self._daily_report_include_structured_inputs = False self._audience_stats_sample_interval_seconds = 60 self._status_check_retry_count = 3 self._status_check_retry_delay_seconds = 1 @@ -613,6 +617,12 @@ class DouyuPlugin(MessagePluginInterface): ) report_api_cfg = cfg.get("report_api", {}) or {} + self._daily_report_include_structured_inputs = bool( + report_api_cfg.get( + "include_structured_inputs", + self._daily_report_include_structured_inputs, + ) + ) if report_api_cfg: self._daily_report_llm_client = UnifiedLLMClient(report_api_cfg) return True @@ -1857,8 +1867,11 @@ class DouyuPlugin(MessagePluginInterface): room_id = str(meta.get("room_id") or "").strip() anchor_day = str(meta.get("anchor_day") or "").strip() nickname = str(meta.get("nickname") or meta.get("room_name") or "").strip() - payload_json = json.dumps(payload, ensure_ascii=False) - return { + # 说明： + # 1. 部分 Dify Workflow 对输入变量类型校验较严格，复杂对象(dict/list)容易触发 400； + # 2. 默认只提交精简字符串字段，优先保证链路可用； + # 3. 如需在工作流内使用完整载荷，可通过 include_structured_inputs 开关启用。 + inputs = { # 任务路由字段：在 Dify 条件分支里用于区分日报正文/弹幕摘要。 "task_type": task_type, # 兼容 Workflow 中直接读取 query 的场景。 @@ -1866,9 +1879,6 @@ class DouyuPlugin(MessagePluginInterface): # 保留原有两段提示词，便于工作流内部二次拼装或调试。 "system_prompt": system_prompt, "user_prompt": user_prompt, - # 结构化报告载荷：既提供对象，也提供 JSON 文本，适配不同节点处理能力。 - "report_payload": payload, - "report_payload_json": payload_json, # 关键元信息：用于日志、标题拼接、数据看板或异常追踪。 "room_id": room_id, "anchor_day": anchor_day, @@ -1876,6 +1886,9 @@ class DouyuPlugin(MessagePluginInterface): # 控制输出长度：避免 Dify 侧生成超长内容后再被本地硬截断。 "max_length": int(self._daily_report_max_length or 1800), } + if self._daily_report_include_structured_inputs: + inputs["report_payload_json"] = json.dumps(payload, ensure_ascii=False) + return inputs def _call_daily_report_llm( self, diff --git a/utils/ai/unified_llm.py b/utils/ai/unified_llm.py index 98be060..f02a78d 100644 --- a/utils/ai/unified_llm.py +++ b/utils/ai/unified_llm.py @@ -9,6 +9,7 @@ from typing import Any, Dict, List, Optional, Tuple from urllib.parse import urlparse import requests +from requests import HTTPError from loguru import logger from utils.ai.llm_registry import LLMRegistry @@ -282,6 +283,23 @@ class UnifiedLLMClient: if parsed and parsed.get("text"): return parsed self.last_error = f"empty_model_output:{self.mode}" + except HTTPError as exc: + # 诊断增强： + # 1. Dify 返回 400 时，异常信息默认只包含状态码和 URL，不含具体原因； + # 2. 这里把响应体片段追加到 last_error，便于快速定位“入参字段/类型”问题。 + response_text = "" + response_obj = getattr(exc, "response", None) + if response_obj is not None: + try: + response_text = str(response_obj.text or "").strip() + except Exception: + response_text = "" + response_text = response_text[:500] if response_text else "" + self.last_error = ( + f"request_failed:attempt_{attempt}:{exc}" + + (f" | response_body={response_text}" if response_text else "") + ) + self.LOG.warning(f"[UnifiedLLMClient] Dify 请求失败: tag={tag}, attempt={attempt}, error={self.last_error}") except Exception as exc: self.last_error = f"request_failed:attempt_{attempt}:{exc}" self.LOG.warning(f"[UnifiedLLMClient] Dify 请求失败: tag={tag}, attempt={attempt}, error={exc}")