{"id":121047,"date":"2026-11-02T00:56:49","date_gmt":"2026-11-01T16:56:49","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/121047.html"},"modified":"2026-11-02T00:56:49","modified_gmt":"2026-11-01T16:56:49","slug":"ai%e6%99%ba%e8%83%bd%e4%bd%93%e9%a1%b9%e7%9b%ae%e5%ae%9e%e6%88%98%e8%ae%b0%e5%bd%95%ef%bc%8830%ef%bc%89%ef%bc%9atoken-%e6%b6%88%e8%80%97%e7%bb%9f%e8%ae%a1%ef%bc%8c%e5%b9%b6%e5%9c%a8%e6%af%8f%e8%bd%ae","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/121047.html","title":{"rendered":"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0830\uff09\uff1atoken \u6d88\u8017\u7edf\u8ba1\uff0c\u5e76\u5728\u6bcf\u8f6e\u5bf9\u8bdd\u7ed3\u675f\u540e\u5c55\u793a\u7ed9\u7528\u6237"},"content":{"rendered":"

\/* MD \/ \u5bcc\u6587\u672c\u4e2d\u7684 .toc\uff08\u542b\u535a\u5ba2\u56ed\u642c\u5bb6\u7b49\u5d4c\u5957\u7ed3\u6784\uff09\uff1b.toc-box \u5728\u4fa7\u680f\uff0c\u4e0d\u53d7\u5f71\u54cd *\/
\n #content_views .toc,
\n \/* \u7f16\u8f91\u5668\u5e38\u5728\u76ee\u5f55\u524d\u540e\u63d2\u5165\u7a7a p\uff08:empty \u4ecd\u5360 20px\uff09\uff0c\u4e00\u5e76\u53bb\u6389\u907f\u514d\u9876\u7a7a\u9699 *\/
\n #content_views.markdown_views > p:empty:has(+ .toc),
\n #content_views.markdown_views > .toc + p:empty,
\n \/* \u5bcc\u6587\u672c\u65e7\u7248\u76ee\u5f55\u6807\u8bb0 *\/
\n #content_views.htmledit_views #main-toc,
\n #content_views.htmledit_views #hr-toc,
\n #content_views.htmledit_views p[id*=\\”-toc\\”] {
\n display: none !important;
\n }
\n \/* \u76ee\u5f55\u53bb\u6389\u540e\uff0c\u7d27\u8ddf\u7684\u9996\u4e2a\u6807\u9898\u4e0d\u518d\u591a\u51fa\u4e00\u5757\u4e0a\u8fb9\u8ddd *\/
\n #content_views.markdown_views > .toc + h1,
\n #content_views.markdown_views > .toc + h2,
\n #content_views.markdown_views > .toc + h3,
\n #content_views.markdown_views > .toc + h4,
\n #content_views.markdown_views > .toc + p:empty + h1,
\n #content_views.markdown_views > .toc + p:empty + h2,
\n #content_views.markdown_views > .toc + p:empty + h3,
\n #content_views.markdown_views > .toc + p:empty + h4 {
\n margin-top: 0 !important;
\n }<\/p>\n

AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55（30）：token \u6d88\u8017\u7edf\u8ba1，\u5e76\u5728\u6bcf\u8f6e\u5bf9\u8bdd\u7ed3\u675f\u540e\u5c55\u793a\u7ed9\u7528\u6237<\/h2>\n

1. \u5f15\u8a00<\/h3>\n

\u7b2c 15 \u7bc7\u7b2c\u4e00\u6b21\u628a\u8c03\u7528\u65e5\u5fd7\u843d\u5230\u4e86 ai_invoke_log \/ ai_tool_invoke_log，\u601d\u8def\u662f\u5bf9\u7684：<\/p>\n

\u4e00\u6b21\u7528\u6237\u63d0\u95ee = \u4e00\u4e2a TASK_BATCH
\n \u251c\u2500 \u4e00\u6761\u201c\u4e3b\u7ba1\u667a\u80fd\u4f53\u201d\u6c47\u603b\u884c
\n \u251c\u2500 \u6bcf\u4e2a\u5b50\u667a\u80fd\u4f53（\u6bcf\u6b21\u5de5\u5177\u6267\u884c）\u4e00\u6761\u660e\u7ec6\u884c
\n \u2514\u2500 \u6bcf\u6761\u660e\u7ec6\u884c\u518d\u5173\u8054\u4e00\u6761\u5de5\u5177\u8c03\u7528\u8bb0\u5f55<\/p>\n

\u4f46\u90a3\u4e00\u7248\u7559\u4e0b\u4e86\u4e00\u6279\u9057\u6f0f\u548c bug，\u6700\u5178\u578b\u7684\u662f：<\/p>\n\n#\u95ee\u9898\u73b0\u8c61<\/tr>\n\n\n\n\n\n\n\n
1<\/td>\n\u5b50\u667a\u80fd\u4f53\u884c COST_TOKEN_ \u6052\u4e3a 0<\/td>\n\u53ea\u80fd\u770b\u5230\u603b\u6570，\u62c6\u4e0d\u51fa\u201c\u94b1\u82b1\u5728\u54ea\u4e2a\u5de5\u5177\u201d<\/td>\n<\/tr>\n
2<\/td>\nCHILD_AGENT_ID_ \u5168\u4e3a\u7a7a<\/td>\n\u6c47\u603b\u884c\u5173\u8054\u4e0d\u5230\u6267\u884c\u5355\u5143，\u6309\u667a\u80fd\u4f53\u805a\u5408\u5168\u662f\u7a7a<\/td>\n<\/tr>\n
3<\/td>\n\u5e76\u884c\u5de5\u5177\u4e22\u8bb0\u8d26<\/td>\nThreadPoolExecutor.submit \u4e0d\u4f20\u64ad contextvar，\u5de5\u5177\u7ebf\u7a0b\u91cc current() \u662f None<\/td>\n<\/tr>\n
4<\/td>\n\u53e3\u5f84\u4e0d\u5168<\/td>\n\u77e5\u8bc6\u5e93\u3001\u4f01\u4e1a\u4fe1\u606f\u3001\u7ecf\u8425\u5206\u6790\u3001\u7f51\u7ad9\u5de5\u5177\u5185\u90e8\u7684\u6a21\u578b\u8c03\u7528\u6ca1\u8ba1\u5165<\/td>\n<\/tr>\n
5<\/td>\n\u7528\u91cf\u62ff\u4e0d\u51fa\u6765<\/td>\nfinalize_run \u843d\u5b8c\u5e93\u5c31\u628a\u5bf9\u8c61\u4e22\u4e86，\u524d\u7aef\u62ff\u4e0d\u5230<\/td>\n<\/tr>\n
6<\/td>\n\u91cd\u590d\u8c03\u7528\u653e\u5927\u7528\u91cf<\/td>\n\u4e3b\u7ba1\u53cd\u590d\u68c0\u7d22\u540c\u4e00\u95ee\u9898，token \u7ffb 2~3 \u500d<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

\u8fd9\u4e00\u7bc7\u628a\u8fd9\u4e9b\u95ee\u9898\u4e00\u8d77\u4fee\u6389，\u5e76\u8865\u4e0a\u201c\u6bcf\u8f6e\u5bf9\u8bdd\u7ed3\u675f\u5c55\u793a\u7ed9\u7528\u6237\u201d\u7684\u5b8c\u6574\u94fe\u8def\u3002<\/p>\n

\n

2. \u6574\u4f53\u6d41\u7a0b<\/h3>\n

POST \/chat\/v1\/chat\/completions
\n \u2502
\n \u25bc
\n_handle_stream（controller）
\n \u2502 begin_run(user_id, thread_id, skill, question)
\n \u25bc
\nsupervisor_graph.astream()
\n \u2502
\n \u251c\u2500 \u4e3b\u7ba1\u51b3\u7b56 \u2500\u2500\u2500\u2500 record_model_response() \u2500\u2510
\n \u2502 \u2502
\n \u251c\u2500 \u5de5\u5177\u8c03\u7528（\u53ef\u5e76\u884c） \u2502 \u90fd\u5199\u8fdb _RunLog（\u7236\u7ea7\u7d2f\u52a0\u5668）
\n \u2502 begin_tool_scope(name) \u2502 \u540c\u65f6\u5199\u8fdb\u5f53\u524d\u5de5\u5177\u4f5c\u7528\u57df
\n \u2502 \u251c\u2500 \u77e5\u8bc6\u5e93 RAG record_model_response()
\n \u2502 \u251c\u2500 \u4f01\u4e1a\u4fe1\u606f record_model_response()
\n \u2502 \u2514\u2500 \u2026 \u2502
\n \u2502 end_tool_scope() \u2192 \u8be5\u5de5\u5177 tokens \u2500\u2500\u2500\u2500\u2524
\n \u2502 \u2502
\n \u2514\u2500 \u603b\u7ed3\u751f\u6210 \u2500\u2500\u2500\u2500 record_usage() \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518
\n \u2502
\n \u25bc
\nfinalize_run() \u2500\u2500 \u843d\u5e93（\u6c47\u603b\u884c + \u5b50\u884c + \u5de5\u5177\u660e\u7ec6）\u2500\u2500 \u8fd4\u56de summary
\n \u2502 \u2514\u2500 token_quota_service.add_tokens()
\n \u25bc
\nyield {"type": "usage", "content": {…, "usedToday", "limit"}}
\n \u2502
\n \u25bc
\ncontroller \u8f6c StreamDataResp(type="usage") \u2192 \u6d4f\u89c8\u5668
\n \u2502
\n \u251c\u2500 \u524d\u7aef：\u6c14\u6ce1\u4e0b\u65b9\u5c0f\u5b57
\n \u2514\u2500 \u515c\u5e95：\u6b63\u6587\u5c3e\u90e8\u8ffd\u52a0\u4e00\u884c（\u517c\u5bb9\u65e7\u524d\u7aef）<\/p>\n

\u4e09\u6761\u786c\u7ea6\u675f：<\/p>\n

  • \u5148\u843d\u5e93\u3001\u540e\u63a8\u9001\u2014\u2014\u5c55\u793a\u7684\u6570\u5b57\u5fc5\u987b\u7b49\u4e8e\u8bb0\u8d26\u7684\u6570\u5b57；<\/li>\n
  • \u7236\u7ea7\u8bb0\u5168\u91cf\u3001\u4f5c\u7528\u57df\u8bb0\u660e\u7ec6\u2014\u2014\u53cc\u5199，\u4e24\u8fb9\u90fd\u4e0d\u91cd\u4e0d\u6f0f；<\/li>\n
  • \u4efb\u4f55\u8bb0\u8d26\u5931\u8d25\u90fd\u4e0d\u5f71\u54cd\u56de\u7b54\u2014\u2014\u5168\u90e8 try\/except \u5305\u88f9\u3002<\/li>\n
    \n

    3. \u6570\u636e\u6a21\u578b<\/h3>\n

    3.1 \u4e09\u7c7b\u884c<\/h4>\n\n\u884c\u6570\u91cfCOST_TOKEN_TOOL_INVOKE_COUNT_CHILD_AGENT_ID_<\/tr>\n\n\n\n\n
    \u6c47\u603b\u884c<\/td>\n\u6bcf\u8f6e 1 \u6761<\/td>\n\u672c\u8f6e\u603b\u91cf（\u542b\u6240\u6709\u5b50\u667a\u80fd\u4f53）<\/td>\n\u672c\u8f6e\u5de5\u5177\u6570<\/td>\nagent_supervisor<\/td>\n<\/tr>\n
    \u5b50\u667a\u80fd\u4f53\u884c<\/td>\n\u6bcf\u4e2a\u5de5\u5177 1 \u6761<\/td>\n\u8be5\u5de5\u5177\u81ea\u5df1\u7684\u6d88\u8017<\/td>\n1<\/td>\n\u5bf9\u5e94\u667a\u80fd\u4f53 ID<\/td>\n<\/tr>\n
    \u5de5\u5177\u660e\u7ec6<\/td>\n\u6bcf\u4e2a\u5de5\u5177 1 \u6761（ai_tool_invoke_log）<\/td>\n\u2014<\/td>\n\u2014<\/td>\n\u901a\u8fc7 AI_INVOKE_LOG_ID_ \u5173\u8054\u5b50\u884c<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

    \u6c47\u603b\u884c\u5b58\u5168\u91cf\u662f\u6709\u610f\u4e3a\u4e4b：\u8fd9\u6837 SUM(COST_TOKEN_) \u6309\u7528\u6237\/\u6309\u5929\u7edf\u8ba1\u624d\u662f\u5bf9\u7684；\u60f3\u62c6\u660e\u7ec6\u5c31\u67e5\u5b50\u884c\u3002<\/p>\n

    3.2 \u5b9e\u6d4b\u6570\u636e\u5f62\u6001<\/h4>\n

    thread=xxx child_agent_id=agent_supervisor cost_token=8865 tool_invoke_count=1 \u2190 \u6c47\u603b
    \nthread=xxx child_agent_id=2 cost_token=2830 tool_invoke_count=1 \u2190 \u77e5\u8bc6\u5e93<\/p>\n

    8865（\u603b） = 2830（\u77e5\u8bc6\u5e93） + 6035（\u4e3b\u7ba1\u51b3\u7b56 + \u603b\u7ed3）<\/p>\n

    \n

    4. \u5173\u952e\u8bbe\u8ba1<\/h3>\n

    4.1 contextvar \u8d2f\u7a7f\u5f02\u6b65\u4e0e\u7ebf\u7a0b<\/h4>\n

    \u56fe\u8282\u70b9\u3001\u5de5\u5177\u3001LLM \u8c03\u7528\u5206\u6563\u5728 async \u4e0e ThreadPoolExecutor \u91cc，\u624b\u5de5\u4f20\u5bf9\u8c61\u4e0d\u73b0\u5b9e，\u6240\u4ee5\u7528\u4e24\u4e2a contextvar：<\/p>\n

    _run_log_var:<\/span> ContextVar[<\/span>Optional[<\/span>_RunLog]<\/span>]<\/span> # \u6574\u4e2a\u8bf7\u6c42<\/span>
    \n_tool_scope_var:<\/span> ContextVar[<\/span>Optional[<\/span>_ToolScope]<\/span>]<\/span> # \u5f53\u524d\u5de5\u5177<\/span><\/p>\n

    4.2 \u53cc\u5199：\u7236\u7ea7 + \u5de5\u5177\u4f5c\u7528\u57df<\/h4>\n

    def<\/span> record_usage<\/span>(<\/span>prompt_tokens=<\/span>None<\/span>,<\/span> completion_tokens=<\/span>None<\/span>)<\/span>:<\/span>
    \n run_log =<\/span> current(<\/span>)<\/span>
    \n if<\/span> run_log is<\/span> None<\/span>:<\/span>
    \n return<\/span>
    \n run_log.<\/span>add_usage(<\/span>prompt_tokens,<\/span> completion_tokens)<\/span> # \u7236\u7ea7（\u603b\u91cf）<\/span>
    \n scope =<\/span> _tool_scope_var.<\/span>get(<\/span>)<\/span>
    \n if<\/span> scope is<\/span> not<\/span> None<\/span>:<\/span>
    \n scope.<\/span>add(<\/span>prompt_tokens,<\/span> completion_tokens)<\/span> # \u5f53\u524d\u5de5\u5177（\u660e\u7ec6）<\/span><\/p>\n

    \u4e00\u6b21\u8bb0\u8d26，\u4e24\u4e2a\u53bb\u5904\u3002\u7236\u7ea7\u4fdd\u8bc1\u603b\u91cf\u6b63\u786e，\u4f5c\u7528\u57df\u4fdd\u8bc1\u80fd\u62c6\u5230\u5de5\u5177\u3002<\/p>\n

    4.3 \u5e76\u884c\u5de5\u5177\u4e0d\u4e22\u8d26<\/h4>\n

    # supervisor_graph._run_async_in_thread_pool<\/span>
    \nctx =<\/span> contextvars.<\/span>copy_context(<\/span>)<\/span>
    \nreturn<\/span> executor.<\/span>submit(<\/span>ctx.<\/span>run,<\/span> lambda<\/span>:<\/span> asyncio.<\/span>run(<\/span>coro)<\/span>)<\/span>.<\/span>result(<\/span>)<\/span><\/p>\n

    copy_context() \u628a\u5f53\u524d\u7ebf\u7a0b\u7684 contextvar \u5feb\u7167\u5e26\u8fdb\u5b50\u4efb\u52a1，\u5426\u5219\u5de5\u5177\u7ebf\u7a0b\u91cc current() \u662f None，\u8bb0\u8d26\u9759\u9ed8\u4e22\u5931\u2014\u2014\u8fd9\u662f\u7b2c 15 \u7bc7\u6700\u9690\u853d\u7684 bug\u3002<\/p>\n

    4.4 CHILD_AGENT_ID_ \u4e3a\u7a7a\u7684\u771f\u6b63\u539f\u56e0<\/h4>\n

    row =<\/span> query_one(<\/span>"SELECT ID_ FROM ai_child_agent WHERE NAME = :name …"<\/span>)<\/span>
    \nagent_id =<\/span> (<\/span>row or<\/span> {<\/span>}<\/span>)<\/span>.<\/span>get(<\/span>"ID_"<\/span>)<\/span> # \u2190 \u6c38\u8fdc\u53d6\u4e0d\u5230<\/span><\/p>\n

    PostgreSQL \u4f1a\u628a\u672a\u52a0\u5f15\u53f7\u7684\u6807\u8bc6\u7b26\u6298\u6210\u5c0f\u5199，\u8fd4\u56de\u7684\u5b57\u5178\u952e\u662f id_，\u4e0d\u662f ID_\u3002MySQL \u4e0b\u6ca1\u95ee\u9898，\u5207\u5230 PG \u540e\u5168\u7a7a\u3002<\/p>\n

    \u4fee\u6cd5：\u7528\u522b\u540d，\u4e0d\u4f9d\u8d56\u9a71\u52a8\u7684\u5927\u5c0f\u5199\u884c\u4e3a\u3002<\/p>\n

    SELECT<\/span> ID_ AS<\/span> agent_id FROM<\/span> ai_child_agent WHERE<\/span> NAME =<\/span> :name AND<\/span> DELETED_ !=<\/span> 1<\/span> LIMIT<\/span> 1<\/span><\/p>\n

    \u540c\u65f6\u8865\u4e86\u4e24\u4ef6\u4e8b：<\/p>\n

      \n
    • ai_child_agent \u91cc\u6ca1\u6709\u201c\u4e3b\u7ba1\u667a\u80fd\u4f53\u201d\u8fd9\u884c\u65f6\u81ea\u52a8\u8865\u5efa（\u56fa\u5b9a ID agent_supervisor，\u5e42\u7b49）；<\/li>\n
    • \u672a\u547d\u4e2d\u7684\u7ed3\u679c\u4e0d\u7f13\u5b58，\u8865\u5b8c\u6570\u636e\u4e0d\u7528\u91cd\u542f\u3002<\/li>\n<\/ul>\n

      4.5 \u7528\u91cf\u5fc5\u987b\u80fd\u5e26\u51fa\u6765<\/h4>\n

      finalize_run \u539f\u672c return None，\u73b0\u5728\u8fd4\u56de：<\/p>\n

      {<\/span>
      \n "promptTokens"<\/span>:<\/span> 7756<\/span>,<\/span> "completionTokens"<\/span>:<\/span> 1109<\/span>,<\/span> "totalTokens"<\/span>:<\/span> 8865<\/span>,<\/span>
      \n "costMs"<\/span>:<\/span> 12345<\/span>,<\/span> "toolCount"<\/span>:<\/span> 1<\/span>
      \n}<\/span><\/p>\n

      \u4e0a\u5c42\u518d\u8865 usedToday \/ limit \u63a8\u7ed9\u524d\u7aef\u3002<\/p>\n

      \n

      5. \u5173\u952e\u4ee3\u7801<\/h3>\n

      5.1 \u8fd0\u884c\u4e0a\u4e0b\u6587\u4e0e\u5de5\u5177\u4f5c\u7528\u57df<\/h4>\n

      class<\/span> _RunLog<\/span>:<\/span>
      \n def<\/span> __init__<\/span>(<\/span>self,<\/span> user_id,<\/span> thread_id,<\/span> skill,<\/span> question)<\/span>:<\/span>
      \n self.<\/span>run_id =<\/span> uuid.<\/span>uuid4(<\/span>)<\/span>.<\/span>hex<\/span>
      \n self.<\/span>batch_id =<\/span> uuid.<\/span>uuid4(<\/span>)<\/span>.<\/span>hex<\/span>
      \n self.<\/span>started_dt =<\/span> datetime.<\/span>now(<\/span>)<\/span>
      \n self.<\/span>tools =<\/span> [<\/span>]<\/span>
      \n self.<\/span>prompt_tokens =<\/span> 0<\/span>
      \n self.<\/span>completion_tokens =<\/span> 0<\/span>
      \n self.<\/span>lock =<\/span> threading.<\/span>Lock(<\/span>)<\/span><\/p>\n

      def<\/span> add_usage<\/span>(<\/span>self,<\/span> prompt=<\/span>None<\/span>,<\/span> completion=<\/span>None<\/span>)<\/span>:<\/span>
      \n with<\/span> self.<\/span>lock:<\/span>
      \n if<\/span> prompt:<\/span>
      \n self.<\/span>prompt_tokens +=<\/span> int<\/span>(<\/span>prompt)<\/span>
      \n if<\/span> completion:<\/span>
      \n self.<\/span>completion_tokens +=<\/span> int<\/span>(<\/span>completion)<\/span><\/p>\n

      @property<\/span>
      \n def<\/span> total_tokens<\/span>(<\/span>self)<\/span>:<\/span>
      \n return<\/span> self.<\/span>prompt_tokens +<\/span> self.<\/span>completion_tokens<\/p>\n

      class<\/span> _ToolScope<\/span>:<\/span>
      \n """\u5355\u6b21\u5de5\u5177\u6267\u884c\u7684 token \u8ba1\u6570\u5668"""<\/span><\/p>\n

      def<\/span> __init__<\/span>(<\/span>self,<\/span> tool_name)<\/span>:<\/span>
      \n self.<\/span>tool_name =<\/span> tool_name
      \n self.<\/span>prompt_tokens =<\/span> 0<\/span>
      \n self.<\/span>completion_tokens =<\/span> 0<\/span>
      \n self.<\/span>lock =<\/span> threading.<\/span>Lock(<\/span>)<\/span><\/p>\n

      begin_tool_scope \/ end_tool_scope \u7528\u5de5\u6574\u7684 set\/reset，\u5fc5\u987b\u5728 finally \u4e2d\u914d\u5bf9：<\/p>\n

      def<\/span> begin_tool_scope<\/span>(<\/span>tool_name:<\/span> str<\/span>)<\/span>:<\/span>
      \n return<\/span> _tool_scope_var.<\/span>set<\/span>(<\/span>_ToolScope(<\/span>tool_name)<\/span>)<\/span><\/p>\n

      def<\/span> end_tool_scope<\/span>(<\/span>scope_token)<\/span> –<\/span>><\/span> int<\/span>:<\/span>
      \n scope =<\/span> _tool_scope_var.<\/span>get(<\/span>)<\/span>
      \n _tool_scope_var.<\/span>reset(<\/span>scope_token)<\/span>
      \n return<\/span> scope.<\/span>total_tokens if<\/span> scope else<\/span> 0<\/span><\/p>\n

      5.2 \u5de5\u5177\u8282\u70b9：\u4f5c\u7528\u57df\u5305\u4f4f\u6574\u6bb5\u6267\u884c<\/h4>\n

      start_dt =<\/span> datetime.<\/span>now(<\/span>)<\/span>
      \nscope_token =<\/span> invoke_log_service.<\/span>begin_tool_scope(<\/span>tool_name)<\/span>
      \ntry<\/span>:<\/span>
      \n result =<\/span> tool.<\/span>_run(<\/span>.<\/span>.<\/span>.<\/span>)<\/span>
      \n clean_result =<\/span> strip_tool_error(<\/span>result)<\/span>
      \n ok =<\/span> not<\/span> is_tool_error(<\/span>result)<\/span>
      \nexcept<\/span> Exception as<\/span> e:<\/span>
      \n clean_result =<\/span> f"\u5de5\u5177\u6267\u884c\u5931\u8d25: <\/span>{<\/span>str<\/span>(<\/span>e)<\/span>}<\/span><\/span>"<\/span><\/span>
      \n ok =<\/span> False<\/span>
      \n error_text =<\/span> str<\/span>(<\/span>e)<\/span>
      \nfinally<\/span>:<\/span>
      \n tool_tokens =<\/span> invoke_log_service.<\/span>end_tool_scope(<\/span>scope_token)<\/span><\/p>\n

      _record_tool_event(<\/span>
      \n tool_name,<\/span> tool_args,<\/span> start_dt,<\/span>
      \n clean_result if<\/span> ok else<\/span> None<\/span>,<\/span>
      \n error_text,<\/span>
      \n tool_tokens,<\/span> # \u2190 \u5b50\u884c COST_TOKEN_ \u7528\u8fd9\u4e2a<\/span>
      \n)<\/span><\/p>\n

      \u4e0d\u7ba1\u6210\u529f\u3001\u5931\u8d25\u8fd8\u662f\u629b\u5f02\u5e38，\u4f5c\u7528\u57df\u90fd\u4f1a\u51fa\u6808，\u4e0d\u4f1a\u6c61\u67d3\u4e0b\u4e00\u4e2a\u5de5\u5177\u3002<\/p>\n

      5.3 \u8bb0\u8d26\u5165\u53e3：\u4e09\u5904\u5fc5\u8c03<\/h4>\n

      def<\/span> record_model_response<\/span>(<\/span>resp,<\/span> prompt_messages,<\/span> answer_text)<\/span> –<\/span>><\/span> None<\/span>:<\/span>
      \n """\u4f18\u5148\u53d6 usage，\u7f3a\u5931\u65f6\u6309\u5b57\u7b26\u4f30\u7b97"""<\/span>
      \n run_log =<\/span> current(<\/span>)<\/span>
      \n if<\/span> run_log is<\/span> None<\/span>:<\/span>
      \n return<\/span>
      \n usage =<\/span> getattr<\/span>(<\/span>resp,<\/span> "usage"<\/span>,<\/span> None<\/span>)<\/span>
      \n if<\/span> usage is<\/span> not<\/span> None<\/span>:<\/span>
      \n record_usage(<\/span>
      \n getattr<\/span>(<\/span>usage,<\/span> "prompt_tokens"<\/span>,<\/span> None<\/span>)<\/span>,<\/span>
      \n getattr<\/span>(<\/span>usage,<\/span> "completion_tokens"<\/span>,<\/span> None<\/span>)<\/span>,<\/span>
      \n )<\/span>
      \n else<\/span>:<\/span>
      \n record_text_estimate(<\/span>prompt_messages,<\/span> answer_text)<\/span><\/p>\n

      \u8c03\u7528\u70b9：<\/p>\n\n\u4f4d\u7f6e\u8c03\u7528<\/tr>\n\n\n\n\n
      _node_supervisor \u6bcf\u8f6e\u51b3\u7b56<\/td>\nrecord_model_response(resp, messages_for_selection, raw_output)<\/td>\n<\/tr>\n
      _astream_llm（\u603b\u7ed3）<\/td>\n\u6d41\u7ed3\u675f\u540e record_usage(usage_prompt, usage_completion)<\/td>\n<\/tr>\n
      \u5de5\u5177\u5185\u90e8（RAG \/ \u4f01\u4e1a\u4fe1\u606f \/ \u7ecf\u8425\u5206\u6790 \/ \u7f51\u7ad9）<\/td>\n\u5404\u81ea record_model_response(…)<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

      5.4 \u6c47\u603b\u884c\u4e0e\u5b50\u884c\u843d\u5e93<\/h4>\n

      # 1) \u6c47\u603b\u884c<\/span>
      \nconn.<\/span>execute(<\/span>text(<\/span>text_insert_invoke(<\/span>)<\/span>)<\/span>,<\/span> {<\/span>
      \n "id"<\/span>:<\/span> run_log.<\/span>run_id,<\/span>
      \n "child_agent_id"<\/span>:<\/span> supervisor_agent_id or<\/span> ""<\/span>,<\/span>
      \n "tool_invoke_count"<\/span>:<\/span> len<\/span>(<\/span>run_log.<\/span>tools)<\/span>,<\/span>
      \n "cost_token"<\/span>:<\/span> run_log.<\/span>total_tokens,<\/span> # \u2190 \u672c\u8f6e\u603b\u91cf<\/span>
      \n .<\/span>.<\/span>.<\/span>
      \n}<\/span>)<\/span><\/p>\n

      # 2) \u6bcf\u4e2a\u5b50\u667a\u80fd\u4f53\u4e00\u884c<\/span>
      \nfor<\/span> event in<\/span> run_log.<\/span>tools:<\/span>
      \n child_invoke_id =<\/span> uuid.<\/span>uuid4(<\/span>)<\/span>.<\/span>hex<\/span>
      \n conn.<\/span>execute(<\/span>text(<\/span>text_insert_invoke(<\/span>)<\/span>)<\/span>,<\/span> {<\/span>
      \n "id"<\/span>:<\/span> child_invoke_id,<\/span>
      \n "child_agent_id"<\/span>:<\/span> _lookup_child_agent_id(<\/span>[<\/span>event.<\/span>get(<\/span>"display_name"<\/span>)<\/span>,<\/span> event.<\/span>get(<\/span>"tool_name"<\/span>)<\/span>]<\/span>)<\/span>,<\/span>
      \n "tool_invoke_count"<\/span>:<\/span> 1<\/span>,<\/span>
      \n "cost_token"<\/span>:<\/span> int<\/span>(<\/span>event.<\/span>get(<\/span>"tokens"<\/span>)<\/span> or<\/span> 0<\/span>)<\/span>,<\/span> # \u2190 \u8be5\u5de5\u5177\u81ea\u5df1\u7684\u7528\u91cf<\/span>
      \n .<\/span>.<\/span>.<\/span>
      \n }<\/span>)<\/span>
      \n # 3) \u5de5\u5177\u660e\u7ec6<\/span>
      \n conn.<\/span>execute(<\/span>text(<\/span>text_insert_tool(<\/span>)<\/span>)<\/span>,<\/span> {<\/span>.<\/span>.<\/span>.<\/span>}<\/span>)<\/span><\/p>\n

      5.5 \u6536\u5c3e\u5e76\u8fd4\u56de\u7528\u91cf<\/h4>\n

      async<\/span> def<\/span> finalize_run<\/span>(<\/span>success,<\/span> answer=<\/span>""<\/span>,<\/span> fail_msg=<\/span>""<\/span>)<\/span>:<\/span>
      \n run_log =<\/span> current(<\/span>)<\/span>
      \n if<\/span> run_log is<\/span> None<\/span>:<\/span>
      \n return<\/span> None<\/span><\/p>\n

      summary =<\/span> {<\/span>
      \n "promptTokens"<\/span>:<\/span> run_log.<\/span>prompt_tokens,<\/span>
      \n "completionTokens"<\/span>:<\/span> run_log.<\/span>completion_tokens,<\/span>
      \n "totalTokens"<\/span>:<\/span> run_log.<\/span>total_tokens,<\/span>
      \n "costMs"<\/span>:<\/span> int<\/span>(<\/span>(<\/span>datetime.<\/span>now(<\/span>)<\/span> –<\/span> run_log.<\/span>started_dt)<\/span>.<\/span>total_seconds(<\/span>)<\/span> *<\/span> 1000<\/span>)<\/span>,<\/span>
      \n "toolCount"<\/span>:<\/span> len<\/span>(<\/span>run_log.<\/span>tools)<\/span>,<\/span>
      \n }<\/span>
      \n try<\/span>:<\/span>
      \n await<\/span> asyncio.<\/span>to_thread(<\/span>_do_finalize,<\/span> run_log,<\/span> success,<\/span> answer,<\/span> fail_msg)<\/span>
      \n finally<\/span>:<\/span>
      \n reset_run(<\/span>)<\/span>
      \n return<\/span> summary<\/p>\n

      5.6 \u56fe\u91cc\u63a8\u9001 usage（\u843d\u5e93\u4e4b\u540e）<\/h4>\n

      summary =<\/span> await<\/span> invoke_log_service.<\/span>finalize_run(<\/span>
      \n success=<\/span>success,<\/span> answer=<\/span>answer_text,<\/span> fail_msg=<\/span>fail_msg
      \n)<\/span><\/p>\n

      if<\/span> summary:<\/span>
      \n limit =<\/span> int<\/span>(<\/span>setting.<\/span>chat_daily_token_limit or<\/span> 0<\/span>)<\/span>
      \n used_today =<\/span> 0<\/span>
      \n if<\/span> limit ><\/span> 0<\/span>:<\/span>
      \n try<\/span>:<\/span>
      \n used_today =<\/span> await<\/span> asyncio.<\/span>to_thread(<\/span>
      \n token_quota_service.<\/span>used_tokens,<\/span> user_id,<\/span> "chat"<\/span>
      \n )<\/span>
      \n except<\/span> Exception as<\/span> e:<\/span>
      \n logger.<\/span>warning(<\/span>f"[usage] \u8bfb\u53d6\u4eca\u65e5\u7528\u91cf\u5931\u8d25: <\/span>{<\/span>e}<\/span><\/span>"<\/span><\/span>)<\/span>
      \n yield<\/span> {<\/span>
      \n "type"<\/span>:<\/span> "usage"<\/span>,<\/span>
      \n "content"<\/span>:<\/span> {<\/span>**<\/span>summary,<\/span> "usedToday"<\/span>:<\/span> used_today,<\/span> "limit"<\/span>:<\/span> limit}<\/span>,<\/span>
      \n }<\/span><\/p>\n

      usedToday \u4ece Redis \u8bfb（finalize_run \u5185\u90e8\u5df2 add_tokens），\u6240\u4ee5\u63a8\u9001\u503c\u548c\u5f53\u65e5\u989d\u5ea6\u662f\u540c\u4e00\u4efd\u6570\u636e\u3002<\/p>\n

      5.7 \u63a7\u5236\u5668\u8f6c\u53d1 + \u65e7\u524d\u7aef\u515c\u5e95<\/h4>\n

      elif<\/span> chunk_type ==<\/span> "usage"<\/span>:<\/span>
      \n usage_info =<\/span> content if<\/span> isinstance<\/span>(<\/span>content,<\/span> dict<\/span>)<\/span> else<\/span> None<\/span>
      \n yield<\/span> StreamDataResp(<\/span>data=<\/span>content,<\/span> type<\/span>=<\/span>StreamDataRespType.<\/span>USAGE.<\/span>value)<\/span>.<\/span>model_dump_json(<\/span>)<\/span>
      \n.<\/span>.<\/span>.<\/span>
      \nawait<\/span> _record_conversation(<\/span>messages,<\/span> thread_id,<\/span> user_id,<\/span> full_answer)<\/span><\/p>\n

      if<\/span> setting.<\/span>chat_usage_in_answer and<\/span> usage_info:<\/span>
      \n tail =<\/span> _format_usage_line(<\/span>usage_info)<\/span>
      \n if<\/span> tail:<\/span>
      \n yield<\/span> StreamDataResp(<\/span>data=<\/span>tail,<\/span> type<\/span>=<\/span>StreamDataRespType.<\/span>ANSWER.<\/span>value)<\/span>.<\/span>model_dump_json(<\/span>)<\/span><\/p>\n

      def<\/span> _format_usage_line<\/span>(<\/span>usage:<\/span> dict<\/span>)<\/span> –<\/span>><\/span> str<\/span>:<\/span>
      \n total =<\/span> int<\/span>(<\/span>usage.<\/span>get(<\/span>"totalTokens"<\/span>)<\/span> or<\/span> 0<\/span>)<\/span>
      \n if<\/span> total <=<\/span> 0<\/span>:<\/span>
      \n return<\/span> ""<\/span>
      \n parts =<\/span> [<\/span>f"\u672c\u6b21\u6d88\u8017 <\/span>{<\/span>total:<\/span>,<\/span>}<\/span><\/span> tokens"<\/span><\/span>]<\/span>
      \n cost_ms =<\/span> int<\/span>(<\/span>usage.<\/span>get(<\/span>"costMs"<\/span>)<\/span> or<\/span> 0<\/span>)<\/span>
      \n if<\/span> cost_ms ><\/span> 0<\/span>:<\/span>
      \n parts.<\/span>append(<\/span>f"\u7528\u65f6 <\/span>{<\/span>cost_ms \/<\/span> 1000<\/span>:<\/span>.1f<\/span>}<\/span><\/span>s"<\/span><\/span>)<\/span>
      \n limit =<\/span> int<\/span>(<\/span>usage.<\/span>get(<\/span>"limit"<\/span>)<\/span> or<\/span> 0<\/span>)<\/span>
      \n used =<\/span> int<\/span>(<\/span>usage.<\/span>get(<\/span>"usedToday"<\/span>)<\/span> or<\/span> 0<\/span>)<\/span>
      \n if<\/span> limit ><\/span> 0<\/span>:<\/span>
      \n parts.<\/span>append(<\/span>f"\u4eca\u65e5\u5269\u4f59 <\/span>{<\/span>max<\/span>(<\/span>0<\/span>,<\/span> limit –<\/span> used)<\/span>:<\/span>,<\/span>}<\/span><\/span>"<\/span><\/span>)<\/span>
      \n return<\/span> "\\\\n\\\\n—\\\\n"<\/span> +<\/span> " \u00b7 "<\/span>.<\/span>join(<\/span>parts)<\/span><\/p>\n

      \u4e24\u4e2a\u7ec6\u8282：<\/p>\n

        \n
      • \u5c3e\u90e8\u6587\u6848\u5728 _record_conversation \u4e4b\u540e\u53d1，\u6240\u4ee5\u4e0d\u4f1a\u5199\u8fdb\u5386\u53f2；<\/li>\n
      • CHAT_USAGE_IN_ANSWER=false \u53ef\u5173\u6389，\u53ea\u7528\u7ed3\u6784\u5316\u4e8b\u4ef6\u3002<\/li>\n<\/ul>\n

        5.8 \u524d\u7aef\u89e3\u6790\u4e0e\u5c55\u793a<\/h4>\n

        chat.js \u589e\u52a0\u5206\u652f：<\/p>\n

        if<\/span> (<\/span>type ===<\/span> 'answer'<\/span>)<\/span> {<\/span>
        \n onAnswer?.<\/span>(<\/span>data)<\/span>
        \n}<\/span> else<\/span> if<\/span> (<\/span>type ===<\/span> 'analysis'<\/span>)<\/span> {<\/span>
        \n onStatus?.<\/span>(<\/span>data)<\/span>
        \n}<\/span> else<\/span> if<\/span> (<\/span>type ===<\/span> 'usage'<\/span>)<\/span> {<\/span>
        \n onUsage?.<\/span>(<\/span>data)<\/span> \/\/ \u65b0\u589e：\u672c\u6b21\u7528\u91cf<\/span>
        \n}<\/span> else<\/span> if<\/span> (<\/span>type ===<\/span> 'complete'<\/span>)<\/span> {<\/span>
        \n onDone?.<\/span>(<\/span>)<\/span>
        \n}<\/span><\/p>\n

        Chat.vue \u63a5\u6536\u5e76\u6302\u5230\u6d88\u606f\u4e0a：<\/p>\n

        onUsage<\/span>:<\/span> (<\/span>usage<\/span>)<\/span> =><\/span> {<\/span>
        \n if<\/span> (<\/span>messages.<\/span>value[<\/span>assistantIndex]<\/span>)<\/span> {<\/span>
        \n messages.<\/span>value[<\/span>assistantIndex]<\/span>.<\/span>usage =<\/span> usage ||<\/span> null<\/span>
        \n }<\/span>
        \n}<\/span>,<\/span><\/p>\n

        function<\/span> formatUsage<\/span>(<\/span>u<\/span>)<\/span> {<\/span>
        \n if<\/span> (<\/span>!<\/span>u ||<\/span> !<\/span>u.<\/span>totalTokens)<\/span> return<\/span> ''<\/span>
        \n const<\/span> parts =<\/span> [<\/span>`<\/span>\u672c\u6b21\u6d88\u8017 <\/span>${<\/span>Number<\/span>(<\/span>u.<\/span>totalTokens)<\/span>.<\/span>toLocaleString<\/span>(<\/span>)<\/span>}<\/span><\/span> tokens<\/span>`<\/span><\/span>]<\/span>
        \n if<\/span> (<\/span>u.<\/span>costMs)<\/span> parts.<\/span>push<\/span>(<\/span>`<\/span>\u7528\u65f6 <\/span>${<\/span>(<\/span>u.<\/span>costMs \/<\/span> 1000<\/span>)<\/span>.<\/span>toFixed<\/span>(<\/span>1<\/span>)<\/span>}<\/span><\/span>s<\/span>`<\/span><\/span>)<\/span>
        \n if<\/span> (<\/span>u.<\/span>limit ><\/span> 0<\/span> &&<\/span> typeof<\/span> u.<\/span>usedToday ===<\/span> 'number'<\/span>)<\/span> {<\/span>
        \n const<\/span> left =<\/span> Math.<\/span>max<\/span>(<\/span>0<\/span>,<\/span> u.<\/span>limit –<\/span> u.<\/span>usedToday)<\/span>
        \n parts.<\/span>push<\/span>(<\/span>`<\/span>\u4eca\u65e5\u5269\u4f59 <\/span>${<\/span>left.<\/span>toLocaleString<\/span>(<\/span>)<\/span>}<\/span><\/span>`<\/span><\/span>)<\/span>
        \n }<\/span>
        \n return<\/span> parts.<\/span>join<\/span>(<\/span>' \u00b7 '<\/span>)<\/span>
        \n}<\/span><\/p>\n

        <<\/span>div<\/span> v-if<\/span>=<\/span>"<\/span>msg.usage"<\/span><\/span> class<\/span>=<\/span>"<\/span>usage-hint"<\/span><\/span>><\/span><\/span>{{ formatUsage(msg.usage) }}<\/<\/span>div<\/span>><\/span><\/span><\/p>\n

        \u672a\u77e5 type \u4f1a\u88ab\u89e3\u6790\u5668\u5ffd\u7565，\u6240\u4ee5\u65b0\u589e\u4e8b\u4ef6\u5929\u7136\u5411\u540e\u517c\u5bb9\u3002<\/p>\n

        \n

        6. \u907f\u514d\u91cd\u590d\u8c03\u7528\u653e\u5927\u7528\u91cf<\/h3>\n

        \u540c\u4e00\u95ee\u9898\u88ab\u8fde\u8c03 4 \u6b21\u65f6，\u7528\u91cf\u4f1a\u7ffb 2~3 \u500d\u3002\u4e24\u5c42\u9632\u62a4：<\/p>\n

        \u2460 \u63d0\u793a\u8bcd\u89c4\u5219（\u8f6f\u7ea6\u675f）<\/p>\n

        11. \u3010\u907f\u514d\u91cd\u590d\u8c03\u7528\u3011\u5982\u679c\u201c\u5df2\u83b7\u53d6\u7684\u5de5\u5177\u7ed3\u679c\u201d\u4e2d\u5df2\u6709\u80fd\u56de\u7b54\u7528\u6237\u95ee\u9898\u7684\u5185\u5bb9，\u4e0d\u8981\u518d\u6b21\u8c03\u7528\u76f8\u540c\u5de5\u5177\u3002<\/p>\n

        \u2461 \u786c\u53bb\u91cd（\u786e\u5b9a\u6027）<\/p>\n

        def<\/span> _call_signature<\/span>(<\/span>tool_name:<\/span> str<\/span>,<\/span> tool_args:<\/span> dict<\/span>)<\/span> –<\/span>><\/span> str<\/span>:<\/span>
        \n args_text =<\/span> json.<\/span>dumps(<\/span>tool_args or<\/span> {<\/span>}<\/span>,<\/span> sort_keys=<\/span>True<\/span>,<\/span> ensure_ascii=<\/span>False<\/span>,<\/span> default=<\/span>str<\/span>)<\/span>
        \n return<\/span> f"<\/span>{<\/span>tool_name}<\/span><\/span>:<\/span>{<\/span>args_text}<\/span><\/span>"<\/span><\/span><\/p>\n

        executed =<\/span> set<\/span>(<\/span>state.<\/span>get(<\/span>"executed_calls"<\/span>)<\/span> or<\/span> [<\/span>]<\/span>)<\/span>
        \ndeduped =<\/span> [<\/span>]<\/span>
        \nfor<\/span> tc in<\/span> tool_calls or<\/span> [<\/span>]<\/span>:<\/span>
        \n sig =<\/span> _call_signature(<\/span>tc.<\/span>get(<\/span>"name"<\/span>)<\/span> or<\/span> ""<\/span>,<\/span> tc.<\/span>get(<\/span>"args"<\/span>)<\/span> or<\/span> {<\/span>}<\/span>)<\/span>
        \n if<\/span> sig in<\/span> executed:<\/span>
        \n logger.<\/span>warning(<\/span>f"[supervisor] \u8df3\u8fc7\u91cd\u590d\u8c03\u7528: <\/span>{<\/span>sig[<\/span>:<\/span>120]<\/span>}<\/span><\/span>"<\/span><\/span>)<\/span>
        \n continue<\/span>
        \n deduped.<\/span>append(<\/span>tc)<\/span>
        \ntool_calls =<\/span> deduped<\/p>\n

        \u53ea\u62e6\u201c\u5de5\u5177\u540d + \u53c2\u6570\u5b8c\u5168\u76f8\u540c\u201d，\u6362\u5e93\u8865\u5145\u68c0\u7d22（\u53c2\u6570\u4e0d\u540c）\u4ecd\u7136\u5141\u8bb8\u3002<\/p>\n

        \n

        7. \u5b9e\u6d4b<\/h3>\n

        # \u4e8b\u4ef6\u987a\u5e8f
        \ndata: {"data":"…","type":"answer"}
        \ndata: {"data":{"promptTokens":7756,"completionTokens":1109,"totalTokens":8865,
        \n "costMs":12345,"toolCount":1,"usedToday":8865,"limit":200000},"type":"usage"}
        \ndata: {"data":"\\\\n\\\\n—\\\\n\u672c\u6b21\u6d88\u8017 8,865 tokens \u00b7 \u7528\u65f6 12.3s \u00b7 \u4eca\u65e5\u5269\u4f59 191,135","type":"answer"}
        \ndata: {"data":"","type":"complete"}<\/p>\n

        # \u53bb\u91cd\u524d\u540e（\u540c\u4e00\u95ee\u9898）
        \n\u6539\u524d: 4 \u6b21\u5de5\u5177\u8c03\u7528, \u51b3\u7b56 5 \u8f6e, 21467 tokens, 21.3s
        \n\u6539\u540e: 1 \u6b21\u5de5\u5177\u8c03\u7528, \u51b3\u7b56 2 \u8f6e, 8865 tokens, 8.2s<\/p>\n

        # \u5b50\u884c\u7ec8\u4e8e\u6709\u503c
        \n{'child_agent_id_': 'agent_supervisor', 'cost_token': 8865, 'tool_invoke_count': 1}
        \n{'child_agent_id_': '2', 'cost_token': 2830, 'tool_invoke_count': 1}<\/p>\n

        \n

        8. \u5bf9\u8d26\u53e3\u5f84<\/h3>\n

        — \u67d0\u7528\u6237\u67d0\u5929\u603b\u6d88\u8017（\u6c47\u603b\u884c\u5df2\u542b\u5b50\u884c，\u76f4\u63a5 SUM \u4e0d\u4f1a\u91cd\u590d）<\/span>
        \nSELECT<\/span> SUM<\/span>(<\/span>COST_TOKEN_)<\/span> FROM<\/span> ai_invoke_log
        \nWHERE<\/span> CREATE_BY_ =<\/span> '1001'<\/span> AND<\/span> CREATE_TIME_ >=<\/span> '2026-10-29'<\/span>;<\/span><\/p>\n

        — \u67d0\u8f6e\u6309\u5de5\u5177\u62c6\u5206<\/span>
        \nSELECT<\/span> CHILD_AGENT_ID_,<\/span> SUM<\/span>(<\/span>COST_TOKEN_)<\/span>,<\/span> COUNT<\/span>(<\/span>*<\/span>)<\/span>
        \nFROM<\/span> ai_invoke_log
        \nWHERE<\/span> THREAD_ID =<\/span> 'xxx'<\/span> AND<\/span> CHILD_AGENT_ID_ <><\/span> 'agent_supervisor'<\/span>
        \nGROUP<\/span> BY<\/span> CHILD_AGENT_ID_;<\/span><\/p>\n

        — \u4e3b\u7ba1\u81ea\u8eab = \u6c47\u603b\u884c – \u5b50\u884c\u5408\u8ba1<\/span><\/p>\n

        \u548c DeepSeek \u63a7\u5236\u53f0\u5bf9\u6bd4\u65f6\u6ce8\u610f\u53e3\u5f84：\u63a7\u5236\u53f0\u6309\u201c\u5355\u6b21 API \u8bf7\u6c42\u201d\u8ba1，\u6211\u4eec\u6309\u201c\u4e00\u8f6e\u7528\u6237\u63d0\u95ee\u201d\u8ba1，\u4e00\u8f6e\u901a\u5e38\u5305\u542b 3~5 \u6b21\u8bf7\u6c42，\u6240\u4ee5\u6211\u4eec\u7684\u6570\u5b57\u662f\u63a7\u5236\u53f0\u5355\u6761\u7684\u51e0\u500d，\u5c5e\u6b63\u5e38\u3002<\/p>\n

        \n

        \"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"<\/p>\n

        \"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"<\/p>\n

        9. \u9057\u7559<\/h3>\n\n#\u95ee\u9898\u5f71\u54cd<\/tr>\n\n\n\n\n\n\n
        1<\/td>\nusage \u7f3a\u5931\u65f6\u6309\u201c2 \u5b57\u7b26 \u2248 1 token\u201d\u4f30\u7b97<\/td>\n\u4e2d\u6587\u7565\u504f\u4f4e<\/td>\n<\/tr>\n
        2<\/td>\nHermes \u957f\u4efb\u52a1\u4e0d\u56de\u4f20 usage<\/td>\n\u8be5\u90e8\u5206\u672a\u8ba1\u5165<\/td>\n<\/tr>\n
        3<\/td>\n\u5386\u53f2\u6d88\u606f\u4e0d\u4fdd\u5b58 usage<\/td>\n\u91cd\u65b0\u8fdb\u5165\u4f1a\u8bdd\u770b\u4e0d\u5230\u7528\u91cf（\u53ea\u5728\u5f53\u8f6e\u663e\u793a）<\/td>\n<\/tr>\n
        4<\/td>\n\u975e\u6d41\u5f0f\u63a5\u53e3（stream: false）\u672a\u8fd4\u56de usage<\/td>\n\u9700\u8981\u5355\u72ec\u63a5\u53e3\u6216\u6539\u5951\u7ea6<\/td>\n<\/tr>\n
        5<\/td>\n\u62a5\u8868\u5de5\u5177\u5931\u8d25\u65f6 success_result \u4e3a\u7a7a<\/td>\n\u6392\u67e5\u65f6\u53ea\u80fd\u770b FAIL_MSG_<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n
        \n

        10. \u9644：invoke_log_service.py \u5b8c\u6574\u4ee3\u7801<\/h3>\n

        #!\/usr\/bin\/env python<\/span>
        \n# -*- coding: utf-8 -*-<\/span>
        \n# @File : invoke_log_service.py<\/span>
        \n# @Desc : \u667a\u80fd\u4f53\u8c03\u7528\u65e5\u5fd7\u843d\u5e93\u670d\u52a1（MySQL）<\/span>
        \n# – \u4e00\u6b21\u7528\u6237\u8bf7\u6c42 = \u4e00\u4e2a TASK_BATCH，ai_invoke_log \u5199\u4e00\u6761\u201c\u4e3b\u7ba1\u667a\u80fd\u4f53\u201d\u6c47\u603b\u884c<\/span>
        \n# – \u6bcf\u6b21\u5de5\u5177\u6267\u884c（=\u4e00\u6b21\u5b50\u667a\u80fd\u4f53\u8c03\u7528）\u5404\u5199\u4e00\u6761 ai_invoke_log，\u6267\u884c\u5355\u5143\u4e3a\u5bf9\u5e94\u5b50\u667a\u80fd\u4f53<\/span>
        \n# – \u6bcf\u6761\u5b50\u667a\u80fd\u4f53\u884c\u518d\u5bf9\u5e94\u5199\u4e00\u6761 ai_tool_invoke_log \u5de5\u5177\u8c03\u7528\u660e\u7ec6<\/span>
        \n# – token \u7edf\u8ba1：\u4f18\u5148\u53d6\u5404\u6a21\u578b\u54cd\u5e94 usage，\u7f3a\u5931\u65f6\u6309\u5b57\u7b26\u6570\u4f30\u7b97（\u7ea6 2 \u5b57\u7b26 \u2248 1 token）<\/span>
        \n#<\/span>
        \n# \u901a\u8fc7 contextvar \u628a\u201c\u672c\u6b21\u8fd0\u884c\u7684\u65e5\u5fd7\u4e0a\u4e0b\u6587\u201d\u900f\u4f20\u7ed9\u7f16\u6392\u56fe\u5404\u8282\u70b9\u4e0e\u5de5\u5177\u7ebf\u7a0b，<\/span>
        \n# \u7ed3\u675f\u540e\u7edf\u4e00\u843d\u5e93，\u907f\u514d\u5728\u591a\u7ebf\u7a0b\/\u5f02\u6b65\u95f4\u624b\u5de5\u4f20\u9012\u5bf9\u8c61\u3002<\/span><\/p>\n

        import<\/span> asyncio
        \nimport<\/span> contextvars
        \nimport<\/span> threading
        \nimport<\/span> uuid
        \nfrom<\/span> datetime import<\/span> datetime
        \nfrom<\/span> typing import<\/span> Any,<\/span> Dict,<\/span> List,<\/span> Optional<\/p>\n

        from<\/span> loguru import<\/span> logger
        \nfrom<\/span> sqlalchemy import<\/span> text<\/p>\n

        from<\/span> app.<\/span>service.<\/span>system import<\/span> db_service,<\/span> token_quota_service<\/p>\n

        # \u8868\u540d（\u4e0e Java \u540e\u53f0 ai_invoke_log \/ ai_tool_invoke_log \u5bf9\u5e94，\u65e0 dzxx_ \u524d\u7f00）<\/span>
        \nTABLE_INVOKE_LOG =<\/span> "ai_invoke_log"<\/span>
        \nTABLE_TOOL_INVOKE_LOG =<\/span> "ai_tool_invoke_log"<\/span>
        \nTABLE_CHILD_AGENT =<\/span> "ai_child_agent"<\/span><\/p>\n

        # \u201c\u4e3b\u7ba1\u667a\u80fd\u4f53\u201d\u5728 ai_child_agent \u8868\u4e2d\u7684\u540d\u79f0（\u7528\u4e8e\u628a\u6c47\u603b\u884c\u5173\u8054\u5230\u6267\u884c\u5355\u5143）<\/span>
        \nSUPERVISOR_AGENT_NAME =<\/span> "\u4e3b\u7ba1\u667a\u80fd\u4f53"<\/span>
        \n# \u7f3a\u5931\u65f6\u81ea\u52a8\u8865\u4e00\u6761（\u56fa\u5b9a ID，\u4fbf\u4e8e\u8bc6\u522b\u662f\u7cfb\u7edf\u751f\u6210\u7684）<\/span>
        \nSUPERVISOR_AGENT_ID =<\/span> "agent_supervisor"<\/span><\/p>\n

        # 2 \u4e2a\u5b57\u7b26\u4f30\u7b97\u4e3a 1 \u4e2a token（\u4e2d\u6587\u573a\u666f\u7684\u7c97\u7565\u6298\u7b97）<\/span>
        \n_CHARS_PER_TOKEN =<\/span> 2<\/span><\/p>\n

        class<\/span> _RunLog<\/span>:<\/span>
        \n """\u4e00\u6b21\u667a\u80fd\u4f53\u8c03\u7528\u7684\u8fd0\u884c\u65e5\u5fd7\u4e0a\u4e0b\u6587"""<\/span><\/p>\n

        def<\/span> __init__<\/span>(<\/span>self,<\/span> user_id:<\/span> str<\/span>,<\/span> thread_id:<\/span> str<\/span>,<\/span> skill:<\/span> str<\/span>,<\/span> question:<\/span> str<\/span>)<\/span>:<\/span>
        \n self.<\/span>run_id =<\/span> uuid.<\/span>uuid4(<\/span>)<\/span>.<\/span>hex<\/span> # ai_invoke_log.ID_<\/span>
        \n self.<\/span>batch_id =<\/span> uuid.<\/span>uuid4(<\/span>)<\/span>.<\/span>hex<\/span> # TASK_BATCH_ID<\/span>
        \n self.<\/span>user_id =<\/span> user_id or<\/span> ""<\/span>
        \n self.<\/span>thread_id =<\/span> thread_id or<\/span> ""<\/span>
        \n self.<\/span>skill =<\/span> skill or<\/span> ""<\/span>
        \n self.<\/span>question =<\/span> (<\/span>question or<\/span> ""<\/span>)<\/span>[<\/span>:<\/span>1000<\/span>]<\/span> # USER_INPUT varchar(1000)<\/span>
        \n self.<\/span>started_dt =<\/span> datetime.<\/span>now(<\/span>)<\/span>
        \n self.<\/span>tools:<\/span> List[<\/span>Dict[<\/span>str<\/span>,<\/span> Any]<\/span>]<\/span> =<\/span> [<\/span>]<\/span> # \u5de5\u5177\u660e\u7ec6<\/span>
        \n self.<\/span>prompt_tokens =<\/span> 0<\/span>
        \n self.<\/span>completion_tokens =<\/span> 0<\/span>
        \n self.<\/span>lock =<\/span> threading.<\/span>Lock(<\/span>)<\/span>
        \n self.<\/span>error_message =<\/span> ""<\/span><\/p>\n

        def<\/span> add_tool<\/span>(<\/span>self,<\/span> event:<\/span> Dict[<\/span>str<\/span>,<\/span> Any]<\/span>)<\/span> –<\/span>><\/span> None<\/span>:<\/span>
        \n with<\/span> self.<\/span>lock:<\/span>
        \n self.<\/span>tools.<\/span>append(<\/span>event)<\/span><\/p>\n

        def<\/span> add_usage<\/span>(<\/span>self,<\/span> prompt:<\/span> Optional[<\/span>int<\/span>]<\/span> =<\/span> None<\/span>,<\/span> completion:<\/span> Optional[<\/span>int<\/span>]<\/span> =<\/span> None<\/span>)<\/span> –<\/span>><\/span> None<\/span>:<\/span>
        \n with<\/span> self.<\/span>lock:<\/span>
        \n if<\/span> prompt:<\/span>
        \n self.<\/span>prompt_tokens +=<\/span> int<\/span>(<\/span>prompt)<\/span>
        \n if<\/span> completion:<\/span>
        \n self.<\/span>completion_tokens +=<\/span> int<\/span>(<\/span>completion)<\/span><\/p>\n

        @property<\/span>
        \n def<\/span> total_tokens<\/span>(<\/span>self)<\/span> –<\/span>><\/span> int<\/span>:<\/span>
        \n return<\/span> self.<\/span>prompt_tokens +<\/span> self.<\/span>completion_tokens<\/p>\n

        _run_log_var:<\/span> contextvars.<\/span>ContextVar[<\/span>Optional[<\/span>_RunLog]<\/span>]<\/span> =<\/span> contextvars.<\/span>ContextVar(<\/span>"invoke_run_log"<\/span>,<\/span> default=<\/span>None<\/span>)<\/span><\/p>\n

        class<\/span> _ToolScope<\/span>:<\/span>
        \n """\u5355\u6b21\u5de5\u5177\u6267\u884c\u7684 token \u8ba1\u6570\u5668（\u7528\u4e8e\u628a\u7528\u91cf\u62c6\u5206\u5230\u5b50\u667a\u80fd\u4f53\u884c）"""<\/span><\/p>\n

        def<\/span> __init__<\/span>(<\/span>self,<\/span> tool_name:<\/span> str<\/span>)<\/span>:<\/span>
        \n self.<\/span>tool_name =<\/span> tool_name
        \n self.<\/span>prompt_tokens =<\/span> 0<\/span>
        \n self.<\/span>completion_tokens =<\/span> 0<\/span>
        \n self.<\/span>lock =<\/span> threading.<\/span>Lock(<\/span>)<\/span><\/p>\n

        def<\/span> add<\/span>(<\/span>self,<\/span> prompt:<\/span> Optional[<\/span>int<\/span>]<\/span> =<\/span> None<\/span>,<\/span> completion:<\/span> Optional[<\/span>int<\/span>]<\/span> =<\/span> None<\/span>)<\/span> –<\/span>><\/span> None<\/span>:<\/span>
        \n with<\/span> self.<\/span>lock:<\/span>
        \n if<\/span> prompt:<\/span>
        \n self.<\/span>prompt_tokens +=<\/span> int<\/span>(<\/span>prompt)<\/span>
        \n if<\/span> completion:<\/span>
        \n self.<\/span>completion_tokens +=<\/span> int<\/span>(<\/span>completion)<\/span><\/p>\n

        @property<\/span>
        \n def<\/span> total_tokens<\/span>(<\/span>self)<\/span> –<\/span>><\/span> int<\/span>:<\/span>
        \n return<\/span> self.<\/span>prompt_tokens +<\/span> self.<\/span>completion_tokens<\/p>\n

        # \u5f53\u524d\u7ebf\u7a0b\/\u4efb\u52a1\u6b63\u5728\u6267\u884c\u7684\u5de5\u5177\u4f5c\u7528\u57df；\u5e76\u884c\u5de5\u5177\u5404\u81ea\u5728\u72ec\u7acb\u7ebf\u7a0b\u4e0a\u4e0b\u6587\u91cc，\u4e92\u4e0d\u5e72\u6270<\/span>
        \n_tool_scope_var:<\/span> contextvars.<\/span>ContextVar[<\/span>Optional[<\/span>_ToolScope]<\/span>]<\/span> =<\/span> contextvars.<\/span>ContextVar(<\/span>"invoke_tool_scope"<\/span>,<\/span> default=<\/span>None<\/span>)<\/span><\/p>\n

        _supervisor_id_cache:<\/span> Optional[<\/span>str<\/span>]<\/span> =<\/span> None<\/span>
        \n_supervisor_id_lock =<\/span> threading.<\/span>Lock(<\/span>)<\/span><\/p>\n

        # \u5b50\u667a\u80fd\u4f53（\u6309\u5de5\u5177\u5c55\u793a\u540d\/\u5de5\u5177\u540d）ID \u89e3\u6790\u7f13\u5b58：name -> ID_（'' \u8868\u793a\u672a\u5339\u914d）<\/span>
        \n_child_agent_id_cache:<\/span> Dict[<\/span>str<\/span>,<\/span> str<\/span>]<\/span> =<\/span> {<\/span>}<\/span>
        \n_child_agent_id_lock =<\/span> threading.<\/span>Lock(<\/span>)<\/span><\/p>\n

        # =============================================================================<\/span>
        \n# \u8fd0\u884c\u4e0a\u4e0b\u6587\u7ba1\u7406<\/span>
        \n# =============================================================================<\/span><\/p>\n

        def<\/span> begin_run<\/span>(<\/span>user_id:<\/span> str<\/span> =<\/span> ""<\/span>,<\/span> thread_id:<\/span> str<\/span> =<\/span> ""<\/span>,<\/span> skill:<\/span> str<\/span> =<\/span> ""<\/span>,<\/span> question:<\/span> str<\/span> =<\/span> ""<\/span>)<\/span> –<\/span>><\/span> _RunLog:<\/span>
        \n """\u5f00\u542f\u4e00\u6b21\u667a\u80fd\u4f53\u8c03\u7528\u65e5\u5fd7\u4e0a\u4e0b\u6587（\u6bcf\u4e2a\u8bf7\u6c42\u4e00\u6b21）"""<\/span>
        \n run_log =<\/span> _RunLog(<\/span>user_id,<\/span> thread_id,<\/span> skill,<\/span> question)<\/span>
        \n _run_log_var.<\/span>set<\/span>(<\/span>run_log)<\/span>
        \n return<\/span> run_log<\/p>\n

        def<\/span> current<\/span>(<\/span>)<\/span> –<\/span>><\/span> Optional[<\/span>_RunLog]<\/span>:<\/span>
        \n """\u83b7\u53d6\u5f53\u524d\u8bf7\u6c42\u7684\u65e5\u5fd7\u4e0a\u4e0b\u6587（\u56fe\u8282\u70b9\/\u5de5\u5177\u7ebf\u7a0b\u5185\u8c03\u7528）"""<\/span>
        \n return<\/span> _run_log_var.<\/span>get(<\/span>)<\/span><\/p>\n

        def<\/span> reset_run<\/span>(<\/span>)<\/span> –<\/span>><\/span> None<\/span>:<\/span>
        \n """\u8bf7\u6c42\u7ed3\u675f\u540e\u6e05\u7406\u4e0a\u4e0b\u6587"""<\/span>
        \n _run_log_var.<\/span>set<\/span>(<\/span>None<\/span>)<\/span><\/p>\n

        def<\/span> begin_tool_scope<\/span>(<\/span>tool_name:<\/span> str<\/span>)<\/span>:<\/span>
        \n """\u8fdb\u5165\u4e00\u6b21\u5de5\u5177\u6267\u884c\u7684\u4f5c\u7528\u57df（\u8fd4\u56de\u7528\u4e8e end_tool_scope \u7684 token）"""<\/span>
        \n return<\/span> _tool_scope_var.<\/span>set<\/span>(<\/span>_ToolScope(<\/span>tool_name)<\/span>)<\/span><\/p>\n

        def<\/span> end_tool_scope<\/span>(<\/span>scope_token)<\/span> –<\/span>><\/span> int<\/span>:<\/span>
        \n """
        \n \u9000\u51fa\u5de5\u5177\u4f5c\u7528\u57df\u5e76\u8fd4\u56de\u8be5\u5de5\u5177\u6d88\u8017\u7684 token\u3002<\/p>\n

        \u5fc5\u987b\u5728 finally \u4e2d\u8c03\u7528，\u4fdd\u8bc1\u5f02\u5e38\u8def\u5f84\u4e5f\u80fd\u51fa\u6808\u3002
        \n """<\/span>
        \n scope =<\/span> _tool_scope_var.<\/span>get(<\/span>)<\/span>
        \n _tool_scope_var.<\/span>reset(<\/span>scope_token)<\/span>
        \n return<\/span> scope.<\/span>total_tokens if<\/span> scope else<\/span> 0<\/span><\/p>\n

        # =============================================================================<\/span>
        \n# token \u7edf\u8ba1\u8f85\u52a9（\u4f9b\u5404 LLM \u8c03\u7528\u70b9\u4f7f\u7528）<\/span>
        \n# =============================================================================<\/span><\/p>\n

        def<\/span> _estimate_tokens<\/span>(<\/span>text:<\/span> Any)<\/span> –<\/span>><\/span> int<\/span>:<\/span>
        \n text =<\/span> ""<\/span> if<\/span> text is<\/span> None<\/span> else<\/span> str<\/span>(<\/span>text)<\/span>
        \n return<\/span> max<\/span>(<\/span>1<\/span>,<\/span> (<\/span>len<\/span>(<\/span>text)<\/span> +<\/span> _CHARS_PER_TOKEN –<\/span> 1<\/span>)<\/span> \/\/<\/span> _CHARS_PER_TOKEN)<\/span><\/p>\n

        def<\/span> record_usage<\/span>(<\/span>prompt_tokens:<\/span> Optional[<\/span>int<\/span>]<\/span> =<\/span> None<\/span>,<\/span> completion_tokens:<\/span> Optional[<\/span>int<\/span>]<\/span> =<\/span> None<\/span>)<\/span> –<\/span>><\/span> None<\/span>:<\/span>
        \n """\u628a\u6a21\u578b\u8fd4\u56de\u7684 usage \u8ba1\u5165\u5f53\u524d\u8fd0\u884c（usage \u5b57\u6bb5\u7f3a\u5931\u65f6\u8c03\u7528\u65b9\u4f20 None，\u5219\u4e0d\u4f1a\u7d2f\u52a0）"""<\/span>
        \n run_log =<\/span> current(<\/span>)<\/span>
        \n if<\/span> run_log is<\/span> None<\/span>:<\/span>
        \n return<\/span>
        \n run_log.<\/span>add_usage(<\/span>prompt_tokens,<\/span> completion_tokens)<\/span>
        \n # \u540c\u6b65\u8ba1\u5165\u5f53\u524d\u5de5\u5177\u4f5c\u7528\u57df，\u4fbf\u4e8e\u6309\u5b50\u667a\u80fd\u4f53\u62c6\u5206\u7edf\u8ba1<\/span>
        \n scope =<\/span> _tool_scope_var.<\/span>get(<\/span>)<\/span>
        \n if<\/span> scope is<\/span> not<\/span> None<\/span>:<\/span>
        \n scope.<\/span>add(<\/span>prompt_tokens,<\/span> completion_tokens)<\/span><\/p>\n

        def<\/span> record_text_estimate<\/span>(<\/span>prompt_messages:<\/span> List[<\/span>Dict[<\/span>str<\/span>,<\/span> Any]<\/span>]<\/span>,<\/span> answer_text:<\/span> Any)<\/span> –<\/span>><\/span> None<\/span>:<\/span>
        \n """\u6a21\u578b\u672a\u8fd4\u56de usage \u65f6\u6309\u5b57\u7b26\u4f30\u7b97 prompt\/completion token \u5e76\u8ba1\u5165"""<\/span>
        \n run_log =<\/span> current(<\/span>)<\/span>
        \n if<\/span> run_log is<\/span> None<\/span>:<\/span>
        \n return<\/span>
        \n prompt_text =<\/span> ""<\/span>
        \n for<\/span> msg in<\/span> prompt_messages or<\/span> [<\/span>]<\/span>:<\/span>
        \n content =<\/span> msg.<\/span>get(<\/span>"content"<\/span>)<\/span>
        \n if<\/span> isinstance<\/span>(<\/span>content,<\/span> str<\/span>)<\/span>:<\/span>
        \n prompt_text +=<\/span> content
        \n prompt =<\/span> _estimate_tokens(<\/span>prompt_text)<\/span>
        \n completion =<\/span> _estimate_tokens(<\/span>answer_text)<\/span>
        \n record_usage(<\/span>prompt,<\/span> completion)<\/span><\/p>\n

        def<\/span> record_model_response<\/span>(<\/span>resp:<\/span> Any,<\/span> prompt_messages:<\/span> List[<\/span>Dict[<\/span>str<\/span>,<\/span> Any]<\/span>]<\/span>,<\/span> answer_text:<\/span> Any)<\/span> –<\/span>><\/span> None<\/span>:<\/span>
        \n """
        \n \u7edf\u4e00\u7684\u6a21\u578b\u54cd\u5e94 token \u8bb0\u8d26\u5165\u53e3：
        \n \u4f18\u5148\u4f7f\u7528 resp.usage（OpenAI \u517c\u5bb9\u54cd\u5e94\u5bf9\u8c61），\u7f3a\u5931\u65f6\u6309\u5b57\u7b26\u4f30\u7b97\u3002
        \n """<\/span>
        \n run_log =<\/span> current(<\/span>)<\/span>
        \n if<\/span> run_log is<\/span> None<\/span>:<\/span>
        \n return<\/span>
        \n usage =<\/span> getattr<\/span>(<\/span>resp,<\/span> "usage"<\/span>,<\/span> None<\/span>)<\/span>
        \n if<\/span> usage is<\/span> not<\/span> None<\/span>:<\/span>
        \n record_usage(<\/span>
        \n getattr<\/span>(<\/span>usage,<\/span> "prompt_tokens"<\/span>,<\/span> None<\/span>)<\/span>,<\/span>
        \n getattr<\/span>(<\/span>usage,<\/span> "completion_tokens"<\/span>,<\/span> None<\/span>)<\/span>,<\/span>
        \n )<\/span>
        \n else<\/span>:<\/span>
        \n record_text_estimate(<\/span>prompt_messages,<\/span> answer_text)<\/span><\/p>\n

        # =============================================================================<\/span>
        \n# \u843d\u5e93<\/span>
        \n# =============================================================================<\/span><\/p>\n

        def<\/span> _query_supervisor_agent_id<\/span>(<\/span>)<\/span> –<\/span>><\/span> Optional[<\/span>str<\/span>]<\/span>:<\/span>
        \n """\u67e5\u8be2\u201c\u4e3b\u7ba1\u667a\u80fd\u4f53\u201d\u5728 ai_child_agent \u4e2d\u7684 ID（\u8fdb\u7a0b\u5185\u7f13\u5b58；\u7f3a\u5931\u65f6\u81ea\u52a8\u8865\u4e00\u6761）"""<\/span>
        \n global<\/span> _supervisor_id_cache
        \n with<\/span> _supervisor_id_lock:<\/span>
        \n if<\/span> _supervisor_id_cache is<\/span> not<\/span> None<\/span>:<\/span>
        \n return<\/span> _supervisor_id_cache
        \n if<\/span> not<\/span> db_service.<\/span>is_configured(<\/span>)<\/span>:<\/span>
        \n return<\/span> None<\/span>
        \n try<\/span>:<\/span>
        \n # \u6ce8\u610f：PostgreSQL \u4f1a\u628a\u672a\u52a0\u5f15\u53f7\u7684\u5217\u540d\u8f6c\u4e3a\u5c0f\u5199，\u5fc5\u987b\u7528\u522b\u540d\u8bfb\u53d6，<\/span>
        \n # \u5426\u5219 row.get("ID_") \u6c38\u8fdc\u53d6\u4e0d\u5230\u503c（\u5386\u53f2 bug）<\/span>
        \n row =<\/span> db_service.<\/span>query_one(<\/span>
        \n f"SELECT ID_ AS agent_id FROM <\/span>{<\/span>TABLE_CHILD_AGENT}<\/span><\/span> "<\/span><\/span>
        \n "WHERE NAME = :name AND DELETED_ != 1 LIMIT 1"<\/span>,<\/span>
        \n {<\/span>"name"<\/span>:<\/span> SUPERVISOR_AGENT_NAME}<\/span>,<\/span>
        \n )<\/span>
        \n agent_id =<\/span> (<\/span>row or<\/span> {<\/span>}<\/span>)<\/span>.<\/span>get(<\/span>"agent_id"<\/span>)<\/span> or<\/span> ""<\/span>
        \n if<\/span> not<\/span> agent_id:<\/span>
        \n agent_id =<\/span> _create_supervisor_agent(<\/span>)<\/span> or<\/span> ""<\/span>
        \n _supervisor_id_cache =<\/span> agent_id or<\/span> None<\/span>
        \n except<\/span> Exception as<\/span> e:<\/span>
        \n logger.<\/span>warning(<\/span>f"[invoke_log] \u67e5\u8be2\u4e3b\u7ba1\u667a\u80fd\u4f53ID\u5931\u8d25: <\/span>{<\/span>e}<\/span><\/span>"<\/span><\/span>)<\/span>
        \n _supervisor_id_cache =<\/span> None<\/span>
        \n return<\/span> _supervisor_id_cache<\/p>\n

        def<\/span> _create_supervisor_agent<\/span>(<\/span>)<\/span> –<\/span>><\/span> Optional[<\/span>str<\/span>]<\/span>:<\/span>
        \n """ai_child_agent \u7f3a\u5c11\u201c\u4e3b\u7ba1\u667a\u80fd\u4f53\u201d\u65f6\u81ea\u52a8\u8865\u4e00\u6761（\u6c47\u603b\u884c\u9700\u8981\u5173\u8054\u5230\u5b83）"""<\/span>
        \n try<\/span>:<\/span>
        \n now =<\/span> datetime.<\/span>now(<\/span>)<\/span>
        \n with<\/span> db_service.<\/span>get_engine(<\/span>)<\/span>.<\/span>begin(<\/span>)<\/span> as<\/span> conn:<\/span>
        \n conn.<\/span>execute(<\/span>
        \n text(<\/span>
        \n f"INSERT INTO <\/span>{<\/span>TABLE_CHILD_AGENT}<\/span><\/span> "<\/span><\/span>
        \n "(ID_, NAME, CATEGORY, STATUS, DUTY, DELETED_, CREATE_TIME_, UPDATE_TIME_) "<\/span>
        \n "VALUES (:id, :name, 1, 1, '1', 0, :now, :now)"<\/span>
        \n )<\/span>,<\/span>
        \n {<\/span>"id"<\/span>:<\/span> SUPERVISOR_AGENT_ID,<\/span> "name"<\/span>:<\/span> SUPERVISOR_AGENT_NAME,<\/span> "now"<\/span>:<\/span> now}<\/span>,<\/span>
        \n )<\/span>
        \n logger.<\/span>info(<\/span>f"[invoke_log] \u5df2\u81ea\u52a8\u521b\u5efa\u300c<\/span>{<\/span>SUPERVISOR_AGENT_NAME}<\/span><\/span>\u300d\u8bb0\u5f55 id=<\/span>{<\/span>SUPERVISOR_AGENT_ID}<\/span><\/span>"<\/span><\/span>)<\/span>
        \n return<\/span> SUPERVISOR_AGENT_ID
        \n except<\/span> Exception as<\/span> e:<\/span>
        \n logger.<\/span>warning(<\/span>f"[invoke_log] \u81ea\u52a8\u521b\u5efa\u4e3b\u7ba1\u667a\u80fd\u4f53\u8bb0\u5f55\u5931\u8d25（\u6c47\u603b\u884c\u5c06\u4e0d\u5e26 agent_id）: <\/span>{<\/span>e}<\/span><\/span>"<\/span><\/span>)<\/span>
        \n return<\/span> None<\/span><\/p>\n

        def<\/span> _safe_text<\/span>(<\/span>value:<\/span> Any,<\/span> limit:<\/span> Optional[<\/span>int<\/span>]<\/span> =<\/span> None<\/span>)<\/span> –<\/span>><\/span> Optional[<\/span>str<\/span>]<\/span>:<\/span>
        \n if<\/span> value is<\/span> None<\/span>:<\/span>
        \n return<\/span> None<\/span>
        \n text =<\/span> str<\/span>(<\/span>value)<\/span>
        \n if<\/span> limit is<\/span> not<\/span> None<\/span> and<\/span> len<\/span>(<\/span>text)<\/span> ><\/span> limit:<\/span>
        \n text =<\/span> text[<\/span>:<\/span>limit]<\/span>
        \n return<\/span> text<\/p>\n

        def<\/span> _lookup_child_agent_id<\/span>(<\/span>names:<\/span> List[<\/span>str<\/span>]<\/span>)<\/span> –<\/span>><\/span> str<\/span>:<\/span>
        \n """\u6309\u540d\u79f0\u4f18\u5148\u7ea7\u89e3\u6790\u5b50\u667a\u80fd\u4f53\u5728 ai_child_agent \u4e2d\u7684 ID（\u5c55\u793a\u540d\u4f18\u5148，\u5176\u6b21\u5de5\u5177\u540d）"""<\/span>
        \n if<\/span> not<\/span> db_service.<\/span>is_configured(<\/span>)<\/span>:<\/span>
        \n return<\/span> ""<\/span>
        \n for<\/span> name in<\/span> names or<\/span> [<\/span>]<\/span>:<\/span>
        \n if<\/span> not<\/span> name:<\/span>
        \n continue<\/span>
        \n with<\/span> _child_agent_id_lock:<\/span>
        \n if<\/span> name in<\/span> _child_agent_id_cache:<\/span>
        \n return<\/span> _child_agent_id_cache.<\/span>get(<\/span>name,<\/span> ""<\/span>)<\/span>
        \n agent_id =<\/span> ""<\/span>
        \n try<\/span>:<\/span>
        \n # \u540c\u6837\u7528\u522b\u540d\u8bfb\u53d6，\u907f\u514d PostgreSQL \u5c0f\u5199\u5217\u540d\u5bfc\u81f4\u53d6\u4e0d\u5230\u503c<\/span>
        \n row =<\/span> db_service.<\/span>query_one(<\/span>
        \n f"SELECT ID_ AS agent_id FROM <\/span>{<\/span>TABLE_CHILD_AGENT}<\/span><\/span> "<\/span><\/span>
        \n "WHERE NAME = :name AND DELETED_ != 1 LIMIT 1"<\/span>,<\/span>
        \n {<\/span>"name"<\/span>:<\/span> name}<\/span>,<\/span>
        \n )<\/span>
        \n agent_id =<\/span> (<\/span>row or<\/span> {<\/span>}<\/span>)<\/span>.<\/span>get(<\/span>"agent_id"<\/span>)<\/span> or<\/span> ""<\/span>
        \n except<\/span> Exception as<\/span> e:<\/span>
        \n logger.<\/span>warning(<\/span>f"[invoke_log] \u67e5\u8be2\u5b50\u667a\u80fd\u4f53[<\/span>{<\/span>name}<\/span><\/span>]ID\u5931\u8d25: <\/span>{<\/span>e}<\/span><\/span>"<\/span><\/span>)<\/span>
        \n # \u53ea\u7f13\u5b58\u547d\u4e2d\u7ed3\u679c：\u672a\u547d\u4e2d\u4e0d\u7f13\u5b58，\u8865\u6570\u636e\u540e\u65e0\u9700\u91cd\u542f\u5373\u53ef\u751f\u6548<\/span>
        \n if<\/span> agent_id:<\/span>
        \n _child_agent_id_cache[<\/span>name]<\/span> =<\/span> agent_id
        \n else<\/span>:<\/span>
        \n logger.<\/span>warning(<\/span>f"[invoke_log] ai_child_agent \u4e2d\u672a\u627e\u5230\u540d\u79f0\u4e3a\u300c<\/span>{<\/span>name}<\/span><\/span>\u300d\u7684\u667a\u80fd\u4f53"<\/span><\/span>)<\/span>
        \n return<\/span> agent_id
        \n return<\/span> ""<\/span><\/p>\n

        def<\/span> _event_user_input<\/span>(<\/span>event:<\/span> Dict[<\/span>str<\/span>,<\/span> Any]<\/span>)<\/span> –<\/span>><\/span> str<\/span>:<\/span>
        \n """\u4ece\u5de5\u5177\u53c2\u6570\u4e2d\u63d0\u53d6\u7528\u4e8e USER_INPUT \u7684\u4efb\u52a1\u63cf\u8ff0（\u4f18\u5148 question\/query \u7b49\u5173\u952e\u53c2\u6570）"""<\/span>
        \n args =<\/span> event.<\/span>get(<\/span>"args"<\/span>)<\/span>
        \n if<\/span> isinstance<\/span>(<\/span>args,<\/span> dict<\/span>)<\/span>:<\/span>
        \n for<\/span> key in<\/span> (<\/span>"question"<\/span>,<\/span> "query"<\/span>,<\/span> "company_name"<\/span>,<\/span> "city"<\/span>,<\/span> "date_str"<\/span>,<\/span> "datetime"<\/span>,<\/span> "date"<\/span>,<\/span> "content"<\/span>)<\/span>:<\/span>
        \n value =<\/span> args.<\/span>get(<\/span>key)<\/span>
        \n if<\/span> value is<\/span> not<\/span> None<\/span> and<\/span> str<\/span>(<\/span>value)<\/span>.<\/span>strip(<\/span>)<\/span>:<\/span>
        \n return<\/span> str<\/span>(<\/span>value)<\/span>[<\/span>:<\/span>1000<\/span>]<\/span>
        \n return<\/span> _safe_text(<\/span>event.<\/span>get(<\/span>"tool_params"<\/span>)<\/span>,<\/span> 500<\/span>)<\/span> or<\/span> ""<\/span><\/p>\n

        def<\/span> _do_finalize<\/span>(<\/span>run_log:<\/span> _RunLog,<\/span> success:<\/span> bool<\/span>,<\/span> answer:<\/span> str<\/span>,<\/span> fail_msg:<\/span> str<\/span> =<\/span> ""<\/span>)<\/span> –<\/span>><\/span> None<\/span>:<\/span>
        \n """\u628a\u672c\u6b21\u8fd0\u884c\u7684\u6c47\u603b\u884c\u4e0e\u5de5\u5177\u660e\u7ec6\u884c\u5199\u5165 MySQL（\u5728 to_thread \u4e2d\u6267\u884c）"""<\/span>
        \n if<\/span> not<\/span> db_service.<\/span>is_configured(<\/span>)<\/span>:<\/span>
        \n return<\/span>
        \n try<\/span>:<\/span>
        \n end_dt =<\/span> datetime.<\/span>now(<\/span>)<\/span>
        \n cost_time =<\/span> round<\/span>(<\/span>(<\/span>end_dt –<\/span> run_log.<\/span>started_dt)<\/span>.<\/span>total_seconds(<\/span>)<\/span>,<\/span> 6<\/span>)<\/span><\/p>\n

        supervisor_agent_id =<\/span> _query_supervisor_agent_id(<\/span>)<\/span><\/p>\n

        with<\/span> db_service.<\/span>get_engine(<\/span>)<\/span>.<\/span>begin(<\/span>)<\/span> as<\/span> conn:<\/span>
        \n # 1) ai_invoke_log \u6c47\u603b\u884c（\u4e3b\u7ba1\u667a\u80fd\u4f53）<\/span>
        \n conn.<\/span>execute(<\/span>
        \n text(<\/span>text_insert_invoke(<\/span>)<\/span>)<\/span>,<\/span>
        \n {<\/span>
        \n "id"<\/span>:<\/span> run_log.<\/span>run_id,<\/span>
        \n "thread_id"<\/span>:<\/span> _safe_text(<\/span>run_log.<\/span>thread_id,<\/span> 64<\/span>)<\/span> or<\/span> ""<\/span>,<\/span>
        \n "task_batch_id"<\/span>:<\/span> run_log.<\/span>batch_id,<\/span>
        \n "child_agent_id"<\/span>:<\/span> supervisor_agent_id or<\/span> ""<\/span>,<\/span>
        \n "user_input"<\/span>:<\/span> run_log.<\/span>question,<\/span>
        \n "tool_invoke_count"<\/span>:<\/span> len<\/span>(<\/span>run_log.<\/span>tools)<\/span>,<\/span>
        \n "status"<\/span>:<\/span> 1<\/span> if<\/span> success else<\/span> –<\/span>1<\/span>,<\/span>
        \n "cost_time"<\/span>:<\/span> cost_time,<\/span>
        \n "cost_token"<\/span>:<\/span> run_log.<\/span>total_tokens,<\/span>
        \n "fail_msg"<\/span>:<\/span> _safe_text(<\/span>fail_msg,<\/span> 500<\/span>)<\/span>,<\/span>
        \n "success_result"<\/span>:<\/span> _safe_text(<\/span>answer)<\/span> if<\/span> success else<\/span> None<\/span>,<\/span>
        \n "skill_id"<\/span>:<\/span> _safe_text(<\/span>run_log.<\/span>skill,<\/span> 64<\/span>)<\/span>,<\/span>
        \n "tenant_id"<\/span>:<\/span> ""<\/span>,<\/span>
        \n "create_dep_id"<\/span>:<\/span> ""<\/span>,<\/span>
        \n "create_by"<\/span>:<\/span> _safe_text(<\/span>run_log.<\/span>user_id,<\/span> 64<\/span>)<\/span> or<\/span> ""<\/span>,<\/span>
        \n "create_time"<\/span>:<\/span> run_log.<\/span>started_dt,<\/span>
        \n "update_by"<\/span>:<\/span> _safe_text(<\/span>run_log.<\/span>user_id,<\/span> 64<\/span>)<\/span> or<\/span> ""<\/span>,<\/span>
        \n "update_time"<\/span>:<\/span> end_dt,<\/span>
        \n }<\/span>,<\/span>
        \n )<\/span><\/p>\n

        # 2) \u6bcf\u4e2a\u5b50\u667a\u80fd\u4f53（\u6bcf\u6b21\u5de5\u5177\u6267\u884c）\u5404\u5199\u4e00\u6761 ai_invoke_log，\u5e76\u628a\u5de5\u5177\u660e\u7ec6\u5173\u8054\u5230\u8be5\u884c<\/span>
        \n for<\/span> event in<\/span> run_log.<\/span>tools:<\/span>
        \n child_invoke_id =<\/span> uuid.<\/span>uuid4(<\/span>)<\/span>.<\/span>hex<\/span>
        \n child_agent_id =<\/span> _lookup_child_agent_id(<\/span>[<\/span>
        \n event.<\/span>get(<\/span>"display_name"<\/span>)<\/span>,<\/span>
        \n event.<\/span>get(<\/span>"tool_name"<\/span>)<\/span>,<\/span>
        \n ]<\/span>)<\/span>
        \n event_ok =<\/span> event.<\/span>get(<\/span>"status"<\/span>,<\/span> 1<\/span>)<\/span> ==<\/span> 1<\/span>
        \n conn.<\/span>execute(<\/span>
        \n text(<\/span>text_insert_invoke(<\/span>)<\/span>)<\/span>,<\/span>
        \n {<\/span>
        \n "id"<\/span>:<\/span> child_invoke_id,<\/span>
        \n "thread_id"<\/span>:<\/span> _safe_text(<\/span>run_log.<\/span>thread_id,<\/span> 64<\/span>)<\/span> or<\/span> ""<\/span>,<\/span>
        \n "task_batch_id"<\/span>:<\/span> run_log.<\/span>batch_id,<\/span>
        \n "child_agent_id"<\/span>:<\/span> child_agent_id,<\/span>
        \n "user_input"<\/span>:<\/span> _event_user_input(<\/span>event)<\/span>,<\/span>
        \n "tool_invoke_count"<\/span>:<\/span> 1<\/span>,<\/span>
        \n "status"<\/span>:<\/span> event.<\/span>get(<\/span>"status"<\/span>,<\/span> 1<\/span>)<\/span>,<\/span>
        \n "cost_time"<\/span>:<\/span> event.<\/span>get(<\/span>"cost_time"<\/span>)<\/span> or<\/span> 0<\/span>,<\/span>
        \n "cost_token"<\/span>:<\/span> int<\/span>(<\/span>event.<\/span>get(<\/span>"tokens"<\/span>)<\/span> or<\/span> 0<\/span>)<\/span>,<\/span>
        \n "fail_msg"<\/span>:<\/span> _safe_text(<\/span>event.<\/span>get(<\/span>"fail_msg"<\/span>)<\/span>,<\/span> 500<\/span>)<\/span>,<\/span>
        \n "success_result"<\/span>:<\/span> _safe_text(<\/span>event.<\/span>get(<\/span>"success_result"<\/span>)<\/span>)<\/span> if<\/span> event_ok else<\/span> None<\/span>,<\/span>
        \n "skill_id"<\/span>:<\/span> _safe_text(<\/span>run_log.<\/span>skill,<\/span> 64<\/span>)<\/span>,<\/span>
        \n "tenant_id"<\/span>:<\/span> ""<\/span>,<\/span>
        \n "create_dep_id"<\/span>:<\/span> ""<\/span>,<\/span>
        \n "create_by"<\/span>:<\/span> _safe_text(<\/span>run_log.<\/span>user_id,<\/span> 64<\/span>)<\/span> or<\/span> ""<\/span>,<\/span>
        \n "create_time"<\/span>:<\/span> event.<\/span>get(<\/span>"start_time"<\/span>)<\/span>,<\/span>
        \n "update_by"<\/span>:<\/span> _safe_text(<\/span>run_log.<\/span>user_id,<\/span> 64<\/span>)<\/span> or<\/span> ""<\/span>,<\/span>
        \n "update_time"<\/span>:<\/span> event.<\/span>get(<\/span>"end_time"<\/span>)<\/span>,<\/span>
        \n }<\/span>,<\/span>
        \n )<\/span><\/p>\n

        # 3) \u5b50\u667a\u80fd\u4f53\u884c\u5bf9\u5e94\u7684\u5de5\u5177\u8c03\u7528\u660e\u7ec6<\/span>
        \n display_name =<\/span> event.<\/span>get(<\/span>"display_name"<\/span>)<\/span> or<\/span> event.<\/span>get(<\/span>"tool_name"<\/span>)<\/span> or<\/span> ""<\/span>
        \n conn.<\/span>execute(<\/span>
        \n text(<\/span>text_insert_tool(<\/span>)<\/span>)<\/span>,<\/span>
        \n {<\/span>
        \n "id"<\/span>:<\/span> uuid.<\/span>uuid4(<\/span>)<\/span>.<\/span>hex<\/span>,<\/span>
        \n "invoke_log_id"<\/span>:<\/span> child_invoke_id,<\/span>
        \n "tool_name"<\/span>:<\/span> _safe_text(<\/span>display_name,<\/span> 255<\/span>)<\/span> or<\/span> ""<\/span>,<\/span>
        \n "tool_params"<\/span>:<\/span> _safe_text(<\/span>event.<\/span>get(<\/span>"tool_params"<\/span>)<\/span>)<\/span>,<\/span>
        \n "start_time"<\/span>:<\/span> event.<\/span>get(<\/span>"start_time"<\/span>)<\/span>,<\/span>
        \n "end_time"<\/span>:<\/span> event.<\/span>get(<\/span>"end_time"<\/span>)<\/span>,<\/span>
        \n "cost_time"<\/span>:<\/span> event.<\/span>get(<\/span>"cost_time"<\/span>)<\/span> or<\/span> 0<\/span>,<\/span>
        \n "status"<\/span>:<\/span> event.<\/span>get(<\/span>"status"<\/span>,<\/span> 1<\/span>)<\/span>,<\/span>
        \n "success_result"<\/span>:<\/span> _safe_text(<\/span>event.<\/span>get(<\/span>"success_result"<\/span>)<\/span>)<\/span> if<\/span> event_ok else<\/span> None<\/span>,<\/span>
        \n "fail_msg"<\/span>:<\/span> _safe_text(<\/span>event.<\/span>get(<\/span>"fail_msg"<\/span>)<\/span>,<\/span> 2000<\/span>)<\/span>,<\/span>
        \n "create_by"<\/span>:<\/span> _safe_text(<\/span>run_log.<\/span>user_id,<\/span> 64<\/span>)<\/span> or<\/span> ""<\/span>,<\/span>
        \n "create_time"<\/span>:<\/span> event.<\/span>get(<\/span>"start_time"<\/span>)<\/span>,<\/span>
        \n "update_by"<\/span>:<\/span> _safe_text(<\/span>run_log.<\/span>user_id,<\/span> 64<\/span>)<\/span> or<\/span> ""<\/span>,<\/span>
        \n "update_time"<\/span>:<\/span> event.<\/span>get(<\/span>"end_time"<\/span>)<\/span>,<\/span>
        \n }<\/span>,<\/span>
        \n )<\/span><\/p>\n

        logger.<\/span>info(<\/span>
        \n f"[invoke_log] \u5df2\u5199\u5165\u8c03\u7528\u65e5\u5fd7 run_id=<\/span>{<\/span>run_log.<\/span>run_id}<\/span><\/span> batch=<\/span>{<\/span>run_log.<\/span>batch_id}<\/span><\/span> "<\/span><\/span>
        \n f"tools=<\/span>{<\/span>len<\/span>(<\/span>run_log.<\/span>tools)<\/span>}<\/span><\/span> tokens=<\/span>{<\/span>run_log.<\/span>total_tokens}<\/span><\/span> status=<\/span>{<\/span>'\u6210\u529f'<\/span> if<\/span> success else<\/span> '\u5931\u8d25'<\/span>}<\/span><\/span>"<\/span><\/span>
        \n )<\/span><\/p>\n

        # \u7d2f\u52a0\u5f53\u5929\u666e\u901a\u5bf9\u8bdd\u989d\u5ea6（MCP \u8c03\u7528\u5728 MCP Server \u4fa7\u5355\u72ec\u7d2f\u52a0）<\/span>
        \n token_quota_service.<\/span>add_tokens(<\/span>run_log.<\/span>user_id,<\/span> run_log.<\/span>total_tokens,<\/span> "chat"<\/span>)<\/span>
        \n except<\/span> Exception as<\/span> e:<\/span>
        \n logger.<\/span>error(<\/span>f"[invoke_log] \u5199\u5165\u8c03\u7528\u65e5\u5fd7\u5931\u8d25: <\/span>{<\/span>e}<\/span><\/span>"<\/span><\/span>)<\/span><\/p>\n

        def<\/span> log_external_invoke<\/span>(<\/span>
        \n user_id:<\/span> str<\/span>,<\/span>
        \n question:<\/span> str<\/span>,<\/span>
        \n answer:<\/span> str<\/span>,<\/span>
        \n tokens:<\/span> int<\/span>,<\/span>
        \n source:<\/span> str<\/span> =<\/span> "mcp:knowledge-base"<\/span>,<\/span>
        \n success:<\/span> bool<\/span> =<\/span> True<\/span>,<\/span>
        \n fail_msg:<\/span> str<\/span> =<\/span> ""<\/span>,<\/span>
        \n)<\/span> –<\/span>><\/span> None<\/span>:<\/span>
        \n """
        \n \u8bb0\u5f55\u4e00\u6b21\u7531\u5916\u90e8\u5ba2\u6237\u7aef（MCP Server \/ \u7b2c\u4e09\u65b9\u7cfb\u7edf）\u53d1\u8d77\u7684\u8c03\u7528\u3002<\/p>\n

        \u4e0e\u5bf9\u8bdd\u94fe\u8def\u7684\u533a\u522b：\u6ca1\u6709\u4e3b\u7ba1\/\u5b50\u667a\u80fd\u4f53\u7f16\u6392，\u53ea\u843d\u4e00\u884c\u6c47\u603b\u65e5\u5fd7；
        \n SKILL_ID_ \u7528 mcp \u524d\u7f00\u6807\u8bb0，\u4fbf\u4e8e\u548c\u666e\u901a\u5bf9\u8bdd\u989d\u5ea6\u533a\u5206\u7edf\u8ba1\u3002
        \n """<\/span>
        \n if<\/span> not<\/span> db_service.<\/span>is_configured(<\/span>)<\/span>:<\/span>
        \n return<\/span><\/p>\n

        now =<\/span> datetime.<\/span>now(<\/span>)<\/span>
        \n try<\/span>:<\/span>
        \n with<\/span> db_service.<\/span>get_engine(<\/span>)<\/span>.<\/span>begin(<\/span>)<\/span> as<\/span> conn:<\/span>
        \n conn.<\/span>execute(<\/span>
        \n text(<\/span>text_insert_invoke(<\/span>)<\/span>)<\/span>,<\/span>
        \n {<\/span>
        \n "id"<\/span>:<\/span> uuid.<\/span>uuid4(<\/span>)<\/span>.<\/span>hex<\/span>,<\/span>
        \n "thread_id"<\/span>:<\/span> ""<\/span>,<\/span>
        \n "task_batch_id"<\/span>:<\/span> uuid.<\/span>uuid4(<\/span>)<\/span>.<\/span>hex<\/span>,<\/span>
        \n "child_agent_id"<\/span>:<\/span> ""<\/span>,<\/span>
        \n "user_input"<\/span>:<\/span> (<\/span>question or<\/span> ""<\/span>)<\/span>[<\/span>:<\/span>1000<\/span>]<\/span>,<\/span>
        \n "tool_invoke_count"<\/span>:<\/span> 1<\/span>,<\/span>
        \n "status"<\/span>:<\/span> 1<\/span> if<\/span> success else<\/span> –<\/span>1<\/span>,<\/span>
        \n "cost_time"<\/span>:<\/span> 0<\/span>,<\/span>
        \n "cost_token"<\/span>:<\/span> int<\/span>(<\/span>tokens or<\/span> 0<\/span>)<\/span>,<\/span>
        \n "fail_msg"<\/span>:<\/span> _safe_text(<\/span>fail_msg,<\/span> 500<\/span>)<\/span>,<\/span>
        \n "success_result"<\/span>:<\/span> _safe_text(<\/span>answer)<\/span> if<\/span> success else<\/span> None<\/span>,<\/span>
        \n "skill_id"<\/span>:<\/span> _safe_text(<\/span>source,<\/span> 64<\/span>)<\/span>,<\/span>
        \n "tenant_id"<\/span>:<\/span> ""<\/span>,<\/span>
        \n "create_dep_id"<\/span>:<\/span> ""<\/span>,<\/span>
        \n "create_by"<\/span>:<\/span> _safe_text(<\/span>user_id,<\/span> 64<\/span>)<\/span> or<\/span> "mcp"<\/span>,<\/span>
        \n "create_time"<\/span>:<\/span> now,<\/span>
        \n "update_by"<\/span>:<\/span> _safe_text(<\/span>user_id,<\/span> 64<\/span>)<\/span> or<\/span> "mcp"<\/span>,<\/span>
        \n "update_time"<\/span>:<\/span> now,<\/span>
        \n }<\/span>,<\/span>
        \n )<\/span>
        \n logger.<\/span>info(<\/span>
        \n f"[invoke_log] \u5df2\u5199\u5165\u5916\u90e8\u8c03\u7528\u65e5\u5fd7 source=<\/span>{<\/span>source}<\/span><\/span> user=<\/span>{<\/span>user_id or<\/span> 'mcp'<\/span>}<\/span><\/span> tokens=<\/span>{<\/span>tokens}<\/span><\/span>"<\/span><\/span>
        \n )<\/span>
        \n # \u53f0\u8d26\u5199\u6210\u529f\u540e\u518d\u7d2f\u52a0 MCP \u989d\u5ea6，\u907f\u514d\u65e5\u5fd7\u5931\u8d25\u65f6\u989d\u5ea6\u88ab\u591a\u6263<\/span>
        \n token_quota_service.<\/span>add_tokens(<\/span>user_id,<\/span> tokens,<\/span> "mcp"<\/span>)<\/span>
        \n except<\/span> Exception as<\/span> e:<\/span>
        \n logger.<\/span>error(<\/span>f"[invoke_log] \u5199\u5165\u5916\u90e8\u8c03\u7528\u65e5\u5fd7\u5931\u8d25: <\/span>{<\/span>e}<\/span><\/span>"<\/span><\/span>)<\/span><\/p>\n

        async<\/span> def<\/span> finalize_run<\/span>(<\/span>success:<\/span> bool<\/span>,<\/span> answer:<\/span> str<\/span> =<\/span> ""<\/span>,<\/span> fail_msg:<\/span> str<\/span> =<\/span> ""<\/span>)<\/span> –<\/span>><\/span> Optional[<\/span>Dict[<\/span>str<\/span>,<\/span> Any]<\/span>]<\/span>:<\/span>
        \n """
        \n \u5f02\u6b65\u6536\u5c3e：\u5728 to_thread \u4e2d\u6267\u884c\u843d\u5e93\u5e76\u6e05\u7406\u4e0a\u4e0b\u6587\u3002<\/p>\n

        Returns:
        \n \u672c\u6b21\u8fd0\u884c\u7684\u7528\u91cf\u6c47\u603b（\u4f9b\u4e0a\u5c42\u63a8\u9001\u7ed9\u524d\u7aef）；\u65e0\u8fd0\u884c\u4e0a\u4e0b\u6587\u65f6\u8fd4\u56de None
        \n """<\/span>
        \n run_log =<\/span> current(<\/span>)<\/span>
        \n if<\/span> run_log is<\/span> None<\/span>:<\/span>
        \n return<\/span> None<\/span><\/p>\n

        summary =<\/span> {<\/span>
        \n "promptTokens"<\/span>:<\/span> run_log.<\/span>prompt_tokens,<\/span>
        \n "completionTokens"<\/span>:<\/span> run_log.<\/span>completion_tokens,<\/span>
        \n "totalTokens"<\/span>:<\/span> run_log.<\/span>total_tokens,<\/span>
        \n "costMs"<\/span>:<\/span> int<\/span>(<\/span>(<\/span>datetime.<\/span>now(<\/span>)<\/span> –<\/span> run_log.<\/span>started_dt)<\/span>.<\/span>total_seconds(<\/span>)<\/span> *<\/span> 1000<\/span>)<\/span>,<\/span>
        \n "toolCount"<\/span>:<\/span> len<\/span>(<\/span>run_log.<\/span>tools)<\/span>,<\/span>
        \n }<\/span>
        \n try<\/span>:<\/span>
        \n await<\/span> asyncio.<\/span>to_thread(<\/span>_do_finalize,<\/span> run_log,<\/span> success,<\/span> answer,<\/span> fail_msg)<\/span>
        \n except<\/span> Exception as<\/span> e:<\/span>
        \n logger.<\/span>error(<\/span>f"[invoke_log] \u5f02\u6b65\u6536\u5c3e\u5931\u8d25: <\/span>{<\/span>e}<\/span><\/span>"<\/span><\/span>)<\/span>
        \n finally<\/span>:<\/span>
        \n reset_run(<\/span>)<\/span>
        \n return<\/span> summary<\/p>\n

        def<\/span> text_insert_invoke<\/span>(<\/span>)<\/span> –<\/span>><\/span> str<\/span>:<\/span>
        \n return<\/span> (<\/span>
        \n f"INSERT INTO <\/span>{<\/span>TABLE_INVOKE_LOG}<\/span><\/span> ("<\/span><\/span>
        \n "ID_, THREAD_ID, TASK_BATCH_ID, CHILD_AGENT_ID_, USER_INPUT, TOOL_INVOKE_COUNT, "<\/span>
        \n "STATUS, COST_TIME, COST_TOKEN, FAIL_MSG, SUCCESS_RESULT, SKILL_ID_, "<\/span>
        \n "TENANT_ID_, CREATE_DEP_ID_, CREATE_BY_, CREATE_TIME_, UPDATE_BY_, UPDATE_TIME_"<\/span>
        \n ") VALUES ("<\/span>
        \n ":id, :thread_id, :task_batch_id, :child_agent_id, :user_input, :tool_invoke_count, "<\/span>
        \n ":status, :cost_time, :cost_token, :fail_msg, :success_result, :skill_id, "<\/span>
        \n ":tenant_id, :create_dep_id, :create_by, :create_time, :update_by, :update_time"<\/span>
        \n ")"<\/span>
        \n )<\/span><\/p>\n

        def<\/span> text_insert_tool<\/span>(<\/span>)<\/span> –<\/span>><\/span> str<\/span>:<\/span>
        \n return<\/span> (<\/span>
        \n f"INSERT INTO <\/span>{<\/span>TABLE_TOOL_INVOKE_LOG}<\/span><\/span> ("<\/span><\/span>
        \n "ID_, AI_INVOKE_LOG_ID_, TOOL_NAME, TOOL_PARAMS, START_TIME, END_TIME, "<\/span>
        \n "COST_TIME, STATUS, SUCCESS_RESULT, FAIL_MSG, CREATE_BY_, CREATE_TIME_, UPDATE_BY_, UPDATE_TIME_"<\/span>
        \n ") VALUES ("<\/span>
        \n ":id, :invoke_log_id, :tool_name, :tool_params, :start_time, :end_time, "<\/span>
        \n ":cost_time, :status, :success_result, :fail_msg, :create_by, :create_time, :update_by, :update_time"<\/span>
        \n ")"<\/span>
        \n )<\/span><\/p>\n

        __all__ =<\/span> [<\/span>
        \n "begin_run"<\/span>,<\/span>
        \n "current"<\/span>,<\/span>
        \n "reset_run"<\/span>,<\/span>
        \n "begin_tool_scope"<\/span>,<\/span>
        \n "end_tool_scope"<\/span>,<\/span>
        \n "record_usage"<\/span>,<\/span>
        \n "record_text_estimate"<\/span>,<\/span>
        \n "record_model_response"<\/span>,<\/span>
        \n "finalize_run"<\/span>,<\/span>
        \n "log_external_invoke"<\/span>,<\/span>
        \n]<\/span><\/p>\n

        \n

        11. \u5c0f\u7ed3<\/h3>\n

        \u8fd9\u4e00\u7bc7\u4fee\u7684\u4e0d\u662f"\u52a0\u4e2a\u529f\u80fd"，\u800c\u662f\u628a\u7b2c 15 \u7bc7\u7559\u4e0b\u7684\u4e09\u5904\u786c\u4f24\u8865\u9f50：<\/p>\n\n\u4fee\u590d\u4ef7\u503c<\/tr>\n\n\n\n\n\n\n
        \u5de5\u5177\u4f5c\u7528\u57df\u53cc\u5199<\/td>\n\u4ece"\u53ea\u6709\u603b\u6570"\u53d8\u6210"\u80fd\u62c6\u5230\u6bcf\u4e2a\u5de5\u5177"<\/td>\n<\/tr>\n
        SELECT ID_ AS agent_id + \u81ea\u52a8\u8865\u5efa<\/td>\n\u6c47\u603b\u884c\u7ec8\u4e8e\u80fd\u5173\u8054\u6267\u884c\u5355\u5143，\u6309\u667a\u80fd\u4f53\u805a\u5408\u53ef\u7528<\/td>\n<\/tr>\n
        copy_context() + \u5168\u94fe\u8def\u8bb0\u8d26<\/td>\n\u5e76\u884c\u4e0d\u4e22\u8d26，\u53e3\u5f84\u8986\u76d6\u6240\u6709\u6a21\u578b\u8c03\u7528<\/td>\n<\/tr>\n
        finalize_run \u8fd4\u56de summary<\/td>\n\u524d\u7aef\u80fd\u62ff\u5230，\u4e14\u4e0e\u843d\u5e93\u4e00\u81f4<\/td>\n<\/tr>\n
        \u63d0\u793a\u8bcd\u89c4\u5219 + \u786c\u53bb\u91cd<\/td>\n\u6d88\u9664\u91cd\u590d\u68c0\u7d22，token \u76f4\u63a5\u964d 60%<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

        \u4e00\u53e5\u8bdd：token \u7edf\u8ba1\u7684\u53ef\u4fe1\u5ea6，\u53d6\u51b3\u4e8e"\u6bcf\u4e2a\u8c03\u7528\u70b9\u90fd\u8bb0\u8d26"\u548c"\u8bb0\u8d26\u4e0e\u5c55\u793a\u540c\u6e90"\u8fd9\u4e24\u4ef6\u4e8b，\u7f3a\u4e00\u4e2a\u6570\u5b57\u5c31\u4e0d\u53ef\u4fe1\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"

        \/* MD \/ \u5bcc\u6587\u672c\u4e2d\u7684 .toc\uff08\u542b\u535a\u5ba2\u56ed\u642c\u5bb6\u7b49\u5d4c\u5957\u7ed3\u6784\uff09\uff1b.toc-box \u5728\u4fa7\u680f\uff0c\u4e0d\u53d7\u5f71\u54cd *\/#content_views .toc,\/* \u7f16\u8f91\u5668\u5e38\u5728\u76ee\u5f55\u524d\u540e\u63d2\u5165\u7a7a p\uff08:empty \u4ecd\u5360 20px\uff09\uff0c\u4e00\u5e76\u53bb\u6389\u907f\u514d\u9876\u7a7a\u9699 *\/#content_views.markdown_views > p:empty:has(+ .toc),#content_views.markdown_views > .toc + p:empty,\/* \u5bcc\u6587\u672c\u65e7\u7248\u76ee\u5f55\u6807\u8bb0 *\/#content<\/p>\n","protected":false},"author":2,"featured_media":121045,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[11032,74,4119,1717,50],"topic":[],"class_list":["post-121047","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-11032","tag-agent","tag-rag","tag-token","tag-50"],"yoast_head":"\nAI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0830\uff09\uff1atoken \u6d88\u8017\u7edf\u8ba1\uff0c\u5e76\u5728\u6bcf\u8f6e\u5bf9\u8bdd\u7ed3\u675f\u540e\u5c55\u793a\u7ed9\u7528\u6237 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/121047.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0830\uff09\uff1atoken \u6d88\u8017\u7edf\u8ba1\uff0c\u5e76\u5728\u6bcf\u8f6e\u5bf9\u8bdd\u7ed3\u675f\u540e\u5c55\u793a\u7ed9\u7528\u6237 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\/* MD \/ \u5bcc\u6587\u672c\u4e2d\u7684 .toc\uff08\u542b\u535a\u5ba2\u56ed\u642c\u5bb6\u7b49\u5d4c\u5957\u7ed3\u6784\uff09\uff1b.toc-box \u5728\u4fa7\u680f\uff0c\u4e0d\u53d7\u5f71\u54cd *\/#content_views .toc,\/* \u7f16\u8f91\u5668\u5e38\u5728\u76ee\u5f55\u524d\u540e\u63d2\u5165\u7a7a p\uff08:empty \u4ecd\u5360 20px\uff09\uff0c\u4e00\u5e76\u53bb\u6389\u907f\u514d\u9876\u7a7a\u9699 *\/#content_views.markdown_views > p:empty:has(+ .toc),#content_views.markdown_views > .toc + p:empty,\/* \u5bcc\u6587\u672c\u65e7\u7248\u76ee\u5f55\u6807\u8bb0 *\/#content\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/121047.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-11-01T16:56:49+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261101165647-6ae76f4fbad75.png\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"19 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/121047.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/121047.html\",\"name\":\"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0830\uff09\uff1atoken \u6d88\u8017\u7edf\u8ba1\uff0c\u5e76\u5728\u6bcf\u8f6e\u5bf9\u8bdd\u7ed3\u675f\u540e\u5c55\u793a\u7ed9\u7528\u6237 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-11-01T16:56:49+00:00\",\"dateModified\":\"2026-11-01T16:56:49+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/121047.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/121047.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/121047.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0830\uff09\uff1atoken \u6d88\u8017\u7edf\u8ba1\uff0c\u5e76\u5728\u6bcf\u8f6e\u5bf9\u8bdd\u7ed3\u675f\u540e\u5c55\u793a\u7ed9\u7528\u6237\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0830\uff09\uff1atoken \u6d88\u8017\u7edf\u8ba1\uff0c\u5e76\u5728\u6bcf\u8f6e\u5bf9\u8bdd\u7ed3\u675f\u540e\u5c55\u793a\u7ed9\u7528\u6237 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/121047.html","og_locale":"zh_CN","og_type":"article","og_title":"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0830\uff09\uff1atoken \u6d88\u8017\u7edf\u8ba1\uff0c\u5e76\u5728\u6bcf\u8f6e\u5bf9\u8bdd\u7ed3\u675f\u540e\u5c55\u793a\u7ed9\u7528\u6237 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\/* MD \/ \u5bcc\u6587\u672c\u4e2d\u7684 .toc\uff08\u542b\u535a\u5ba2\u56ed\u642c\u5bb6\u7b49\u5d4c\u5957\u7ed3\u6784\uff09\uff1b.toc-box \u5728\u4fa7\u680f\uff0c\u4e0d\u53d7\u5f71\u54cd *\/#content_views .toc,\/* \u7f16\u8f91\u5668\u5e38\u5728\u76ee\u5f55\u524d\u540e\u63d2\u5165\u7a7a p\uff08:empty \u4ecd\u5360 20px\uff09\uff0c\u4e00\u5e76\u53bb\u6389\u907f\u514d\u9876\u7a7a\u9699 *\/#content_views.markdown_views > p:empty:has(+ .toc),#content_views.markdown_views > .toc + p:empty,\/* \u5bcc\u6587\u672c\u65e7\u7248\u76ee\u5f55\u6807\u8bb0 *\/#content","og_url":"https:\/\/www.wsisp.com\/helps\/121047.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-11-01T16:56:49+00:00","og_image":[{"url":"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261101165647-6ae76f4fbad75.png"}],"author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"19 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/121047.html","url":"https:\/\/www.wsisp.com\/helps\/121047.html","name":"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0830\uff09\uff1atoken \u6d88\u8017\u7edf\u8ba1\uff0c\u5e76\u5728\u6bcf\u8f6e\u5bf9\u8bdd\u7ed3\u675f\u540e\u5c55\u793a\u7ed9\u7528\u6237 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-11-01T16:56:49+00:00","dateModified":"2026-11-01T16:56:49+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/121047.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/121047.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/121047.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0830\uff09\uff1atoken \u6d88\u8017\u7edf\u8ba1\uff0c\u5e76\u5728\u6bcf\u8f6e\u5bf9\u8bdd\u7ed3\u675f\u540e\u5c55\u793a\u7ed9\u7528\u6237"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/121047","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=121047"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/121047\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media\/121045"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=121047"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=121047"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=121047"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=121047"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}