feat(http_request_stream): 新增从流式响应中提取 conversation_id 的功能

在流式响应中检测形如 "conversation_id/xxxxx" 的片段并提取为单独变量输出，同时优化逻辑确保 conversation_id 仅输出一次且不重复出现在 stream_text 中

Author: mobiusy

http_request_stream/tools/http_request_stream.py

@@ -3,6 +3,7 @@
 
 import httpx
 from json import loads
+import re
 
 from dify_plugin import Tool
 from dify_plugin.entities.tool import ToolInvokeMessage
@@ -70,7 +71,10 @@ def _invoke(self, tool_parameters: dict[str, Any]) -> Generator[ToolInvokeMessag
                 raise ValueError("body must be a valid JSON string.")
 
         try:
-            text = ""
+            # 标记是否已经提取并输出过 conversation_id，避免重复输出
+            conversation_id_emitted = False
+            # 预编译匹配 conversation_id 的正则表达式：匹配形如 conversation_id/xxxxx 的片段
+            conversation_id_pattern = re.compile(r"\bconversation_id\/([^\s]+)")
             with httpx.stream(**stream_kwargs) as response:
                 # 对非 2xx 状态码进行友好提示并终止流
                 if response.status_code < 200 or response.status_code >= 300:
@@ -83,7 +87,18 @@ def _invoke(self, tool_parameters: dict[str, Any]) -> Generator[ToolInvokeMessag
                     if line.startswith("data:"):
                         line = line[5:].strip()
                     if line:
-                        text += line
+                        # 先检测是否包含 conversation_id 片段
+                        match = conversation_id_pattern.search(line)
+                        if match:
+                            # 命中 conversation_id 片段的 chunk，不输出到 stream_text
+                            if not conversation_id_emitted:
+                                conversation_id_value = match.group(1)
+                                # 输出一次 conversation_id 变量，供后续节点引用
+                                yield self.create_variable_message("conversation_id", conversation_id_value)
+                                conversation_id_emitted = True
+                            # 跳过本次 chunk 的 stream_text 输出
+                            continue
+                        # 非 conversation_id 的 chunk，正常输出到 stream_text
                         yield self.create_stream_variable_message("stream_text", line)
 
         except httpx.HTTPError as e:

http_request_stream/tools/http_request_stream.yaml

@@ -96,4 +96,7 @@ output_schema:
     stream_text:
       type: string
       description: The stream text generated by the tool
+    conversation_id:
+      type: string
+      description: Extracted conversation id when a chunk matches the pattern "conversation_id/xxxxx"
 

http_request_stream/working/progress.md

@@ -10,9 +10,12 @@
 ## 已完成工作
 - [2025-11-07 16:53:37 +08:00] 完成 README 文档的全面撰写与结构化说明
 - [2025-11-07 17:51:36 +08:00] 新增可选 headers 参数（JSON 对象字符串），实现工具代码读取并与默认 SSE 请求头合并，支持自定义请求头覆盖默认值
+- [2025-11-07 18:12:22 +08:00] 新增输出参数 conversation_id：在流式 chunk 中检测形如 "conversation_id/xxxxx" 的片段，提取并以变量输出，更新 YAML 的 output_schema 与工具实现
+- [2025-11-07 18:23:33 +08:00] 优化 conversation_id 提取逻辑：当 chunk 匹配到 conversation_id 时不输出到 stream_text，同时保持 conversation_id 仅输出一次
 
 ## 待办事项
 - [x] 支持自定义请求头（headers 参数，JSON 字符串）
+- [x] 从流式 chunk 中提取并输出 conversation_id 参数
 - [ ] 提供认证信息示例（如 Bearer Token）
 - [ ] 增加更多使用示例（不同服务的 SSE 与分块响应）
 - [ ] 完善错误信息的指引与用户友好提示