6.3 基于 FastAPI 的 FAQ 与知识库查询接口 2.html 83 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110
  1. <!doctype html>
  2. <html lang="zh" class="no-js">
  3. <head>
  4. <meta charset="utf-8">
  5. <meta name="viewport" content="width=device-width,initial-scale=1">
  6. <link rel="prev" href="6.2%20%E8%9E%8D%E5%90%88FAQ%20%E5%92%8C%E7%9F%A5%E8%AF%86%E5%BA%93%E6%9F%A5%E8%AF%A2%EF%BC%88%E4%BC%98%E5%8C%96%E7%89%88%EF%BC%89.html">
  7. <link rel="next" href="6.4%20FastAPI%E5%92%8CFlask%E7%9A%84%E5%8C%BA%E5%88%AB%E5%92%8C%E8%81%94%E7%B3%BB%28%E6%89%A9%E5%B1%95%E8%B5%84%E6%96%99%29.html">
  8. <link rel="icon" href="../img/AI.jpg">
  9. <meta name="generator" content="mkdocs-1.6.1, mkdocs-material-9.6.21">
  10. <title>6.3 基于 FastAPI 的 FAQ 与知识库查询接口 - 企业知识库RAG智能问答项目V1.0</title>
  11. <link rel="stylesheet" href="../assets/stylesheets/main.2a3383ac.min.css">
  12. <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin>
  13. <link rel="stylesheet" href="https://fonts.googleapis.com/css?family=Roboto:300,300i,400,400i,700,700i%7CRoboto+Mono:400,400i,700,700i&display=fallback">
  14. <style>:root{--md-text-font:"Roboto";--md-code-font:"Roboto Mono"}</style>
  15. <link rel="stylesheet" href="../stylesheets/extra.css">
  16. <script>__md_scope=new URL("..",location),__md_hash=e=>[...e].reduce(((e,_)=>(e<<5)-e+_.charCodeAt(0)),0),__md_get=(e,_=localStorage,t=__md_scope)=>JSON.parse(_.getItem(t.pathname+"."+e)),__md_set=(e,_,t=localStorage,a=__md_scope)=>{try{t.setItem(a.pathname+"."+e,JSON.stringify(_))}catch(e){}}</script>
  17. </head>
  18. <body dir="ltr">
  19. <input class="md-toggle" data-md-toggle="drawer" type="checkbox" id="__drawer" autocomplete="off">
  20. <input class="md-toggle" data-md-toggle="search" type="checkbox" id="__search" autocomplete="off">
  21. <label class="md-overlay" for="__drawer"></label>
  22. <div data-md-component="skip">
  23. <a href="#_1" class="md-skip">
  24. 跳转至
  25. </a>
  26. </div>
  27. <div data-md-component="announce">
  28. </div>
  29. <header class="md-header md-header--shadow" data-md-component="header">
  30. <nav class="md-header__inner md-grid" aria-label="页眉">
  31. <a href="../index.html" title="企业知识库RAG智能问答项目V1.0" class="md-header__button md-logo" aria-label="企业知识库RAG智能问答项目V1.0" data-md-component="logo">
  32. <img src="../img/AI.jpg" alt="logo">
  33. </a>
  34. <label class="md-header__button md-icon" for="__drawer">
  35. <svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 24 24"><path d="M3 6h18v2H3zm0 5h18v2H3zm0 5h18v2H3z"/></svg>
  36. </label>
  37. <div class="md-header__title" data-md-component="header-title">
  38. <div class="md-header__ellipsis">
  39. <div class="md-header__topic">
  40. <span class="md-ellipsis">
  41. 企业知识库RAG智能问答项目V1.0
  42. </span>
  43. </div>
  44. <div class="md-header__topic" data-md-component="header-topic">
  45. <span class="md-ellipsis">
  46. 6.3 基于 FastAPI 的 FAQ 与知识库查询接口
  47. </span>
  48. </div>
  49. </div>
  50. </div>
  51. <script>var palette=__md_get("__palette");if(palette&&palette.color){if("(prefers-color-scheme)"===palette.color.media){var media=matchMedia("(prefers-color-scheme: light)"),input=document.querySelector(media.matches?"[data-md-color-media='(prefers-color-scheme: light)']":"[data-md-color-media='(prefers-color-scheme: dark)']");palette.color.media=input.getAttribute("data-md-color-media"),palette.color.scheme=input.getAttribute("data-md-color-scheme"),palette.color.primary=input.getAttribute("data-md-color-primary"),palette.color.accent=input.getAttribute("data-md-color-accent")}for(var[key,value]of Object.entries(palette.color))document.body.setAttribute("data-md-color-"+key,value)}</script>
  52. <label class="md-header__button md-icon" for="__search">
  53. <svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 24 24"><path d="M9.5 3A6.5 6.5 0 0 1 16 9.5c0 1.61-.59 3.09-1.56 4.23l.27.27h.79l5 5-1.5 1.5-5-5v-.79l-.27-.27A6.52 6.52 0 0 1 9.5 16 6.5 6.5 0 0 1 3 9.5 6.5 6.5 0 0 1 9.5 3m0 2C7 5 5 7 5 9.5S7 14 9.5 14 14 12 14 9.5 12 5 9.5 5"/></svg>
  54. </label>
  55. <div class="md-search" data-md-component="search" role="dialog">
  56. <label class="md-search__overlay" for="__search"></label>
  57. <div class="md-search__inner" role="search">
  58. <form class="md-search__form" name="search">
  59. <input type="text" class="md-search__input" name="query" aria-label="搜索" placeholder="搜索" autocapitalize="off" autocorrect="off" autocomplete="off" spellcheck="false" data-md-component="search-query" required>
  60. <label class="md-search__icon md-icon" for="__search">
  61. <svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 24 24"><path d="M9.5 3A6.5 6.5 0 0 1 16 9.5c0 1.61-.59 3.09-1.56 4.23l.27.27h.79l5 5-1.5 1.5-5-5v-.79l-.27-.27A6.52 6.52 0 0 1 9.5 16 6.5 6.5 0 0 1 3 9.5 6.5 6.5 0 0 1 9.5 3m0 2C7 5 5 7 5 9.5S7 14 9.5 14 14 12 14 9.5 12 5 9.5 5"/></svg>
  62. <svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 24 24"><path d="M20 11v2H8l5.5 5.5-1.42 1.42L4.16 12l7.92-7.92L13.5 5.5 8 11z"/></svg>
  63. </label>
  64. <nav class="md-search__options" aria-label="查找">
  65. <button type="reset" class="md-search__icon md-icon" title="清空当前内容" aria-label="清空当前内容" tabindex="-1">
  66. <svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 24 24"><path d="M19 6.41 17.59 5 12 10.59 6.41 5 5 6.41 10.59 12 5 17.59 6.41 19 12 13.41 17.59 19 19 17.59 13.41 12z"/></svg>
  67. </button>
  68. </nav>
  69. </form>
  70. <div class="md-search__output">
  71. <div class="md-search__scrollwrap" tabindex="0" data-md-scrollfix>
  72. <div class="md-search-result" data-md-component="search-result">
  73. <div class="md-search-result__meta">
  74. 正在初始化搜索引擎
  75. </div>
  76. <ol class="md-search-result__list" role="presentation"></ol>
  77. </div>
  78. </div>
  79. </div>
  80. </div>
  81. </div>
  82. </nav>
  83. </header>
  84. <div class="md-container" data-md-component="container">
  85. <main class="md-main" data-md-component="main">
  86. <div class="md-main__inner md-grid">
  87. <div class="md-sidebar md-sidebar--primary" data-md-component="sidebar" data-md-type="navigation" >
  88. <div class="md-sidebar__scrollwrap">
  89. <div class="md-sidebar__inner">
  90. <nav class="md-nav md-nav--primary" aria-label="导航栏" data-md-level="0">
  91. <label class="md-nav__title" for="__drawer">
  92. <a href="../index.html" title="企业知识库RAG智能问答项目V1.0" class="md-nav__button md-logo" aria-label="企业知识库RAG智能问答项目V1.0" data-md-component="logo">
  93. <img src="../img/AI.jpg" alt="logo">
  94. </a>
  95. 企业知识库RAG智能问答项目V1.0
  96. </label>
  97. <ul class="md-nav__list" data-md-scrollfix>
  98. <li class="md-nav__item">
  99. <a href="../index.html" class="md-nav__link">
  100. <span class="md-ellipsis">
  101. 知识库内容
  102. </span>
  103. </a>
  104. </li>
  105. <li class="md-nav__item md-nav__item--nested">
  106. <input class="md-nav__toggle md-toggle " type="checkbox" id="__nav_2" >
  107. <label class="md-nav__link" for="__nav_2" id="__nav_2_label" tabindex="0">
  108. <span class="md-ellipsis">
  109. ① 项目概述
  110. </span>
  111. <span class="md-nav__icon md-icon"></span>
  112. </label>
  113. <nav class="md-nav" data-md-level="1" aria-labelledby="__nav_2_label" aria-expanded="false">
  114. <label class="md-nav__title" for="__nav_2">
  115. <span class="md-nav__icon md-icon"></span>
  116. ① 项目概述
  117. </label>
  118. <ul class="md-nav__list" data-md-scrollfix>
  119. <li class="md-nav__item">
  120. <a href="../%E2%91%A0%20%E9%A1%B9%E7%9B%AE%E6%A6%82%E8%BF%B0/1.1%20%E9%A1%B9%E7%9B%AE%E6%9E%B6%E6%9E%84.html" class="md-nav__link">
  121. <span class="md-ellipsis">
  122. 1.1 项目架构
  123. </span>
  124. </a>
  125. </li>
  126. <li class="md-nav__item">
  127. <a href="../%E2%91%A0%20%E9%A1%B9%E7%9B%AE%E6%A6%82%E8%BF%B0/1.2%20%E9%A1%B9%E7%9B%AE%E7%8E%AF%E5%A2%83%28window%29.html" class="md-nav__link">
  128. <span class="md-ellipsis">
  129. 1.2 项目环境(window)
  130. </span>
  131. </a>
  132. </li>
  133. <li class="md-nav__item">
  134. <a href="../%E2%91%A0%20%E9%A1%B9%E7%9B%AE%E6%A6%82%E8%BF%B0/1.3%20%E9%A1%B9%E7%9B%AE%E7%8E%AF%E5%A2%83%28mac%29.html" class="md-nav__link">
  135. <span class="md-ellipsis">
  136. 1.3 项目环境(mac)
  137. </span>
  138. </a>
  139. </li>
  140. </ul>
  141. </nav>
  142. </li>
  143. <li class="md-nav__item md-nav__item--nested">
  144. <input class="md-nav__toggle md-toggle " type="checkbox" id="__nav_3" >
  145. <label class="md-nav__link" for="__nav_3" id="__nav_3_label" tabindex="0">
  146. <span class="md-ellipsis">
  147. ② 项目工具
  148. </span>
  149. <span class="md-nav__icon md-icon"></span>
  150. </label>
  151. <nav class="md-nav" data-md-level="1" aria-labelledby="__nav_3_label" aria-expanded="false">
  152. <label class="md-nav__title" for="__nav_3">
  153. <span class="md-nav__icon md-icon"></span>
  154. ② 项目工具
  155. </label>
  156. <ul class="md-nav__list" data-md-scrollfix>
  157. <li class="md-nav__item">
  158. <a href="../%E2%91%A1%20%E9%A1%B9%E7%9B%AE%E5%B7%A5%E5%85%B7/2.1%20Ollama%E5%A4%A7%E6%A8%A1%E5%9E%8B%E9%AB%98%E6%95%88%E7%AE%A1%E7%90%86%E5%B7%A5%E5%85%B7.html" class="md-nav__link">
  159. <span class="md-ellipsis">
  160. 2.1 Ollama大模型高效管理工具
  161. </span>
  162. </a>
  163. </li>
  164. <li class="md-nav__item">
  165. <a href="../%E2%91%A1%20%E9%A1%B9%E7%9B%AE%E5%B7%A5%E5%85%B7/2.2%20LangChain%E5%9F%BA%E7%A1%80%E7%9F%A5%E8%AF%86.md.html" class="md-nav__link">
  166. <span class="md-ellipsis">
  167. 2.2 LangChain基础知识.md
  168. </span>
  169. </a>
  170. </li>
  171. <li class="md-nav__item">
  172. <a href="../%E2%91%A1%20%E9%A1%B9%E7%9B%AE%E5%B7%A5%E5%85%B7/2.3%20%E5%90%91%E9%87%8F%E7%B4%A2%E5%BC%95%EF%BC%9AHNSW%E3%80%81IVF%E4%B8%8EIVF_PQ.html" class="md-nav__link">
  173. <span class="md-ellipsis">
  174. 2.3 向量索引:HNSW、IVF与IVF_PQ
  175. </span>
  176. </a>
  177. </li>
  178. <li class="md-nav__item">
  179. <a href="../%E2%91%A1%20%E9%A1%B9%E7%9B%AE%E5%B7%A5%E5%85%B7/2.4%20Milvus%E5%90%91%E9%87%8F%E6%95%B0%E6%8D%AE%E5%BA%93.html" class="md-nav__link">
  180. <span class="md-ellipsis">
  181. 2.4 Milvus向量数据库
  182. </span>
  183. </a>
  184. </li>
  185. </ul>
  186. </nav>
  187. </li>
  188. <li class="md-nav__item md-nav__item--nested">
  189. <input class="md-nav__toggle md-toggle " type="checkbox" id="__nav_4" >
  190. <label class="md-nav__link" for="__nav_4" id="__nav_4_label" tabindex="0">
  191. <span class="md-ellipsis">
  192. ③ 基于Mysql库的问答系统
  193. </span>
  194. <span class="md-nav__icon md-icon"></span>
  195. </label>
  196. <nav class="md-nav" data-md-level="1" aria-labelledby="__nav_4_label" aria-expanded="false">
  197. <label class="md-nav__title" for="__nav_4">
  198. <span class="md-nav__icon md-icon"></span>
  199. ③ 基于Mysql库的问答系统
  200. </label>
  201. <ul class="md-nav__list" data-md-scrollfix>
  202. <li class="md-nav__item">
  203. <a href="../%E2%91%A2%20%E5%9F%BA%E4%BA%8EMysql%E5%BA%93%E7%9A%84%E9%97%AE%E7%AD%94%E7%B3%BB%E7%BB%9F/3.1%20Python%E6%97%A5%E5%BF%97%E4%BB%8B%E7%BB%8D%E4%B8%8E%E5%BA%94%E7%94%A8.html" class="md-nav__link">
  204. <span class="md-ellipsis">
  205. 3.1 Python日志介绍与应用
  206. </span>
  207. </a>
  208. </li>
  209. <li class="md-nav__item">
  210. <a href="../%E2%91%A2%20%E5%9F%BA%E4%BA%8EMysql%E5%BA%93%E7%9A%84%E9%97%AE%E7%AD%94%E7%B3%BB%E7%BB%9F/3.2%20Redis%E6%95%B0%E6%8D%AE%E5%BA%93%E7%AE%80%E4%BB%8B%E4%B8%8E%E4%BD%BF%E7%94%A8.html" class="md-nav__link">
  211. <span class="md-ellipsis">
  212. 3.2 Redis数据库简介与使用
  213. </span>
  214. </a>
  215. </li>
  216. <li class="md-nav__item">
  217. <a href="../%E2%91%A2%20%E5%9F%BA%E4%BA%8EMysql%E5%BA%93%E7%9A%84%E9%97%AE%E7%AD%94%E7%B3%BB%E7%BB%9F/3.3%20%E5%9F%BA%E4%BA%8EMysql%E6%95%B0%E6%8D%AE%E5%BA%93%E5%AE%9E%E7%8E%B0%E9%97%AE%E7%AD%94%E7%B3%BB%E7%BB%9F.html" class="md-nav__link">
  218. <span class="md-ellipsis">
  219. 3.3 基于Mysql数据库实现问答系统
  220. </span>
  221. </a>
  222. </li>
  223. <li class="md-nav__item">
  224. <a href="../%E2%91%A2%20%E5%9F%BA%E4%BA%8EMysql%E5%BA%93%E7%9A%84%E9%97%AE%E7%AD%94%E7%B3%BB%E7%BB%9F/3.4%20BM25%E7%AE%97%E6%B3%95%E7%AE%80%E4%BB%8B%E4%B8%8E%E5%BA%94%E7%94%A8.html" class="md-nav__link">
  225. <span class="md-ellipsis">
  226. 3.4 BM25算法简介与应用
  227. </span>
  228. </a>
  229. </li>
  230. </ul>
  231. </nav>
  232. </li>
  233. <li class="md-nav__item md-nav__item--nested">
  234. <input class="md-nav__toggle md-toggle " type="checkbox" id="__nav_5" >
  235. <label class="md-nav__link" for="__nav_5" id="__nav_5_label" tabindex="0">
  236. <span class="md-ellipsis">
  237. ④ 基于Milvus库的问答系统
  238. </span>
  239. <span class="md-nav__icon md-icon"></span>
  240. </label>
  241. <nav class="md-nav" data-md-level="1" aria-labelledby="__nav_5_label" aria-expanded="false">
  242. <label class="md-nav__title" for="__nav_5">
  243. <span class="md-nav__icon md-icon"></span>
  244. ④ 基于Milvus库的问答系统
  245. </label>
  246. <ul class="md-nav__list" data-md-scrollfix>
  247. <li class="md-nav__item">
  248. <a href="../%E2%91%A3%20%E5%9F%BA%E4%BA%8EMilvus%E5%BA%93%E7%9A%84%E9%97%AE%E7%AD%94%E7%B3%BB%E7%BB%9F/4.1%20%E6%95%B4%E4%BD%93%E6%9E%B6%E6%9E%84%E4%B8%8E%E5%B7%A5%E7%A8%8B%E6%B5%81%E7%A8%8B.html" class="md-nav__link">
  249. <span class="md-ellipsis">
  250. 4.1 整体架构与工程流程
  251. </span>
  252. </a>
  253. </li>
  254. <li class="md-nav__item">
  255. <a href="../%E2%91%A3%20%E5%9F%BA%E4%BA%8EMilvus%E5%BA%93%E7%9A%84%E9%97%AE%E7%AD%94%E7%B3%BB%E7%BB%9F/4.2%20%E5%9F%BA%E7%A1%80%E6%A8%A1%E5%9D%97.html" class="md-nav__link">
  256. <span class="md-ellipsis">
  257. 4.2 基础模块
  258. </span>
  259. </a>
  260. </li>
  261. <li class="md-nav__item">
  262. <a href="../%E2%91%A3%20%E5%9F%BA%E4%BA%8EMilvus%E5%BA%93%E7%9A%84%E9%97%AE%E7%AD%94%E7%B3%BB%E7%BB%9F/4.3%20%E6%96%87%E6%A1%A3%E5%A4%84%E7%90%86%E6%A8%A1%E5%9D%97.html" class="md-nav__link">
  263. <span class="md-ellipsis">
  264. 4.3 文档处理模块
  265. </span>
  266. </a>
  267. </li>
  268. <li class="md-nav__item">
  269. <a href="../%E2%91%A3%20%E5%9F%BA%E4%BA%8EMilvus%E5%BA%93%E7%9A%84%E9%97%AE%E7%AD%94%E7%B3%BB%E7%BB%9F/4.4%20%E5%90%91%E9%87%8F%E5%AD%98%E5%82%A8.html" class="md-nav__link">
  270. <span class="md-ellipsis">
  271. 4.4 向量存储
  272. </span>
  273. </a>
  274. </li>
  275. <li class="md-nav__item">
  276. <a href="../%E2%91%A3%20%E5%9F%BA%E4%BA%8EMilvus%E5%BA%93%E7%9A%84%E9%97%AE%E7%AD%94%E7%B3%BB%E7%BB%9F/4.5%20prompts%E8%AE%BE%E8%AE%A1%E4%B8%8Equery%E6%84%8F%E5%9B%BE%E8%AF%86%E5%88%AB.html" class="md-nav__link">
  277. <span class="md-ellipsis">
  278. 4.5 prompts设计与query意图识别
  279. </span>
  280. </a>
  281. </li>
  282. <li class="md-nav__item">
  283. <a href="../%E2%91%A3%20%E5%9F%BA%E4%BA%8EMilvus%E5%BA%93%E7%9A%84%E9%97%AE%E7%AD%94%E7%B3%BB%E7%BB%9F/4.6%20%E6%A3%80%E7%B4%A2%E7%AD%96%E7%95%A5%E4%B8%8ERAG%E7%B3%BB%E7%BB%9F%E8%AE%BE%E8%AE%A1.html" class="md-nav__link">
  284. <span class="md-ellipsis">
  285. 4.6 检索策略与RAG系统设计
  286. </span>
  287. </a>
  288. </li>
  289. <li class="md-nav__item">
  290. <a href="../%E2%91%A3%20%E5%9F%BA%E4%BA%8EMilvus%E5%BA%93%E7%9A%84%E9%97%AE%E7%AD%94%E7%B3%BB%E7%BB%9F/4.7%20RAG%E7%B3%BB%E7%BB%9F%E8%BF%90%E8%A1%8C.html" class="md-nav__link">
  291. <span class="md-ellipsis">
  292. 4.7 RAG系统运行
  293. </span>
  294. </a>
  295. </li>
  296. <li class="md-nav__item">
  297. <a href="../%E2%91%A3%20%E5%9F%BA%E4%BA%8EMilvus%E5%BA%93%E7%9A%84%E9%97%AE%E7%AD%94%E7%B3%BB%E7%BB%9F/4.8%20%E6%96%87%E6%A1%A3%E8%A7%A3%E6%9E%90%E5%B7%A5%E5%85%B7%28%E6%89%A9%E5%B1%95%E8%B5%84%E6%96%99%29.html" class="md-nav__link">
  298. <span class="md-ellipsis">
  299. 4.8 文档解析工具(扩展资料)
  300. </span>
  301. </a>
  302. </li>
  303. <li class="md-nav__item">
  304. <a href="../%E2%91%A3%20%E5%9F%BA%E4%BA%8EMilvus%E5%BA%93%E7%9A%84%E9%97%AE%E7%AD%94%E7%B3%BB%E7%BB%9F/4.9%20RAG%E4%B8%AD%E7%9A%84Query%E6%94%B9%E5%86%99%28%E6%89%A9%E5%B1%95%E8%B5%84%E6%96%99%29.html" class="md-nav__link">
  305. <span class="md-ellipsis">
  306. 4.9 RAG中的Query改写(扩展资料)
  307. </span>
  308. </a>
  309. </li>
  310. <li class="md-nav__item">
  311. <a href="../%E2%91%A3%20%E5%9F%BA%E4%BA%8EMilvus%E5%BA%93%E7%9A%84%E9%97%AE%E7%AD%94%E7%B3%BB%E7%BB%9F/%E6%95%B0%E6%8D%AE%E9%9B%86%E7%94%9F%E6%88%90%E4%B8%8E%E4%BC%98%E5%8C%96%28%E6%89%A9%E5%B1%95%E8%B5%84%E6%96%99%29.html" class="md-nav__link">
  312. <span class="md-ellipsis">
  313. 数据集生成与优化(扩展资料)
  314. </span>
  315. </a>
  316. </li>
  317. </ul>
  318. </nav>
  319. </li>
  320. <li class="md-nav__item md-nav__item--nested">
  321. <input class="md-nav__toggle md-toggle " type="checkbox" id="__nav_6" >
  322. <label class="md-nav__link" for="__nav_6" id="__nav_6_label" tabindex="0">
  323. <span class="md-ellipsis">
  324. ⑤ RAG系统评估
  325. </span>
  326. <span class="md-nav__icon md-icon"></span>
  327. </label>
  328. <nav class="md-nav" data-md-level="1" aria-labelledby="__nav_6_label" aria-expanded="false">
  329. <label class="md-nav__title" for="__nav_6">
  330. <span class="md-nav__icon md-icon"></span>
  331. ⑤ RAG系统评估
  332. </label>
  333. <ul class="md-nav__list" data-md-scrollfix>
  334. <li class="md-nav__item">
  335. <a href="../%E2%91%A4%20RAG%E7%B3%BB%E7%BB%9F%E8%AF%84%E4%BC%B0/5.1%20RAG%E7%B3%BB%E7%BB%9F%E8%AF%84%E4%BC%B0%E5%B7%A5%E5%85%B7.html" class="md-nav__link">
  336. <span class="md-ellipsis">
  337. 5.1 RAG系统评估工具
  338. </span>
  339. </a>
  340. </li>
  341. <li class="md-nav__item">
  342. <a href="../%E2%91%A4%20RAG%E7%B3%BB%E7%BB%9F%E8%AF%84%E4%BC%B0/5.2%20%E5%AE%9E%E7%8E%B0EnterpriseKB-RAG%E7%B3%BB%E7%BB%9F%E7%9A%84%E8%AF%84%E4%BC%B0.html" class="md-nav__link">
  343. <span class="md-ellipsis">
  344. 5.2 实现企业知识库RAG系统的评估
  345. </span>
  346. </a>
  347. </li>
  348. <li class="md-nav__item">
  349. <a href="../%E2%91%A4%20RAG%E7%B3%BB%E7%BB%9F%E8%AF%84%E4%BC%B0/5.3%20RAG%E8%AF%84%E4%BC%B0%E6%95%B0%E6%8D%AE%E9%9B%86%E7%9A%84%E6%9E%84%E9%80%A0%28%E6%89%A9%E5%B1%95%29.html" class="md-nav__link">
  350. <span class="md-ellipsis">
  351. 5.3 RAG评估数据集的构造(扩展)
  352. </span>
  353. </a>
  354. </li>
  355. </ul>
  356. </nav>
  357. </li>
  358. <li class="md-nav__item md-nav__item--active md-nav__item--nested">
  359. <input class="md-nav__toggle md-toggle " type="checkbox" id="__nav_7" checked>
  360. <label class="md-nav__link" for="__nav_7" id="__nav_7_label" tabindex="0">
  361. <span class="md-ellipsis">
  362. ⑥ 融合Mysql的RAG系统
  363. </span>
  364. <span class="md-nav__icon md-icon"></span>
  365. </label>
  366. <nav class="md-nav" data-md-level="1" aria-labelledby="__nav_7_label" aria-expanded="true">
  367. <label class="md-nav__title" for="__nav_7">
  368. <span class="md-nav__icon md-icon"></span>
  369. ⑥ 融合Mysql的RAG系统
  370. </label>
  371. <ul class="md-nav__list" data-md-scrollfix>
  372. <li class="md-nav__item">
  373. <a href="6.1%20%E8%9E%8D%E5%90%88FQA%E5%92%8C%E7%9F%A5%E8%AF%86%E5%BA%93%E6%9F%A5%E8%AF%A2.html" class="md-nav__link">
  374. <span class="md-ellipsis">
  375. 6.1 融合FQA和知识库查询
  376. </span>
  377. </a>
  378. </li>
  379. <li class="md-nav__item">
  380. <a href="6.2%20%E8%9E%8D%E5%90%88FAQ%20%E5%92%8C%E7%9F%A5%E8%AF%86%E5%BA%93%E6%9F%A5%E8%AF%A2%EF%BC%88%E4%BC%98%E5%8C%96%E7%89%88%EF%BC%89.html" class="md-nav__link">
  381. <span class="md-ellipsis">
  382. 6.2 融合FAQ 和知识库查询(优化版)
  383. </span>
  384. </a>
  385. </li>
  386. <li class="md-nav__item md-nav__item--active">
  387. <input class="md-nav__toggle md-toggle" type="checkbox" id="__toc">
  388. <label class="md-nav__link md-nav__link--active" for="__toc">
  389. <span class="md-ellipsis">
  390. 6.3 基于 FastAPI 的 FAQ 与知识库查询接口
  391. </span>
  392. <span class="md-nav__icon md-icon"></span>
  393. </label>
  394. <a href="6.3%20%E5%9F%BA%E4%BA%8E%20FastAPI%20%E7%9A%84%20FAQ%20%E4%B8%8E%E7%9F%A5%E8%AF%86%E5%BA%93%E6%9F%A5%E8%AF%A2%E6%8E%A5%E5%8F%A3.html" class="md-nav__link md-nav__link--active">
  395. <span class="md-ellipsis">
  396. 6.3 基于 FastAPI 的 FAQ 与知识库查询接口
  397. </span>
  398. </a>
  399. <nav class="md-nav md-nav--secondary" aria-label="目录">
  400. <label class="md-nav__title" for="__toc">
  401. <span class="md-nav__icon md-icon"></span>
  402. 目录
  403. </label>
  404. <ul class="md-nav__list" data-md-component="toc" data-md-scrollfix>
  405. <li class="md-nav__item">
  406. <a href="#_1" class="md-nav__link">
  407. <span class="md-ellipsis">
  408. 学习目标:
  409. </span>
  410. </a>
  411. </li>
  412. <li class="md-nav__item">
  413. <a href="#_2" class="md-nav__link">
  414. <span class="md-ellipsis">
  415. 一、查询流程图
  416. </span>
  417. </a>
  418. </li>
  419. <li class="md-nav__item">
  420. <a href="#_3" class="md-nav__link">
  421. <span class="md-ellipsis">
  422. 二、流程说明
  423. </span>
  424. </a>
  425. </li>
  426. <li class="md-nav__item">
  427. <a href="#_4" class="md-nav__link">
  428. <span class="md-ellipsis">
  429. 三、代码介绍
  430. </span>
  431. </a>
  432. <nav class="md-nav" aria-label="三、代码介绍">
  433. <ul class="md-nav__list">
  434. <li class="md-nav__item">
  435. <a href="#1" class="md-nav__link">
  436. <span class="md-ellipsis">
  437. 1 导入必备的工具包
  438. </span>
  439. </a>
  440. </li>
  441. <li class="md-nav__item">
  442. <a href="#2-fastapi" class="md-nav__link">
  443. <span class="md-ellipsis">
  444. 2 创建 FastAPI 应用并配置
  445. </span>
  446. </a>
  447. </li>
  448. <li class="md-nav__item">
  449. <a href="#3" class="md-nav__link">
  450. <span class="md-ellipsis">
  451. 3 定义日常问候模式
  452. </span>
  453. </a>
  454. </li>
  455. <li class="md-nav__item">
  456. <a href="#4" class="md-nav__link">
  457. <span class="md-ellipsis">
  458. 4 定义请求和响应模型
  459. </span>
  460. </a>
  461. </li>
  462. <li class="md-nav__item">
  463. <a href="#5" class="md-nav__link">
  464. <span class="md-ellipsis">
  465. 5 挂载静态文件服务
  466. </span>
  467. </a>
  468. </li>
  469. <li class="md-nav__item">
  470. <a href="#6" class="md-nav__link">
  471. <span class="md-ellipsis">
  472. 6 创建新会话
  473. </span>
  474. </a>
  475. </li>
  476. <li class="md-nav__item">
  477. <a href="#7" class="md-nav__link">
  478. <span class="md-ellipsis">
  479. 7 查询历史消息
  480. </span>
  481. </a>
  482. </li>
  483. <li class="md-nav__item">
  484. <a href="#8" class="md-nav__link">
  485. <span class="md-ellipsis">
  486. 8 清除历史消息
  487. </span>
  488. </a>
  489. </li>
  490. <li class="md-nav__item">
  491. <a href="#9" class="md-nav__link">
  492. <span class="md-ellipsis">
  493. 9 检查日常问候
  494. </span>
  495. </a>
  496. </li>
  497. <li class="md-nav__item">
  498. <a href="#10" class="md-nav__link">
  499. <span class="md-ellipsis">
  500. 10 非流式查询接口
  501. </span>
  502. </a>
  503. </li>
  504. <li class="md-nav__item">
  505. <a href="#11-websocket" class="md-nav__link">
  506. <span class="md-ellipsis">
  507. 11 流式查询 WebSocket 接口
  508. </span>
  509. </a>
  510. </li>
  511. <li class="md-nav__item">
  512. <a href="#12" class="md-nav__link">
  513. <span class="md-ellipsis">
  514. 12 健康检查接口
  515. </span>
  516. </a>
  517. </li>
  518. <li class="md-nav__item">
  519. <a href="#13" class="md-nav__link">
  520. <span class="md-ellipsis">
  521. 13 获取知识域
  522. </span>
  523. </a>
  524. </li>
  525. <li class="md-nav__item">
  526. <a href="#14-fastapi" class="md-nav__link">
  527. <span class="md-ellipsis">
  528. 14 启动 FastAPI 服务
  529. </span>
  530. </a>
  531. </li>
  532. </ul>
  533. </nav>
  534. </li>
  535. <li class="md-nav__item">
  536. <a href="#_5" class="md-nav__link">
  537. <span class="md-ellipsis">
  538. 章节小结
  539. </span>
  540. </a>
  541. </li>
  542. </ul>
  543. </nav>
  544. </li>
  545. <li class="md-nav__item">
  546. <a href="6.4%20FastAPI%E5%92%8CFlask%E7%9A%84%E5%8C%BA%E5%88%AB%E5%92%8C%E8%81%94%E7%B3%BB%28%E6%89%A9%E5%B1%95%E8%B5%84%E6%96%99%29.html" class="md-nav__link">
  547. <span class="md-ellipsis">
  548. 6.4 FastAPI和Flask的区别和联系(扩展资料)
  549. </span>
  550. </a>
  551. </li>
  552. </ul>
  553. </nav>
  554. </li>
  555. <li class="md-nav__item md-nav__item--nested">
  556. <input class="md-nav__toggle md-toggle " type="checkbox" id="__nav_8" >
  557. <label class="md-nav__link" for="__nav_8" id="__nav_8_label" tabindex="0">
  558. <span class="md-ellipsis">
  559. ⑦ 企业级生产环境部署
  560. </span>
  561. <span class="md-nav__icon md-icon"></span>
  562. </label>
  563. <nav class="md-nav" data-md-level="1" aria-labelledby="__nav_8_label" aria-expanded="false">
  564. <label class="md-nav__title" for="__nav_8">
  565. <span class="md-nav__icon md-icon"></span>
  566. ⑦ 企业级生产环境部署
  567. </label>
  568. <ul class="md-nav__list" data-md-scrollfix>
  569. <li class="md-nav__item">
  570. <a href="../%E2%91%A6%20%E4%BC%81%E4%B8%9A%E7%BA%A7%E7%94%9F%E4%BA%A7%E7%8E%AF%E5%A2%83%E9%83%A8%E7%BD%B2/7.1%20Docker%E7%9A%84%E5%8E%9F%E7%90%86%E5%92%8C%E5%9F%BA%E6%9C%AC%E4%BD%BF%E7%94%A8.html" class="md-nav__link">
  571. <span class="md-ellipsis">
  572. 7.1 Docker的原理和基本使用
  573. </span>
  574. </a>
  575. </li>
  576. <li class="md-nav__item">
  577. <a href="../%E2%91%A6%20%E4%BC%81%E4%B8%9A%E7%BA%A7%E7%94%9F%E4%BA%A7%E7%8E%AF%E5%A2%83%E9%83%A8%E7%BD%B2/7.2%20%E6%9C%8D%E5%8A%A1%E9%83%A8%E7%BD%B2.html" class="md-nav__link">
  578. <span class="md-ellipsis">
  579. 7.2 服务部署
  580. </span>
  581. </a>
  582. </li>
  583. </ul>
  584. </nav>
  585. </li>
  586. </ul>
  587. </nav>
  588. </div>
  589. </div>
  590. </div>
  591. <div class="md-sidebar md-sidebar--secondary" data-md-component="sidebar" data-md-type="toc" >
  592. <div class="md-sidebar__scrollwrap">
  593. <div class="md-sidebar__inner">
  594. <nav class="md-nav md-nav--secondary" aria-label="目录">
  595. <label class="md-nav__title" for="__toc">
  596. <span class="md-nav__icon md-icon"></span>
  597. 目录
  598. </label>
  599. <ul class="md-nav__list" data-md-component="toc" data-md-scrollfix>
  600. <li class="md-nav__item">
  601. <a href="#_1" class="md-nav__link">
  602. <span class="md-ellipsis">
  603. 学习目标:
  604. </span>
  605. </a>
  606. </li>
  607. <li class="md-nav__item">
  608. <a href="#_2" class="md-nav__link">
  609. <span class="md-ellipsis">
  610. 一、查询流程图
  611. </span>
  612. </a>
  613. </li>
  614. <li class="md-nav__item">
  615. <a href="#_3" class="md-nav__link">
  616. <span class="md-ellipsis">
  617. 二、流程说明
  618. </span>
  619. </a>
  620. </li>
  621. <li class="md-nav__item">
  622. <a href="#_4" class="md-nav__link">
  623. <span class="md-ellipsis">
  624. 三、代码介绍
  625. </span>
  626. </a>
  627. <nav class="md-nav" aria-label="三、代码介绍">
  628. <ul class="md-nav__list">
  629. <li class="md-nav__item">
  630. <a href="#1" class="md-nav__link">
  631. <span class="md-ellipsis">
  632. 1 导入必备的工具包
  633. </span>
  634. </a>
  635. </li>
  636. <li class="md-nav__item">
  637. <a href="#2-fastapi" class="md-nav__link">
  638. <span class="md-ellipsis">
  639. 2 创建 FastAPI 应用并配置
  640. </span>
  641. </a>
  642. </li>
  643. <li class="md-nav__item">
  644. <a href="#3" class="md-nav__link">
  645. <span class="md-ellipsis">
  646. 3 定义日常问候模式
  647. </span>
  648. </a>
  649. </li>
  650. <li class="md-nav__item">
  651. <a href="#4" class="md-nav__link">
  652. <span class="md-ellipsis">
  653. 4 定义请求和响应模型
  654. </span>
  655. </a>
  656. </li>
  657. <li class="md-nav__item">
  658. <a href="#5" class="md-nav__link">
  659. <span class="md-ellipsis">
  660. 5 挂载静态文件服务
  661. </span>
  662. </a>
  663. </li>
  664. <li class="md-nav__item">
  665. <a href="#6" class="md-nav__link">
  666. <span class="md-ellipsis">
  667. 6 创建新会话
  668. </span>
  669. </a>
  670. </li>
  671. <li class="md-nav__item">
  672. <a href="#7" class="md-nav__link">
  673. <span class="md-ellipsis">
  674. 7 查询历史消息
  675. </span>
  676. </a>
  677. </li>
  678. <li class="md-nav__item">
  679. <a href="#8" class="md-nav__link">
  680. <span class="md-ellipsis">
  681. 8 清除历史消息
  682. </span>
  683. </a>
  684. </li>
  685. <li class="md-nav__item">
  686. <a href="#9" class="md-nav__link">
  687. <span class="md-ellipsis">
  688. 9 检查日常问候
  689. </span>
  690. </a>
  691. </li>
  692. <li class="md-nav__item">
  693. <a href="#10" class="md-nav__link">
  694. <span class="md-ellipsis">
  695. 10 非流式查询接口
  696. </span>
  697. </a>
  698. </li>
  699. <li class="md-nav__item">
  700. <a href="#11-websocket" class="md-nav__link">
  701. <span class="md-ellipsis">
  702. 11 流式查询 WebSocket 接口
  703. </span>
  704. </a>
  705. </li>
  706. <li class="md-nav__item">
  707. <a href="#12" class="md-nav__link">
  708. <span class="md-ellipsis">
  709. 12 健康检查接口
  710. </span>
  711. </a>
  712. </li>
  713. <li class="md-nav__item">
  714. <a href="#13" class="md-nav__link">
  715. <span class="md-ellipsis">
  716. 13 获取知识域
  717. </span>
  718. </a>
  719. </li>
  720. <li class="md-nav__item">
  721. <a href="#14-fastapi" class="md-nav__link">
  722. <span class="md-ellipsis">
  723. 14 启动 FastAPI 服务
  724. </span>
  725. </a>
  726. </li>
  727. </ul>
  728. </nav>
  729. </li>
  730. <li class="md-nav__item">
  731. <a href="#_5" class="md-nav__link">
  732. <span class="md-ellipsis">
  733. 章节小结
  734. </span>
  735. </a>
  736. </li>
  737. </ul>
  738. </nav>
  739. </div>
  740. </div>
  741. </div>
  742. <div class="md-content" data-md-component="content">
  743. <article class="md-content__inner md-typeset">
  744. <h1>6.3 基于 FastAPI 的 FAQ 与知识库查询接口</h1>
  745. <h2 id="_1">学习目标:<a class="headerlink" href="#_1" title="Permanent link">&para;</a></h2>
  746. <ul>
  747. <li>理解如何基于 FastAPI 构建高效的问答系统 API 接口。</li>
  748. <li>掌握 WebSocket 流式输出和 HTTP 接口的实现,优化用户交互体验。</li>
  749. <li>学习前后端交互、前端静态文件服务以及日常问候处理的集成。</li>
  750. </ul>
  751. <h2 id="_2">一、查询流程图<a class="headerlink" href="#_2" title="Permanent link">&para;</a></h2>
  752. <p><code>app.py</code> 是对 <code>new_main.py</code> 的进一步优化,基于 FastAPI 框架构建了 RESTful API 和 WebSocket 接口,集成了 MySQL FAQ 和 RAG 系统,支持流式输出、对话历史管理和日常问候处理。同时,通过静态文件服务支持前端页面交互,适用于知识库场景下的实时问答系统。</p>
  753. <p>以下是基于 FastAPI 的问答系统查询流程图,展示从前端请求到后端响应的处理逻辑。</p>
  754. <div align=center><img src="../img/lc_03.png" style="zoom:80%" ><img/></div>
  755. <h2 id="_3">二、流程说明<a class="headerlink" href="#_3" title="Permanent link">&para;</a></h2>
  756. <ol>
  757. <li>
  758. <p><strong>请求接收</strong>:前端通过 HTTP POST (<code>/api/query</code>) 或 WebSocket (<code>/api/stream</code>) 发送查询请求,包含查询内容 (<code>query</code>)、知识域过滤 (<code>source_filter</code>) 和会话 ID (<code>session_id</code>)。</p>
  759. </li>
  760. <li>
  761. <p><strong>日常问候处理</strong>:检查查询是否为日常问候(如“你好”),若匹配则返回模板化回复。</p>
  762. </li>
  763. <li>
  764. <p><strong>BM25 搜索</strong>:使用 BM25 算法搜索 MySQL 知识库,设置相似度阈值 0.85。</p>
  765. </li>
  766. <li>
  767. <p><strong>答案判断</strong>:</p>
  768. </li>
  769. <li>若找到可靠答案(相似度 &gt; 0.85),通过 HTTP 一次性返回或 WebSocket 流式返回。</li>
  770. <li>若无可靠答案且需要 RAG,HTTP 接口提示使用 WebSocket,WebSocket 接口流式返回 RAG 答案。</li>
  771. <li>
  772. <p>若无需 RAG,返回“未找到答案”。</p>
  773. </li>
  774. <li>
  775. <p><strong>历史更新</strong>:将查询和答案存入 MySQL 的 <code>conversations</code> 表,保留最近 5 轮对话。</p>
  776. </li>
  777. <li>
  778. <p><strong>响应输出</strong>:HTTP 返回 JSON 格式响应,WebSocket 流式发送 JSON 数据(包含 <code>start</code>、<code>token</code>、<code>end</code> 或 <code>error</code> 类型)。</p>
  779. </li>
  780. </ol>
  781. <h2 id="_4">三、代码介绍<a class="headerlink" href="#_4" title="Permanent link">&para;</a></h2>
  782. <p>以下是 <code>app.py</code> 的完整代码,包含逐行注释,详细解析功能与实现逻辑。</p>
  783. <h3 id="1">1 导入必备的工具包<a class="headerlink" href="#1" title="Permanent link">&para;</a></h3>
  784. <div class="highlight"><pre><span></span><code><span class="c1"># 导入 FastAPI 相关模块,用于构建 API 和 WebSocket</span>
  785. <span class="kn">from</span><span class="w"> </span><span class="nn">fastapi</span><span class="w"> </span><span class="kn">import</span> <span class="n">FastAPI</span><span class="p">,</span> <span class="n">WebSocket</span><span class="p">,</span> <span class="n">HTTPException</span><span class="p">,</span> <span class="n">Query</span><span class="p">,</span> <span class="n">Depends</span>
  786. <span class="c1"># 导入 FastAPI 响应类型,用于流式响应和文件服务</span>
  787. <span class="kn">from</span><span class="w"> </span><span class="nn">fastapi.responses</span><span class="w"> </span><span class="kn">import</span> <span class="n">StreamingResponse</span><span class="p">,</span> <span class="n">FileResponse</span>
  788. <span class="c1"># 导入 CORS 中间件,支持跨域请求</span>
  789. <span class="kn">from</span><span class="w"> </span><span class="nn">fastapi.middleware.cors</span><span class="w"> </span><span class="kn">import</span> <span class="n">CORSMiddleware</span>
  790. <span class="c1"># 导入静态文件服务模块</span>
  791. <span class="kn">from</span><span class="w"> </span><span class="nn">fastapi.staticfiles</span><span class="w"> </span><span class="kn">import</span> <span class="n">StaticFiles</span>
  792. <span class="c1"># 导入 WebSocket 断开异常</span>
  793. <span class="kn">from</span><span class="w"> </span><span class="nn">starlette.websockets</span><span class="w"> </span><span class="kn">import</span> <span class="n">WebSocketDisconnect</span>
  794. <span class="c1"># 导入系统操作模块,用于文件目录管理</span>
  795. <span class="kn">import</span><span class="w"> </span><span class="nn">os</span>
  796. <span class="c1"># 导入 Pydantic 模型,用于请求验证</span>
  797. <span class="kn">from</span><span class="w"> </span><span class="nn">pydantic</span><span class="w"> </span><span class="kn">import</span> <span class="n">BaseModel</span>
  798. <span class="c1"># 导入异步事件循环模块</span>
  799. <span class="kn">import</span><span class="w"> </span><span class="nn">asyncio</span>
  800. <span class="c1"># 导入 JSON 处理模块</span>
  801. <span class="kn">import</span><span class="w"> </span><span class="nn">json</span>
  802. <span class="c1"># 导入 UUID 模块,生成唯一会话 ID</span>
  803. <span class="kn">import</span><span class="w"> </span><span class="nn">uuid</span>
  804. <span class="c1"># 导入类型注解模块</span>
  805. <span class="kn">from</span><span class="w"> </span><span class="nn">typing</span><span class="w"> </span><span class="kn">import</span> <span class="n">Optional</span><span class="p">,</span> <span class="n">List</span><span class="p">,</span> <span class="n">Dict</span><span class="p">,</span> <span class="n">Any</span>
  806. <span class="c1"># 导入时间模块,记录处理时间</span>
  807. <span class="kn">import</span><span class="w"> </span><span class="nn">time</span>
  808. <span class="c1"># 导入正则表达式模块,用于匹配日常问候</span>
  809. <span class="kn">import</span><span class="w"> </span><span class="nn">re</span>
  810. <span class="c1"># 导入优化后的问答系统</span>
  811. <span class="kn">from</span><span class="w"> </span><span class="nn">new_main</span><span class="w"> </span><span class="kn">import</span> <span class="n">IntegratedQASystem</span>
  812. </code></pre></div>
  813. <h3 id="2-fastapi">2 创建 FastAPI 应用并配置<a class="headerlink" href="#2-fastapi" title="Permanent link">&para;</a></h3>
  814. <ul>
  815. <li>创建 FastAPI 实例并配置 CORS 和静态文件服务。</li>
  816. <li><strong>功能</strong>:初始化 FastAPI 应用,允许跨域请求,挂载静态文件目录。</li>
  817. <li><strong>关键点</strong>:CORS 配置在生产环境中需限制域名,静态文件服务支持前端页面。</li>
  818. </ul>
  819. <div class="highlight"><pre><span></span><code><span class="c1"># 创建 FastAPI 应用实例,设置标题和描述</span>
  820. <span class="n">app</span> <span class="o">=</span> <span class="n">FastAPI</span><span class="p">(</span><span class="n">title</span><span class="o">=</span><span class="s2">&quot;问答系统API&quot;</span><span class="p">,</span> <span class="n">description</span><span class="o">=</span><span class="s2">&quot;集成MySQL和RAG的智能问答系统&quot;</span><span class="p">)</span>
  821. <span class="c1"># 配置 CORS 中间件,允许跨域请求</span>
  822. <span class="n">app</span><span class="o">.</span><span class="n">add_middleware</span><span class="p">(</span>
  823. <span class="n">CORSMiddleware</span><span class="p">,</span>
  824. <span class="n">allow_origins</span><span class="o">=</span><span class="p">[</span><span class="s2">&quot;*&quot;</span><span class="p">],</span> <span class="c1"># 允许所有来源(生产环境需限制)</span>
  825. <span class="n">allow_credentials</span><span class="o">=</span><span class="kc">True</span><span class="p">,</span> <span class="c1"># 允许凭证</span>
  826. <span class="n">allow_methods</span><span class="o">=</span><span class="p">[</span><span class="s2">&quot;*&quot;</span><span class="p">],</span> <span class="c1"># 允许所有 HTTP 方法</span>
  827. <span class="n">allow_headers</span><span class="o">=</span><span class="p">[</span><span class="s2">&quot;*&quot;</span><span class="p">],</span> <span class="c1"># 允许所有头部</span>
  828. <span class="p">)</span>
  829. <span class="c1"># 创建静态文件目录(如果不存在)</span>
  830. <span class="n">os</span><span class="o">.</span><span class="n">makedirs</span><span class="p">(</span><span class="s2">&quot;static&quot;</span><span class="p">,</span> <span class="n">exist_ok</span><span class="o">=</span><span class="kc">True</span><span class="p">)</span>
  831. <span class="c1"># 创建全局问答系统实例</span>
  832. <span class="n">qa_system</span> <span class="o">=</span> <span class="n">IntegratedQASystem</span><span class="p">()</span>
  833. </code></pre></div>
  834. <h3 id="3">3 定义日常问候模式<a class="headerlink" href="#3" title="Permanent link">&para;</a></h3>
  835. <ul>
  836. <li>定义问候语正则匹配模式和回复。</li>
  837. <li><strong>功能</strong>:快速响应常见问候,提升用户体验。</li>
  838. <li><strong>关键点</strong>:使用正则表达式匹配,支持大小写无关匹配。</li>
  839. </ul>
  840. <div class="highlight"><pre><span></span><code><span class="c1"># 定义日常问候用语模式和回复</span>
  841. <span class="n">GREETING_PATTERNS</span> <span class="o">=</span> <span class="p">[</span>
  842. <span class="p">{</span>
  843. <span class="s2">&quot;pattern&quot;</span><span class="p">:</span> <span class="sa">r</span><span class="s2">&quot;^(你好|您好|hi|hello)&quot;</span><span class="p">,</span> <span class="c1"># 匹配问候语</span>
  844. <span class="s2">&quot;response&quot;</span><span class="p">:</span> <span class="s2">&quot;你好!我是企业知识库助手,专注于为员工答疑解惑,很高兴为你服务!&quot;</span>
  845. <span class="p">},</span>
  846. <span class="p">{</span>
  847. <span class="s2">&quot;pattern&quot;</span><span class="p">:</span> <span class="sa">r</span><span class="s2">&quot;^(你是谁|您是谁|你叫什么|你的名字|who are you)&quot;</span><span class="p">,</span> <span class="c1"># 匹配身份询问</span>
  848. <span class="s2">&quot;response&quot;</span><span class="p">:</span> <span class="s2">&quot;我是企业知识库助手,致力于提供企业制度、IT服务、财务报销、合同流程和产品资料等内部知识解答!&quot;</span>
  849. <span class="p">},</span>
  850. <span class="p">{</span>
  851. <span class="s2">&quot;pattern&quot;</span><span class="p">:</span> <span class="sa">r</span><span class="s2">&quot;^(在吗|在不在|有人吗)&quot;</span><span class="p">,</span> <span class="c1"># 匹配在线确认</span>
  852. <span class="s2">&quot;response&quot;</span><span class="p">:</span> <span class="s2">&quot;我在!我是企业知识库助手,随时为你解答问题!&quot;</span>
  853. <span class="p">},</span>
  854. <span class="p">{</span>
  855. <span class="s2">&quot;pattern&quot;</span><span class="p">:</span> <span class="sa">r</span><span class="s2">&quot;^(干嘛呢|你在干嘛|做什么)&quot;</span><span class="p">,</span> <span class="c1"># 匹配状态询问</span>
  856. <span class="s2">&quot;response&quot;</span><span class="p">:</span> <span class="s2">&quot;我正在待命,随时为你检索和解答企业内部知识库问题!有什么我可以帮你的?&quot;</span>
  857. <span class="p">}</span>
  858. <span class="p">]</span>
  859. </code></pre></div>
  860. <h3 id="4">4 定义请求和响应模型<a class="headerlink" href="#4" title="Permanent link">&para;</a></h3>
  861. <ul>
  862. <li>使用 Pydantic 定义请求和响应数据结构。</li>
  863. <li><strong>功能</strong>:规范 API 输入和输出格式,确保数据验证。</li>
  864. <li><strong>关键点</strong>:支持可选字段,方便扩展。</li>
  865. </ul>
  866. <div class="highlight"><pre><span></span><code><span class="c1"># 定义查询请求模型</span>
  867. <span class="k">class</span><span class="w"> </span><span class="nc">QueryRequest</span><span class="p">(</span><span class="n">BaseModel</span><span class="p">):</span>
  868. <span class="n">query</span><span class="p">:</span> <span class="nb">str</span> <span class="c1"># 查询内容,必填</span>
  869. <span class="n">source_filter</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="nb">str</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span> <span class="c1"># 知识域过滤,可选</span>
  870. <span class="n">session_id</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="nb">str</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span> <span class="c1"># 会话 ID,可选</span>
  871. <span class="c1"># 定义查询响应模型</span>
  872. <span class="k">class</span><span class="w"> </span><span class="nc">QueryResponse</span><span class="p">(</span><span class="n">BaseModel</span><span class="p">):</span>
  873. <span class="n">answer</span><span class="p">:</span> <span class="nb">str</span> <span class="c1"># 答案内容</span>
  874. <span class="n">is_streaming</span><span class="p">:</span> <span class="nb">bool</span> <span class="c1"># 是否流式响应</span>
  875. <span class="n">session_id</span><span class="p">:</span> <span class="nb">str</span> <span class="c1"># 会话 ID</span>
  876. <span class="n">processing_time</span><span class="p">:</span> <span class="nb">float</span> <span class="c1"># 处理时间</span>
  877. </code></pre></div>
  878. <h3 id="5">5 挂载静态文件服务<a class="headerlink" href="#5" title="Permanent link">&para;</a></h3>
  879. <ul>
  880. <li>挂载静态文件目录并设置根路径。</li>
  881. <li><strong>功能</strong>:服务前端 HTML 文件,支持交互页面。</li>
  882. <li><strong>关键点</strong>:根路径重定向到 <code>index.html</code>。</li>
  883. </ul>
  884. <div class="highlight"><pre><span></span><code><span class="c1"># 挂载静态文件目录,服务前端文件</span>
  885. <span class="n">app</span><span class="o">.</span><span class="n">mount</span><span class="p">(</span><span class="s2">&quot;/static&quot;</span><span class="p">,</span> <span class="n">StaticFiles</span><span class="p">(</span><span class="n">directory</span><span class="o">=</span><span class="s2">&quot;static&quot;</span><span class="p">),</span> <span class="n">name</span><span class="o">=</span><span class="s2">&quot;static&quot;</span><span class="p">)</span>
  886. <span class="c1"># 根路径重定向到 index.html</span>
  887. <span class="nd">@app</span><span class="o">.</span><span class="n">get</span><span class="p">(</span><span class="s2">&quot;/&quot;</span><span class="p">)</span>
  888. <span class="k">async</span> <span class="k">def</span><span class="w"> </span><span class="nf">read_root</span><span class="p">():</span>
  889. <span class="k">return</span> <span class="n">FileResponse</span><span class="p">(</span><span class="s2">&quot;static/index.html&quot;</span><span class="p">)</span>
  890. </code></pre></div>
  891. <h3 id="6">6 创建新会话<a class="headerlink" href="#6" title="Permanent link">&para;</a></h3>
  892. <ul>
  893. <li>(<code>/api/create_session</code>) 接口</li>
  894. <li><strong>功能</strong>:生成新的唯一会话 ID。</li>
  895. <li><strong>关键点</strong>:使用 UUID 确保唯一性。</li>
  896. </ul>
  897. <div class="highlight"><pre><span></span><code><span class="c1"># 创建新会话接口</span>
  898. <span class="nd">@app</span><span class="o">.</span><span class="n">post</span><span class="p">(</span><span class="s2">&quot;/api/create_session&quot;</span><span class="p">)</span>
  899. <span class="k">async</span> <span class="k">def</span><span class="w"> </span><span class="nf">create_session</span><span class="p">():</span>
  900. <span class="n">session_id</span> <span class="o">=</span> <span class="nb">str</span><span class="p">(</span><span class="n">uuid</span><span class="o">.</span><span class="n">uuid4</span><span class="p">())</span> <span class="c1"># 生成唯一会话 ID</span>
  901. <span class="k">return</span> <span class="p">{</span><span class="s2">&quot;session_id&quot;</span><span class="p">:</span> <span class="n">session_id</span><span class="p">}</span> <span class="c1"># 返回会话 ID</span>
  902. </code></pre></div>
  903. <h3 id="7">7 查询历史消息<a class="headerlink" href="#7" title="Permanent link">&para;</a></h3>
  904. <ul>
  905. <li>(<code>/api/history/{session_id}</code>) 接口</li>
  906. <li><strong>功能</strong>:获取指定会话的历史记录。</li>
  907. <li><strong>关键点</strong>:异常处理确保接口健壮性。</li>
  908. </ul>
  909. <div class="highlight"><pre><span></span><code><span class="c1"># 查询历史消息接口</span>
  910. <span class="nd">@app</span><span class="o">.</span><span class="n">get</span><span class="p">(</span><span class="s2">&quot;/api/history/</span><span class="si">{session_id}</span><span class="s2">&quot;</span><span class="p">)</span>
  911. <span class="k">async</span> <span class="k">def</span><span class="w"> </span><span class="nf">get_history</span><span class="p">(</span><span class="n">session_id</span><span class="p">:</span> <span class="nb">str</span><span class="p">):</span>
  912. <span class="k">try</span><span class="p">:</span>
  913. <span class="c1"># 获取指定会话的历史记录</span>
  914. <span class="n">history</span> <span class="o">=</span> <span class="n">qa_system</span><span class="o">.</span><span class="n">get_session_history</span><span class="p">(</span><span class="n">session_id</span><span class="p">)</span>
  915. <span class="c1"># 返回会话 ID 和历史记录</span>
  916. <span class="k">return</span> <span class="p">{</span><span class="s2">&quot;session_id&quot;</span><span class="p">:</span> <span class="n">session_id</span><span class="p">,</span> <span class="s2">&quot;history&quot;</span><span class="p">:</span> <span class="n">history</span><span class="p">}</span>
  917. <span class="k">except</span> <span class="ne">Exception</span> <span class="k">as</span> <span class="n">e</span><span class="p">:</span>
  918. <span class="c1"># 抛出 HTTP 异常,包含错误信息</span>
  919. <span class="k">raise</span> <span class="n">HTTPException</span><span class="p">(</span><span class="n">status_code</span><span class="o">=</span><span class="mi">500</span><span class="p">,</span> <span class="n">detail</span><span class="o">=</span><span class="sa">f</span><span class="s2">&quot;获取历史记录失败: </span><span class="si">{</span><span class="nb">str</span><span class="p">(</span><span class="n">e</span><span class="p">)</span><span class="si">}</span><span class="s2">&quot;</span><span class="p">)</span>
  920. </code></pre></div>
  921. <h3 id="8">8 清除历史消息<a class="headerlink" href="#8" title="Permanent link">&para;</a></h3>
  922. <ul>
  923. <li>(<code>/api/history/{session_id}</code>) 接口</li>
  924. <li><strong>功能</strong>:删除指定会话的所有历史记录。</li>
  925. <li><strong>关键点</strong>:返回操作状态,异常处理确保健壮性。</li>
  926. </ul>
  927. <div class="highlight"><pre><span></span><code><span class="c1"># 清除历史消息接口</span>
  928. <span class="nd">@app</span><span class="o">.</span><span class="n">delete</span><span class="p">(</span><span class="s2">&quot;/api/history/</span><span class="si">{session_id}</span><span class="s2">&quot;</span><span class="p">)</span>
  929. <span class="k">async</span> <span class="k">def</span><span class="w"> </span><span class="nf">clear_history</span><span class="p">(</span><span class="n">session_id</span><span class="p">:</span> <span class="nb">str</span><span class="p">):</span>
  930. <span class="c1"># 清除指定会话的历史记录</span>
  931. <span class="n">success</span> <span class="o">=</span> <span class="n">qa_system</span><span class="o">.</span><span class="n">clear_session_history</span><span class="p">(</span><span class="n">session_id</span><span class="p">)</span>
  932. <span class="k">if</span> <span class="n">success</span><span class="p">:</span>
  933. <span class="c1"># 返回成功状态</span>
  934. <span class="k">return</span> <span class="p">{</span><span class="s2">&quot;status&quot;</span><span class="p">:</span> <span class="s2">&quot;success&quot;</span><span class="p">,</span> <span class="s2">&quot;message&quot;</span><span class="p">:</span> <span class="s2">&quot;历史记录已清除&quot;</span><span class="p">}</span>
  935. <span class="k">else</span><span class="p">:</span>
  936. <span class="c1"># 抛出 HTTP 异常</span>
  937. <span class="k">raise</span> <span class="n">HTTPException</span><span class="p">(</span><span class="n">status_code</span><span class="o">=</span><span class="mi">500</span><span class="p">,</span> <span class="n">detail</span><span class="o">=</span><span class="s2">&quot;清除历史记录失败&quot;</span><span class="p">)</span>
  938. </code></pre></div>
  939. <h3 id="9">9 检查日常问候<a class="headerlink" href="#9" title="Permanent link">&para;</a></h3>
  940. <ul>
  941. <li>(<code>check_greeting</code>) 函数</li>
  942. <li><strong>功能</strong>:检查查询是否匹配日常问候,返回模板化回复。</li>
  943. <li><strong>关键点</strong>:正则匹配支持大小写无关,简化交互逻辑。</li>
  944. </ul>
  945. <div class="highlight"><pre><span></span><code><span class="c1"># 检查是否为日常问候用语并返回模板回复</span>
  946. <span class="k">def</span><span class="w"> </span><span class="nf">check_greeting</span><span class="p">(</span><span class="n">query</span><span class="p">:</span> <span class="nb">str</span><span class="p">)</span> <span class="o">-&gt;</span> <span class="n">Optional</span><span class="p">[</span><span class="nb">str</span><span class="p">]:</span>
  947. <span class="n">query_text</span> <span class="o">=</span> <span class="n">query</span><span class="o">.</span><span class="n">strip</span><span class="p">()</span> <span class="c1"># 去除首尾空格</span>
  948. <span class="k">for</span> <span class="n">pattern_info</span> <span class="ow">in</span> <span class="n">GREETING_PATTERNS</span><span class="p">:</span>
  949. <span class="c1"># 使用正则匹配,忽略大小写</span>
  950. <span class="k">if</span> <span class="n">re</span><span class="o">.</span><span class="n">match</span><span class="p">(</span><span class="n">pattern_info</span><span class="p">[</span><span class="s2">&quot;pattern&quot;</span><span class="p">],</span> <span class="n">query_text</span><span class="p">,</span> <span class="n">re</span><span class="o">.</span><span class="n">IGNORECASE</span><span class="p">):</span>
  951. <span class="k">return</span> <span class="n">pattern_info</span><span class="p">[</span><span class="s2">&quot;response&quot;</span><span class="p">]</span> <span class="c1"># 返回匹配的回复</span>
  952. <span class="k">return</span> <span class="kc">None</span> <span class="c1"># 无匹配返回 None</span>
  953. </code></pre></div>
  954. <h3 id="10">10 非流式查询接口<a class="headerlink" href="#10" title="Permanent link">&para;</a></h3>
  955. <ul>
  956. <li>(<code>/api/query</code>) 接口</li>
  957. <li><strong>功能</strong>:处理非流式查询,支持 MySQL 答案和日常问候,提示使用 WebSocket 获取 RAG 流式答案。</li>
  958. <li><strong>关键点</strong>:返回 JSON 格式响应,记录处理时间。</li>
  959. </ul>
  960. <div class="highlight"><pre><span></span><code><span class="c1"># 非流式查询接口</span>
  961. <span class="nd">@app</span><span class="o">.</span><span class="n">post</span><span class="p">(</span><span class="s2">&quot;/api/query&quot;</span><span class="p">)</span>
  962. <span class="k">async</span> <span class="k">def</span><span class="w"> </span><span class="nf">query</span><span class="p">(</span><span class="n">request</span><span class="p">:</span> <span class="n">QueryRequest</span><span class="p">):</span>
  963. <span class="n">start_time</span> <span class="o">=</span> <span class="n">time</span><span class="o">.</span><span class="n">time</span><span class="p">()</span> <span class="c1"># 记录开始时间</span>
  964. <span class="c1"># 使用请求中的 session_id 或生成新 ID</span>
  965. <span class="n">session_id</span> <span class="o">=</span> <span class="n">request</span><span class="o">.</span><span class="n">session_id</span> <span class="ow">or</span> <span class="nb">str</span><span class="p">(</span><span class="n">uuid</span><span class="o">.</span><span class="n">uuid4</span><span class="p">())</span>
  966. <span class="c1"># 检查是否为日常问候</span>
  967. <span class="n">greeting_response</span> <span class="o">=</span> <span class="n">check_greeting</span><span class="p">(</span><span class="n">request</span><span class="o">.</span><span class="n">query</span><span class="p">)</span>
  968. <span class="k">if</span> <span class="n">greeting_response</span><span class="p">:</span>
  969. <span class="c1"># 返回问候回复</span>
  970. <span class="k">return</span> <span class="p">{</span>
  971. <span class="s2">&quot;answer&quot;</span><span class="p">:</span> <span class="n">greeting_response</span><span class="p">,</span>
  972. <span class="s2">&quot;is_streaming&quot;</span><span class="p">:</span> <span class="kc">False</span><span class="p">,</span>
  973. <span class="s2">&quot;session_id&quot;</span><span class="p">:</span> <span class="n">session_id</span><span class="p">,</span>
  974. <span class="s2">&quot;processing_time&quot;</span><span class="p">:</span> <span class="n">time</span><span class="o">.</span><span class="n">time</span><span class="p">()</span> <span class="o">-</span> <span class="n">start_time</span>
  975. <span class="p">}</span>
  976. <span class="c1"># 执行 BM25 搜索</span>
  977. <span class="n">answer</span><span class="p">,</span> <span class="n">need_rag</span> <span class="o">=</span> <span class="n">qa_system</span><span class="o">.</span><span class="n">bm25_search</span><span class="o">.</span><span class="n">search</span><span class="p">(</span><span class="n">request</span><span class="o">.</span><span class="n">query</span><span class="p">,</span> <span class="n">threshold</span><span class="o">=</span><span class="mf">0.85</span><span class="p">)</span>
  978. <span class="k">if</span> <span class="n">need_rag</span><span class="p">:</span>
  979. <span class="c1"># 需要 RAG,提示使用 WebSocket</span>
  980. <span class="k">return</span> <span class="p">{</span>
  981. <span class="s2">&quot;answer&quot;</span><span class="p">:</span> <span class="s2">&quot;请使用WebSocket接口获取流式响应&quot;</span><span class="p">,</span>
  982. <span class="s2">&quot;is_streaming&quot;</span><span class="p">:</span> <span class="kc">True</span><span class="p">,</span>
  983. <span class="s2">&quot;session_id&quot;</span><span class="p">:</span> <span class="n">session_id</span><span class="p">,</span>
  984. <span class="s2">&quot;processing_time&quot;</span><span class="p">:</span> <span class="n">time</span><span class="o">.</span><span class="n">time</span><span class="p">()</span> <span class="o">-</span> <span class="n">start_time</span>
  985. <span class="p">}</span>
  986. <span class="c1"># 返回 MySQL 答案</span>
  987. <span class="k">return</span> <span class="p">{</span>
  988. <span class="s2">&quot;answer&quot;</span><span class="p">:</span> <span class="n">answer</span><span class="p">,</span>
  989. <span class="s2">&quot;is_streaming&quot;</span><span class="p">:</span> <span class="kc">False</span><span class="p">,</span>
  990. <span class="s2">&quot;session_id&quot;</span><span class="p">:</span> <span class="n">session_id</span><span class="p">,</span>
  991. <span class="s2">&quot;processing_time&quot;</span><span class="p">:</span> <span class="n">time</span><span class="o">.</span><span class="n">time</span><span class="p">()</span> <span class="o">-</span> <span class="n">start_time</span>
  992. <span class="p">}</span>
  993. </code></pre></div>
  994. <h3 id="11-websocket">11 流式查询 WebSocket 接口<a class="headerlink" href="#11-websocket" title="Permanent link">&para;</a></h3>
  995. <ul>
  996. <li>(<code>/api/stream</code>) 接口</li>
  997. <li><strong>功能</strong>:通过 WebSocket 提供流式查询,支持 RAG 答案、日常问候和错误处理。</li>
  998. <li><strong>关键点</strong>:发送 <code>start</code>、<code>token</code>、<code>end</code> 或 <code>error</code> 类型的 JSON 消息,异步处理确保实时性。</li>
  999. </ul>
  1000. <div class="highlight"><pre><span></span><code><span class="c1"># 流式查询 WebSocket 接口</span>
  1001. <span class="nd">@app</span><span class="o">.</span><span class="n">websocket</span><span class="p">(</span><span class="s2">&quot;/api/stream&quot;</span><span class="p">)</span>
  1002. <span class="k">async</span> <span class="k">def</span><span class="w"> </span><span class="nf">websocket_endpoint</span><span class="p">(</span><span class="n">websocket</span><span class="p">:</span> <span class="n">WebSocket</span><span class="p">):</span>
  1003. <span class="k">await</span> <span class="n">websocket</span><span class="o">.</span><span class="n">accept</span><span class="p">()</span> <span class="c1"># 接受 WebSocket 连接</span>
  1004. <span class="k">try</span><span class="p">:</span>
  1005. <span class="k">while</span> <span class="kc">True</span><span class="p">:</span>
  1006. <span class="c1"># 接收客户端消息</span>
  1007. <span class="n">data</span> <span class="o">=</span> <span class="k">await</span> <span class="n">websocket</span><span class="o">.</span><span class="n">receive_text</span><span class="p">()</span>
  1008. <span class="n">request_data</span> <span class="o">=</span> <span class="n">json</span><span class="o">.</span><span class="n">loads</span><span class="p">(</span><span class="n">data</span><span class="p">)</span> <span class="c1"># 解析 JSON 数据</span>
  1009. <span class="c1"># 获取查询参数</span>
  1010. <span class="n">query</span> <span class="o">=</span> <span class="n">request_data</span><span class="o">.</span><span class="n">get</span><span class="p">(</span><span class="s2">&quot;query&quot;</span><span class="p">)</span>
  1011. <span class="n">source_filter</span> <span class="o">=</span> <span class="n">request_data</span><span class="o">.</span><span class="n">get</span><span class="p">(</span><span class="s2">&quot;source_filter&quot;</span><span class="p">)</span>
  1012. <span class="n">session_id</span> <span class="o">=</span> <span class="n">request_data</span><span class="o">.</span><span class="n">get</span><span class="p">(</span><span class="s2">&quot;session_id&quot;</span><span class="p">,</span> <span class="nb">str</span><span class="p">(</span><span class="n">uuid</span><span class="o">.</span><span class="n">uuid4</span><span class="p">()))</span>
  1013. <span class="n">start_time</span> <span class="o">=</span> <span class="n">time</span><span class="o">.</span><span class="n">time</span><span class="p">()</span> <span class="c1"># 记录开始时间</span>
  1014. <span class="c1"># 发送开始标志</span>
  1015. <span class="k">if</span> <span class="n">websocket</span><span class="o">.</span><span class="n">client_state</span> <span class="o">==</span> <span class="n">websocket</span><span class="o">.</span><span class="n">client_state</span><span class="o">.</span><span class="n">CONNECTED</span><span class="p">:</span>
  1016. <span class="k">await</span> <span class="n">websocket</span><span class="o">.</span><span class="n">send_json</span><span class="p">({</span>
  1017. <span class="s2">&quot;type&quot;</span><span class="p">:</span> <span class="s2">&quot;start&quot;</span><span class="p">,</span>
  1018. <span class="s2">&quot;session_id&quot;</span><span class="p">:</span> <span class="n">session_id</span>
  1019. <span class="p">})</span>
  1020. <span class="c1"># 检查是否为日常问候</span>
  1021. <span class="n">greeting_response</span> <span class="o">=</span> <span class="n">check_greeting</span><span class="p">(</span><span class="n">query</span><span class="p">)</span>
  1022. <span class="k">if</span> <span class="n">greeting_response</span><span class="p">:</span>
  1023. <span class="k">if</span> <span class="n">websocket</span><span class="o">.</span><span class="n">client_state</span> <span class="o">==</span> <span class="n">websocket</span><span class="o">.</span><span class="n">client_state</span><span class="o">.</span><span class="n">CONNECTED</span><span class="p">:</span>
  1024. <span class="c1"># 发送问候回复</span>
  1025. <span class="k">await</span> <span class="n">websocket</span><span class="o">.</span><span class="n">send_json</span><span class="p">({</span>
  1026. <span class="s2">&quot;type&quot;</span><span class="p">:</span> <span class="s2">&quot;token&quot;</span><span class="p">,</span>
  1027. <span class="s2">&quot;token&quot;</span><span class="p">:</span> <span class="n">greeting_response</span><span class="p">,</span>
  1028. <span class="s2">&quot;session_id&quot;</span><span class="p">:</span> <span class="n">session_id</span>
  1029. <span class="p">})</span>
  1030. <span class="c1"># 发送结束标志</span>
  1031. <span class="k">await</span> <span class="n">websocket</span><span class="o">.</span><span class="n">send_json</span><span class="p">({</span>
  1032. <span class="s2">&quot;type&quot;</span><span class="p">:</span> <span class="s2">&quot;end&quot;</span><span class="p">,</span>
  1033. <span class="s2">&quot;session_id&quot;</span><span class="p">:</span> <span class="n">session_id</span><span class="p">,</span>
  1034. <span class="s2">&quot;is_complete&quot;</span><span class="p">:</span> <span class="kc">True</span><span class="p">,</span>
  1035. <span class="s2">&quot;processing_time&quot;</span><span class="p">:</span> <span class="n">time</span><span class="o">.</span><span class="n">time</span><span class="p">()</span> <span class="o">-</span> <span class="n">start_time</span>
  1036. <span class="p">})</span>
  1037. <span class="k">break</span>
  1038. <span class="c1"># 调用问答系统,流式处理查询</span>
  1039. <span class="n">collected_answer</span> <span class="o">=</span> <span class="s2">&quot;&quot;</span>
  1040. <span class="k">for</span> <span class="n">token</span><span class="p">,</span> <span class="n">is_complete</span> <span class="ow">in</span> <span class="n">qa_system</span><span class="o">.</span><span class="n">query</span><span class="p">(</span><span class="n">query</span><span class="p">,</span> <span class="n">source_filter</span><span class="o">=</span><span class="n">source_filter</span><span class="p">,</span> <span class="n">session_id</span><span class="o">=</span><span class="n">session_id</span><span class="p">):</span>
  1041. <span class="n">collected_answer</span> <span class="o">+=</span> <span class="n">token</span> <span class="c1"># 累积答案</span>
  1042. <span class="k">if</span> <span class="n">is_complete</span> <span class="ow">and</span> <span class="ow">not</span> <span class="n">collected_answer</span><span class="p">:</span>
  1043. <span class="k">if</span> <span class="n">websocket</span><span class="o">.</span><span class="n">client_state</span> <span class="o">==</span> <span class="n">websocket</span><span class="o">.</span><span class="n">client_state</span><span class="o">.</span><span class="n">CONNECTED</span><span class="p">:</span>
  1044. <span class="c1"># 发送结束标志</span>
  1045. <span class="k">await</span> <span class="n">websocket</span><span class="o">.</span><span class="n">send_json</span><span class="p">({</span>
  1046. <span class="s2">&quot;type&quot;</span><span class="p">:</span> <span class="s2">&quot;end&quot;</span><span class="p">,</span>
  1047. <span class="s2">&quot;session_id&quot;</span><span class="p">:</span> <span class="n">session_id</span><span class="p">,</span>
  1048. <span class="s2">&quot;is_complete&quot;</span><span class="p">:</span> <span class="kc">True</span><span class="p">,</span>
  1049. <span class="s2">&quot;processing_time&quot;</span><span class="p">:</span> <span class="n">time</span><span class="o">.</span><span class="n">time</span><span class="p">()</span> <span class="o">-</span> <span class="n">start_time</span>
  1050. <span class="p">})</span>
  1051. <span class="k">break</span>
  1052. <span class="k">if</span> <span class="n">token</span> <span class="ow">and</span> <span class="n">websocket</span><span class="o">.</span><span class="n">client_state</span> <span class="o">==</span> <span class="n">websocket</span><span class="o">.</span><span class="n">client_state</span><span class="o">.</span><span class="n">CONNECTED</span><span class="p">:</span>
  1053. <span class="c1"># 发送 token 数据</span>
  1054. <span class="k">await</span> <span class="n">websocket</span><span class="o">.</span><span class="n">send_json</span><span class="p">({</span>
  1055. <span class="s2">&quot;type&quot;</span><span class="p">:</span> <span class="s2">&quot;token&quot;</span><span class="p">,</span>
  1056. <span class="s2">&quot;token&quot;</span><span class="p">:</span> <span class="n">token</span><span class="p">,</span>
  1057. <span class="s2">&quot;session_id&quot;</span><span class="p">:</span> <span class="n">session_id</span>
  1058. <span class="p">})</span>
  1059. <span class="k">if</span> <span class="n">is_complete</span><span class="p">:</span>
  1060. <span class="k">if</span> <span class="n">websocket</span><span class="o">.</span><span class="n">client_state</span> <span class="o">==</span> <span class="n">websocket</span><span class="o">.</span><span class="n">client_state</span><span class="o">.</span><span class="n">CONNECTED</span><span class="p">:</span>
  1061. <span class="c1"># 发送结束标志</span>
  1062. <span class="k">await</span> <span class="n">websocket</span><span class="o">.</span><span class="n">send_json</span><span class="p">({</span>
  1063. <span class="s2">&quot;type&quot;</span><span class="p">:</span> <span class="s2">&quot;end&quot;</span><span class="p">,</span>
  1064. <span class="s2">&quot;session_id&quot;</span><span class="p">:</span> <span class="n">session_id</span><span class="p">,</span>
  1065. <span class="s2">&quot;is_complete&quot;</span><span class="p">:</span> <span class="kc">True</span><span class="p">,</span>
  1066. <span class="s2">&quot;processing_time&quot;</span><span class="p">:</span> <span class="n">time</span><span class="o">.</span><span class="n">time</span><span class="p">()</span> <span class="o">-</span> <span class="n">start_time</span>
  1067. <span class="p">})</span>
  1068. <span class="k">break</span>
  1069. <span class="k">await</span> <span class="n">asyncio</span><span class="o">.</span><span class="n">sleep</span><span class="p">(</span><span class="mf">0.01</span><span class="p">)</span> <span class="c1"># 控制流式输出的速度</span>
  1070. <span class="k">except</span> <span class="n">WebSocketDisconnect</span> <span class="k">as</span> <span class="n">e</span><span class="p">:</span>
  1071. <span class="c1"># 记录 WebSocket 断开信息</span>
  1072. <span class="nb">print</span><span class="p">(</span><span class="sa">f</span><span class="s2">&quot;WebSocket disconnected: code=</span><span class="si">{</span><span class="n">e</span><span class="o">.</span><span class="n">code</span><span class="si">}</span><span class="s2">, reason=</span><span class="si">{</span><span class="n">e</span><span class="o">.</span><span class="n">reason</span><span class="si">}</span><span class="s2">&quot;</span><span class="p">)</span>
  1073. <span class="k">except</span> <span class="ne">Exception</span> <span class="k">as</span> <span class="n">e</span><span class="p">:</span>
  1074. <span class="c1"># 记录错误信息</span>
  1075. <span class="nb">print</span><span class="p">(</span><span class="sa">f</span><span class="s2">&quot;WebSocket error: </span><span class="si">{</span><span class="nb">str</span><span class="p">(</span><span class="n">e</span><span class="p">)</span><span class="si">}</span><span class="s2">&quot;</span><span class="p">)</span>
  1076. <span class="k">if</span> <span class="n">websocket</span><span class="o">.</span><span class="n">client_state</span> <span class="o">==</span> <span class="n">websocket</span><span class="o">.</span><span class="n">client_state</span><span class="o">.</span><span class="n">CONNECTED</span><span class="p">:</span>
  1077. <span class="c1"># 发送错误消息</span>
  1078. <span class="k">await</span> <span class="n">websocket</span><span class="o">.</span><span class="n">send_json</span><span class="p">({</span>
  1079. <span class="s2">&quot;type&quot;</span><span class="p">:</span> <span class="s2">&quot;error&quot;</span><span class="p">,</span>
  1080. <span class="s2">&quot;error&quot;</span><span class="p">:</span> <span class="nb">str</span><span class="p">(</span><span class="n">e</span><span class="p">)</span>
  1081. <span class="p">})</span>
  1082. <span class="k">finally</span><span class="p">:</span>
  1083. <span class="k">try</span><span class="p">:</span>
  1084. <span class="k">if</span> <span class="n">websocket</span><span class="o">.</span><span class="n">client_state</span> <span class="o">==</span> <span class="n">websocket</span><span class="o">.</span><span class="n">client_state</span><span class="o">.</span><span class="n">CONNECTED</span><span class="p">:</span>
  1085. <span class="c1"># 关闭 WebSocket 连接</span>
  1086. <span class="k">await</span> <span class="n">websocket</span><span class="o">.</span><span class="n">close</span><span class="p">()</span>
  1087. <span class="k">except</span> <span class="ne">Exception</span> <span class="k">as</span> <span class="n">e</span><span class="p">:</span>
  1088. <span class="c1"># 记录关闭连接时的错误</span>
  1089. <span class="nb">print</span><span class="p">(</span><span class="sa">f</span><span class="s2">&quot;Error closing WebSocket: </span><span class="si">{</span><span class="nb">str</span><span class="p">(</span><span class="n">e</span><span class="p">)</span><span class="si">}</span><span class="s2">&quot;</span><span class="p">)</span>
  1090. </code></pre></div>
  1091. <h3 id="12">12 健康检查接口<a class="headerlink" href="#12" title="Permanent link">&para;</a></h3>
  1092. <ul>
  1093. <li>(<code>/health</code>) 接口</li>
  1094. <li><strong>功能</strong>:提供健康检查端点,确认服务状态。</li>
  1095. <li><strong>关键点</strong>:简单可靠,适合监控系统可用性。</li>
  1096. </ul>
  1097. <div class="highlight"><pre><span></span><code><span class="c1"># 健康检查接口</span>
  1098. <span class="nd">@app</span><span class="o">.</span><span class="n">get</span><span class="p">(</span><span class="s2">&quot;/health&quot;</span><span class="p">)</span>
  1099. <span class="k">async</span> <span class="k">def</span><span class="w"> </span><span class="nf">health_check</span><span class="p">():</span>
  1100. <span class="k">return</span> <span class="p">{</span><span class="s2">&quot;status&quot;</span><span class="p">:</span> <span class="s2">&quot;healthy&quot;</span><span class="p">}</span> <span class="c1"># 返回健康状态</span>
  1101. </code></pre></div>
  1102. <h3 id="13">13 获取知识域<a class="headerlink" href="#13" title="Permanent link">&para;</a></h3>
  1103. <ul>
  1104. <li>(<code>/api/sources</code>) 接口</li>
  1105. <li><strong>功能</strong>:返回系统支持的知识域。</li>
  1106. <li><strong>关键点</strong>:便于前端动态展示过滤选项。</li>
  1107. </ul>
  1108. <div class="highlight"><pre><span></span><code><span class="c1"># 获取有效知识域接口</span>
  1109. <span class="nd">@app</span><span class="o">.</span><span class="n">get</span><span class="p">(</span><span class="s2">&quot;/api/sources&quot;</span><span class="p">)</span>
  1110. <span class="k">async</span> <span class="k">def</span><span class="w"> </span><span class="nf">get_sources</span><span class="p">():</span>
  1111. <span class="k">return</span> <span class="p">{</span><span class="s2">&quot;sources&quot;</span><span class="p">:</span> <span class="n">qa_system</span><span class="o">.</span><span class="n">config</span><span class="o">.</span><span class="n">VALID_SOURCES</span><span class="p">}</span> <span class="c1"># 返回知识域列表</span>
  1112. </code></pre></div>
  1113. <h3 id="14-fastapi">14 启动 FastAPI 服务<a class="headerlink" href="#14-fastapi" title="Permanent link">&para;</a></h3>
  1114. <ul>
  1115. <li>主程序入口</li>
  1116. <li><strong>功能</strong>:使用 Uvicorn 运行 FastAPI 应用。</li>
  1117. <li><strong>关键点</strong>:配置主机和端口,支持生产环境部署。</li>
  1118. </ul>
  1119. <div class="highlight"><pre><span></span><code><span class="c1"># 主程序入口</span>
  1120. <span class="k">if</span> <span class="vm">__name__</span> <span class="o">==</span> <span class="s2">&quot;__main__&quot;</span><span class="p">:</span>
  1121. <span class="kn">import</span><span class="w"> </span><span class="nn">uvicorn</span>
  1122. <span class="kn">import</span><span class="w"> </span><span class="nn">os</span>
  1123. <span class="c1"># 从环境变量获取主机和端口,默认值为 0.0.0.0:8080</span>
  1124. <span class="n">host</span> <span class="o">=</span> <span class="n">os</span><span class="o">.</span><span class="n">getenv</span><span class="p">(</span><span class="s1">&#39;HOST&#39;</span><span class="p">,</span> <span class="s1">&#39;0.0.0.0&#39;</span><span class="p">)</span>
  1125. <span class="n">port</span> <span class="o">=</span> <span class="nb">int</span><span class="p">(</span><span class="n">os</span><span class="o">.</span><span class="n">getenv</span><span class="p">(</span><span class="s1">&#39;PORT&#39;</span><span class="p">,</span> <span class="mi">8080</span><span class="p">))</span>
  1126. <span class="c1"># 运行 FastAPI 应用,监听指定的主机和端口</span>
  1127. <span class="n">uvicorn</span><span class="o">.</span><span class="n">run</span><span class="p">(</span><span class="s2">&quot;app:app&quot;</span><span class="p">,</span> <span class="n">host</span><span class="o">=</span><span class="n">host</span><span class="p">,</span> <span class="n">port</span><span class="o">=</span><span class="n">port</span><span class="p">,</span> <span class="n">reload</span><span class="o">=</span><span class="kc">False</span><span class="p">)</span>
  1128. </code></pre></div>
  1129. <h2 id="_5">章节小结<a class="headerlink" href="#_5" title="Permanent link">&para;</a></h2>
  1130. <p>本章展示了基于 FastAPI 的 <code>app.py</code>,通过 RESTful API 和 WebSocket 接口实现了高效的问答系统。系统集成了 MySQL FAQ 和 RAG 的查询功能,支持流式输出、对话历史管理和日常问候处理,结合静态文件服务实现了前后端交互,配备健壮的错误处理和日志记录,适合知识库场景下的实时问答需求。</p>
  1131. </article>
  1132. </div>
  1133. <script>var target=document.getElementById(location.hash.slice(1));target&&target.name&&(target.checked=target.name.startsWith("__tabbed_"))</script>
  1134. </div>
  1135. </main>
  1136. <footer class="md-footer">
  1137. <div class="md-footer-meta md-typeset">
  1138. <div class="md-footer-meta__inner md-grid">
  1139. <div class="md-copyright">
  1140. <div class="md-copyright__highlight">
  1141. © EnterpriseKB-RAG 2026. Internal knowledge base demo site.
  1142. </div>
  1143. Made with
  1144. <a href="https://squidfunk.github.io/mkdocs-material/" target="_blank" rel="noopener">
  1145. Material for MkDocs
  1146. </a>
  1147. </div>
  1148. </div>
  1149. </div>
  1150. </footer>
  1151. </div>
  1152. <div class="md-dialog" data-md-component="dialog">
  1153. <div class="md-dialog__inner md-typeset"></div>
  1154. </div>
  1155. <script id="__config" type="application/json">{"base": "..", "features": [], "search": "../assets/javascripts/workers/search.973d3a69.min.js", "tags": null, "translations": {"clipboard.copied": "\u5df2\u590d\u5236", "clipboard.copy": "\u590d\u5236", "search.result.more.one": "\u5728\u8be5\u9875\u4e0a\u8fd8\u6709 1 \u4e2a\u7b26\u5408\u6761\u4ef6\u7684\u7ed3\u679c", "search.result.more.other": "\u5728\u8be5\u9875\u4e0a\u8fd8\u6709 # \u4e2a\u7b26\u5408\u6761\u4ef6\u7684\u7ed3\u679c", "search.result.none": "\u6ca1\u6709\u627e\u5230\u7b26\u5408\u6761\u4ef6\u7684\u7ed3\u679c", "search.result.one": "\u627e\u5230 1 \u4e2a\u7b26\u5408\u6761\u4ef6\u7684\u7ed3\u679c", "search.result.other": "# \u4e2a\u7b26\u5408\u6761\u4ef6\u7684\u7ed3\u679c", "search.result.placeholder": "\u952e\u5165\u4ee5\u5f00\u59cb\u641c\u7d22", "search.result.term.missing": "\u7f3a\u5c11", "select.version": "\u9009\u62e9\u5f53\u524d\u7248\u672c"}, "version": null}</script>
  1156. <script src="../assets/javascripts/bundle.f55a23d4.min.js"></script>
  1157. <script src="../javascripts/extra.js"></script>
  1158. <script src="../javascripts/mathjax.js"></script>
  1159. <!-- <script src="https://polyfill.io/v3/polyfill.min.js?features=es6"></script>-->
  1160. <script src="https://cdn.jsdelivr.net/npm/mathjax@3/es5/tex-mml-chtml.js"></script>
  1161. </body>
  1162. </html>