{"id":105783,"date":"2026-09-16T00:56:38","date_gmt":"2026-09-15T16:56:38","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/105783.html"},"modified":"2026-09-16T00:56:38","modified_gmt":"2026-09-15T16:56:38","slug":"%e3%80%90ai%e5%a4%a7%e6%a8%a1%e5%9e%8b%e5%ba%94%e7%94%a8%e5%bc%80%e5%8f%91%e3%80%91%e3%80%90%e9%a1%b9%e7%9b%ae%e5%ae%9e%e6%88%98%e3%80%9135-%e5%9f%ba%e4%ba%8ea2a%e5%8d%8f%e8%ae%ae%e7%9a%84%e6%99%ba","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/105783.html","title":{"rendered":"\u3010AI\u5927\u6a21\u578b\u5e94\u7528\u5f00\u53d1\u3011\u3010\u9879\u76ee\u5b9e\u6218\u301135.\u57fa\u4e8eA2A\u534f\u8bae\u7684\u667a\u80fd\u52a9\u624b(\u591a\u667a\u80fd\u4f53)(\u4e09)\u9879\u76ee\u5b9e\u73b0\u4e4b\u5929\u6c14MCP\u670d\u52a1\u5668&amp;\u7968\u52a1\u5458MCP\u670d\u52a1\u5668&amp;\u8ba2\u7968MCP\u670d\u52a1\u5668"},"content":{"rendered":"<h3 id=\"6-mcp\">6.\u5929\u6c14MCP\u670d\u52a1\u5668<\/h3>\n<p><span style=\"color:#fe2c24\">mcp_weather_server\u5929\u6c14 MCP \u670d\u52a1\u5668<\/span>&#xff0c;\u63d0\u4f9b weather_data \u8868\u7684 SELECT \u67e5\u8be2\u63a5\u53e3&#xff0c;\u8fd4\u56de JSON \u683c\u5f0f\u7ed3\u679c<\/p>\n<p>\u6838\u5fc3\u529f\u80fd&#xff1a;<\/p>\n<ul>\n<li>\n<p>\u521d\u59cb\u5316 MySQL \u6570\u636e\u5e93\u8fde\u63a5<\/p>\n<\/li>\n<li>\n<p>\u6267\u884c SELECT \u67e5\u8be2&#xff0c;\u8fd4\u56de JSON \u683c\u5f0f\u7ed3\u679c<\/p>\n<\/li>\n<li>\n<p>\u683c\u5f0f\u5316\u65e5\u671f\u548c\u6570\u503c\u5b57\u6bb5&#xff0c;\u786e\u4fdd JSON \u5e8f\u5217\u5316\u517c\u5bb9<\/p>\n<\/li>\n<li>\n<p>\u901a\u8fc7<span style=\"color:#fe2c24\"> FastAPI \u63d0\u4f9b HTTP \u63a5\u53e3<\/span>&#xff0c;<span style=\"color:#fe2c24\">\u54cd\u5e94 MCP \u5de5\u5177\u8c03\u7528<\/span><\/p>\n<\/li>\n<\/ul>\n<h4 id=\"61\">6.1 \u683c\u5f0f\u7f16\u7801<\/h4>\n<p><span style=\"color:#fe2c24\">format.py<\/span>\u4e2d\u5305\u542b\u4e00\u4e2a\u7f16\u7801\u5668\u65b9\u6cd5\u548cJSON\u7f16\u7801\u5668\u7c7b<\/p>\n<p>\u76ee\u6807&#xff1a;\u5b9a\u4e49\u7f16\u7801\u5668\u65b9\u6cd5&#xff0c;\u7528\u4e8e\u683c\u5f0f\u5316\u5355\u4e2a\u5bf9\u8c61&#xff1b;\u81ea\u5b9a\u4e49 JSON \u7f16\u7801\u5668&#xff0c;\u5904\u7406 MySQL \u67e5\u8be2\u7ed3\u679c\u4e2d\u7684\u975e\u6807\u51c6\u7c7b\u578b<\/p>\n<p>\u529f\u80fd&#xff1a;\u5c06 MySQL\u67e5\u8be2\u7ed3\u679c\u4e2d\u7684date\u3001datetime\u3001timedelta \u548c Decimal \u7c7b\u578b\u8f6c\u6362\u4e3a JSON \u517c\u5bb9\u7684\u5b57\u7b26\u4e32\u6216\u6570\u503c<\/p>\n<p>\u4f4d\u7f6e&#xff1a;\/utils\/format.py<\/p>\n<p>import json<br \/>\nfrom datetime import date, datetime, timedelta<br \/>\nfrom decimal import Decimal<\/p>\n<p>def default_encoder(obj):  # \u5b9a\u4e49\u7f16\u7801\u5668\u65b9\u6cd5&#xff0c;\u7528\u4e8e\u683c\u5f0f\u5316\u5355\u4e2a\u5bf9\u8c61<br \/>\n    if isinstance(obj, datetime):  # \u68c0\u67e5\u662f\u5426\u4e3adatetime&#xff0c;\u8fd4\u56de\u5e26\u65f6\u95f4\u7684\u683c\u5f0f\u5316\u5b57\u7b26\u4e32<br \/>\n        return obj.strftime(&#039;%Y-%m-%d %H:%M:%S&#039;)<br \/>\n    if isinstance(obj, date):  # \u68c0\u67e5\u662f\u5426\u4e3adate&#xff0c;\u8fd4\u56de\u65e5\u671f\u683c\u5f0f\u5316\u5b57\u7b26\u4e32<br \/>\n        return obj.strftime(&#039;%Y-%m-%d&#039;)<br \/>\n    if isinstance(obj, timedelta):  # \u68c0\u67e5\u662f\u5426\u4e3atimedelta&#xff0c;\u8f6c\u6362\u4e3a\u5b57\u7b26\u4e32<br \/>\n        return str(obj)<br \/>\n    if isinstance(obj, Decimal):  # \u68c0\u67e5\u662f\u5426\u4e3aDecimal&#xff0c;\u8f6c\u6362\u4e3a\u6d6e\u70b9\u6570<br \/>\n        return float(obj)<br \/>\n    return obj  # \u5426\u5219\u8fd4\u56de\u539f\u5bf9\u8c61<\/p>\n<p># \u5b9a\u4e49\u81ea\u5b9a\u4e49JSON\u7f16\u7801\u5668\u7c7b&#xff0c;\u7ee7\u627f\u81eajson.JSONEncoder&#xff0c;\u7528\u4e8e\u5904\u7406\u975e\u6807\u51c6\u7c7b\u578b\u5e8f\u5217\u5316<br \/>\nclass DateEncoder(json.JSONEncoder):<br \/>\n    def default(self, obj):  # \u91cd\u5199default\u65b9\u6cd5&#xff0c;\u5904\u7406\u5e8f\u5217\u5316\u65f6\u7684\u9ed8\u8ba4\u5bf9\u8c61\u8f6c\u6362<br \/>\n        if isinstance(obj, (date, datetime)):  # \u68c0\u67e5\u5bf9\u8c61\u662f\u5426\u4e3adate\u6216datetime\u7c7b\u578b&#xff0c;\u5bf9\u4e8edatetime\u8fd4\u56de\u5e26\u65f6\u95f4\u7684\u5b57\u7b26\u4e32&#xff0c;\u5bf9\u4e8edate\u8fd4\u56de\u65e5\u671f\u5b57\u7b26\u4e32<br \/>\n            return obj.strftime(&#039;%Y-%m-%d %H:%M:%S&#039;) if isinstance(obj, datetime) else obj.strftime(&#039;%Y-%m-%d&#039;)<br \/>\n        if isinstance(obj, timedelta):  # \u68c0\u67e5\u5bf9\u8c61\u662f\u5426\u4e3atimedelta\u7c7b\u578b&#xff0c;\u5c06\u65f6\u95f4\u5dee\u8f6c\u6362\u4e3a\u5b57\u7b26\u4e32<br \/>\n            return str(obj)<br \/>\n        if isinstance(obj, Decimal):  # \u68c0\u67e5\u5bf9\u8c61\u662f\u5426\u4e3aDecimal\u7c7b\u578b&#xff0c;\u5c06Decimal\u8f6c\u6362\u4e3a\u6d6e\u70b9\u6570\u4ee5\u517c\u5bb9JSON<br \/>\n            return float(obj)<br \/>\n        return super().default(obj)  # \u5bf9\u4e8e\u5176\u4ed6\u7c7b\u578b&#xff0c;\u8c03\u7528\u7236\u7c7b\u9ed8\u8ba4\u65b9\u6cd5 <\/p>\n<p>\u6d4b\u8bd5&#xff1a;<\/p>\n<p>if __name__ &#061;&#061; &#039;__main__&#039;:<br \/>\n    print(default_encoder(datetime(2025&#061;6, 7, 11, 8, 0)))<br \/>\n    print(default_encoder(date(2026, 7, 11)))<br \/>\n    print(default_encoder(timedelta(days&#061;1)))<br \/>\n    print(default_encoder(Decimal(&#039;123.45&#039;)))<br \/>\n    print(&#039;*&#039;*80)<\/p>\n<p>    encoder &#061; DateEncoder()<br \/>\n    print(encoder.default(datetime(2026, 7, 11, 8, 0)))<br \/>\n    print(encoder.default(date(2026, 7, 11)))<br \/>\n    print(encoder.default(timedelta(days&#061;1)))<br \/>\n    print(encoder.default(Decimal(&#039;123.45&#039;))) <\/p>\n<h4 id=\"62-weatherservice\">6.2 WeatherService\u7c7b<\/h4>\n<p>\u76ee\u6807&#xff1a;\u63d0\u4f9b<span style=\"color:#fe2c24\">\u5929\u6c14\u6570\u636e\u67e5\u8be2\u670d\u52a1<\/span>&#xff0c;\u54cd\u5e94\u4ee3\u7406\u7684 SQL \u8bf7\u6c42<\/p>\n<p>\u529f\u80fd&#xff1a;\u521d\u59cb\u5316 MySQL \u8fde\u63a5&#xff0c;\u6267\u884c SELECT \u67e5\u8be2&#xff0c;\u683c\u5f0f\u5316\u7ed3\u679c\u4e3a JSON<\/p>\n<p>\u4f4d\u7f6e&#xff1a;\/mcp_server\/mcp_weather_server.py<\/p>\n<p># -*- coding: utf-8 -*-<br \/>\n&#034;&#034;&#034;<br \/>\n\u8fd9\u662f\u4e00\u4e2a\u57fa\u4e8e FastMCP \u6846\u67b6\u7684\u5929\u6c14\u67e5\u8be2\u670d\u52a1\u3002<br \/>\n\u5b83\u8fde\u63a5 MySQL \u6570\u636e\u5e93&#xff0c;\u901a\u8fc7\u63a5\u6536 SQL \u67e5\u8be2\u8bed\u53e5\u6765\u8fd4\u56de\u5929\u6c14\u6570\u636e\u3002<br \/>\n&#034;&#034;&#034;<\/p>\n<p># \u5bfc\u5165\u5fc5\u8981\u7684\u5e93<br \/>\nimport mysql.connector  # \u7528\u4e8e\u8fde\u63a5\u548c\u64cd\u4f5c MySQL \u6570\u636e\u5e93<br \/>\nimport json  # \u7528\u4e8e\u5904\u7406 JSON \u6570\u636e\u7684\u5e8f\u5217\u5316\u548c\u53cd\u5e8f\u5217\u5316<br \/>\nfrom datetime import date, datetime, timedelta  # \u7528\u4e8e\u5904\u7406\u65e5\u671f\u548c\u65f6\u95f4\u5bf9\u8c61<br \/>\nfrom decimal import Decimal  # \u7528\u4e8e\u5904\u7406\u9ad8\u7cbe\u5ea6\u7684\u5341\u8fdb\u5236\u6570&#xff0c;\u5982\u6570\u636e\u5e93\u4e2d\u7684 DECIMAL \u7c7b\u578b<\/p>\n<p># \u4ece\u81ea\u5b9a\u4e49\u6a21\u5757\u4e2d\u5bfc\u5165 FastMCP \u7c7b&#xff0c;\u8fd9\u662f\u6784\u5efa MCP \u670d\u52a1\u5668\u7684\u6838\u5fc3<br \/>\nfrom mcp.server.fastmcp import FastMCP<\/p>\n<p># \u4ece\u672c\u5730\u914d\u7f6e\u6587\u4ef6\u548c\u65e5\u5fd7\u6a21\u5757\u4e2d\u5bfc\u5165\u914d\u7f6e\u548c\u65e5\u5fd7\u8bb0\u5f55\u5668<br \/>\nfrom config import Config<br \/>\nfrom create_logger import logger<\/p>\n<p># \u4ece\u81ea\u5b9a\u4e49\u5de5\u5177\u6a21\u5757\u4e2d\u5bfc\u5165\u65e5\u671f\u7f16\u7801\u5668\u548c\u9ed8\u8ba4\u7f16\u7801\u5668&#xff0c;\u7528\u4e8e\u683c\u5f0f\u5316\u7279\u6b8a\u6570\u636e\u7c7b\u578b<br \/>\nfrom utils.format import DateEncoder, default_encoder<\/p>\n<p># \u5b9e\u4f8b\u5316\u914d\u7f6e\u5bf9\u8c61&#xff0c;\u7528\u4e8e\u83b7\u53d6\u6570\u636e\u5e93\u8fde\u63a5\u4fe1\u606f&#xff08;host, user, password, database&#xff09;<br \/>\nconf &#061; Config()<\/p>\n<p># \u5b9a\u4e49\u5929\u6c14\u670d\u52a1\u7c7b&#xff0c;\u7528\u4e8e\u5c01\u88c5\u6240\u6709\u4e0e\u5929\u6c14\u6570\u636e\u76f8\u5173\u7684\u6570\u636e\u5e93\u64cd\u4f5c<br \/>\nclass WeatherService:<br \/>\n    def __init__(self):<br \/>\n        # \u5728\u7c7b\u521d\u59cb\u5316\u65f6&#xff0c;\u4f7f\u7528\u914d\u7f6e\u4fe1\u606f\u5efa\u7acb\u4e0e MySQL \u6570\u636e\u5e93\u7684\u8fde\u63a5<br \/>\n        # \u8fd9\u4e2a\u8fde\u63a5\u4f1a\u5728\u6574\u4e2a WeatherService \u5b9e\u4f8b\u7684\u751f\u547d\u5468\u671f\u5185\u4fdd\u6301<br \/>\n        self.conn &#061; mysql.connector.connect(<br \/>\n            host&#061;conf.host,<br \/>\n            user&#061;conf.user,<br \/>\n            password&#061;conf.password,<br \/>\n            database&#061;conf.database<br \/>\n        )<\/p>\n<p>    # \u5b9a\u4e49\u4e00\u4e2a\u6267\u884c SQL \u67e5\u8be2\u7684\u65b9\u6cd5<br \/>\n    # \u53c2\u6570: sql (str) &#8211; \u4e00\u4e2a\u5b8c\u6574\u7684 SQL \u67e5\u8be2\u5b57\u7b26\u4e32<br \/>\n    # \u8fd4\u56de: str &#8211; \u4e00\u4e2a JSON \u683c\u5f0f\u7684\u5b57\u7b26\u4e32&#xff0c;\u5305\u542b\u67e5\u8be2\u7ed3\u679c\u6216\u9519\u8bef\u4fe1\u606f<br \/>\n    def execute_query(self, sql: str) -&gt; str:<br \/>\n        try:<br \/>\n            # \u521b\u5efa\u4e00\u4e2a\u6e38\u6807&#xff08;cursor&#xff09;&#xff0c;dictionary&#061;True \u8868\u793a\u67e5\u8be2\u7ed3\u679c\u5c06\u4ee5\u5b57\u5178\u5217\u8868\u7684\u5f62\u5f0f\u8fd4\u56de<br \/>\n            # \u8fd9\u6837\u53ef\u4ee5\u901a\u8fc7\u5217\u540d&#xff08;\u5982 row[&#039;city&#039;]&#xff09;\u800c\u4e0d\u662f\u7d22\u5f15\u6765\u8bbf\u95ee\u6570\u636e<br \/>\n            cursor &#061; self.conn.cursor(dictionary&#061;True)<\/p>\n<p>            # \u6267\u884c\u4f20\u5165\u7684 SQL \u8bed\u53e5<br \/>\n            cursor.execute(sql)<\/p>\n<p>            # \u83b7\u53d6\u6240\u6709\u67e5\u8be2\u7ed3\u679c<br \/>\n            results &#061; cursor.fetchall()<\/p>\n<p>            # \u5173\u95ed\u6e38\u6807&#xff0c;\u91ca\u653e\u8d44\u6e90<br \/>\n            cursor.close()<\/p>\n<p>            # &#8212; \u6570\u636e\u683c\u5f0f\u5316 &#8212;<br \/>\n            # \u904d\u5386\u67e5\u8be2\u7ed3\u679c\u4e2d\u7684\u6bcf\u4e00\u884c&#xff08;\u6bcf\u4e2a\u7ed3\u679c\u90fd\u662f\u4e00\u4e2a\u5b57\u5178&#xff09;<br \/>\n            for result in results:<br \/>\n                # \u904d\u5386\u5b57\u5178\u4e2d\u7684\u6bcf\u4e00\u4e2a\u952e\u503c\u5bf9<br \/>\n                for key, value in result.items():<br \/>\n                    # \u68c0\u67e5\u503c\u662f\u5426\u662f\u65e5\u671f\u3001\u65f6\u95f4\u6216 Decimal \u7b49\u65e0\u6cd5\u76f4\u63a5\u88ab JSON \u5e8f\u5217\u5316\u7684\u7279\u6b8a\u7c7b\u578b<br \/>\n                    if isinstance(value, (date, datetime, timedelta, Decimal)):<br \/>\n                        # \u5982\u679c\u662f&#xff0c;\u5219\u4f7f\u7528\u81ea\u5b9a\u4e49\u7684 default_encoder \u51fd\u6570\u5c06\u5176\u8f6c\u6362\u4e3a\u5b57\u7b26\u4e32<br \/>\n                        result[key] &#061; default_encoder(value)<\/p>\n<p>            # &#8212; \u6784\u5efa\u5e76\u8fd4\u56de JSON \u54cd\u5e94 &#8212;<br \/>\n            # \u6839\u636e\u67e5\u8be2\u7ed3\u679c\u662f\u5426\u4e3a\u7a7a&#xff0c;\u6784\u5efa\u4e0d\u540c\u7684\u54cd\u5e94\u7ed3\u6784<br \/>\n            # \u5982\u679c\u6709\u6570\u636e&#xff0c;\u8fd4\u56de {&#034;status&#034;: &#034;success&#034;, &#034;data&#034;: [&#8230;]}<br \/>\n            # \u5982\u679c\u65e0\u6570\u636e&#xff0c;\u8fd4\u56de {&#034;status&#034;: &#034;no_data&#034;, &#034;message&#034;: &#034;&#8230;&#034;}<br \/>\n            response_data &#061; {&#034;status&#034;: &#034;success&#034;, &#034;data&#034;: results} if results else {&#034;status&#034;: &#034;no_data&#034;,<br \/>\n                                                                                    &#034;message&#034;: &#034;\u672a\u627e\u5230\u5929\u6c14\u6570\u636e&#xff0c;\u8bf7\u786e\u8ba4\u57ce\u5e02\u548c\u65e5\u671f\u3002&#034;}<\/p>\n<p>            # \u5c06 Python \u5b57\u5178\u5e8f\u5217\u5316\u4e3a JSON \u5b57\u7b26\u4e32<br \/>\n            # cls&#061;DateEncoder: \u4f7f\u7528\u81ea\u5b9a\u4e49\u7684 JSONEncoder \u6765\u5904\u7406\u5e8f\u5217\u5316\u8fc7\u7a0b\u4e2d\u9047\u5230\u7684\u5176\u4ed6\u7279\u6b8a\u7c7b\u578b<br \/>\n            # ensure_ascii&#061;False: \u786e\u4fdd\u4e2d\u6587\u5b57\u7b26\u4e0d\u88ab\u8f6c\u4e49&#xff0c;\u76f4\u63a5\u663e\u793a<br \/>\n            return json.dumps(response_data, cls&#061;DateEncoder, ensure_ascii&#061;False)<\/p>\n<p>        except Exception as e:<br \/>\n            # &#8212; \u5f02\u5e38\u5904\u7406 &#8212;<br \/>\n            # \u5982\u679c\u5728\u6267\u884c\u8fc7\u7a0b\u4e2d\u53d1\u751f\u4efb\u4f55\u9519\u8bef&#xff08;\u5982 SQL \u8bed\u6cd5\u9519\u8bef\u3001\u6570\u636e\u5e93\u8fde\u63a5\u5931\u8d25\u7b49&#xff09;<br \/>\n            # \u4f7f\u7528\u65e5\u5fd7\u8bb0\u5f55\u5668\u8bb0\u5f55\u9519\u8bef\u4fe1\u606f<br \/>\n            logger.error(f&#034;\u5929\u6c14\u67e5\u8be2\u9519\u8bef: {str(e)}&#034;)<\/p>\n<p>            # \u8fd4\u56de\u4e00\u4e2a\u5305\u542b\u9519\u8bef\u72b6\u6001\u7684 JSON \u5b57\u7b26\u4e32<br \/>\n            return json.dumps({&#034;status&#034;: &#034;error&#034;, &#034;message&#034;: str(e)}, ensure_ascii&#061;False)<\/p>\n<p># \u7528\u4e8e\u72ec\u7acb\u6d4b\u8bd5 WeatherService \u7c7b<br \/>\n# if __name__ &#061;&#061; &#034;__main__&#034;:<br \/>\n#     service &#061; WeatherService()<br \/>\n#     sql &#061; &#034;SELECT * FROM weather_data WHERE city&#061;&#039;\u897f\u5b89&#039; limit 2&#034;<br \/>\n#     print(service.execute_query(sql))<\/p>\n<p>    # {&#034;status&#034;: &#034;success&#034;, &#034;data&#034;: results}<\/p>\n<p>    # {&#034;status&#034;: &#034;success&#034;,<br \/>\n    # &#034;data&#034;:<br \/>\n    #   [<br \/>\n    #   {&#034;id&#034;: 1, &#034;city&#034;: &#034;\u897f\u5b89&#034;, &#034;fx_date&#034;: &#034;2026-07-04&#034;, &#034;sunrise&#034;: &#034;7:21:00&#034;,<br \/>\n    #       &#034;sunset&#034;: &#034;17:37:00&#034;, &#034;moonrise&#034;: &#034;20:21:00&#034;, &#034;moonset&#034;: &#034;8:41:00&#034;,<br \/>\n    #       &#034;moon_phase&#034;: &#034;\u4e8f\u51f8\u6708&#034;, &#034;moon_phase_icon&#034;: &#034;805&#034;, &#034;temp_max&#034;: 12,<br \/>\n    #       &#034;temp_min&#034;: -2, &#034;icon_day&#034;: &#034;100&#034;, &#034;text_day&#034;: &#034;\u6674&#034;, &#034;icon_night&#034;: &#034;150&#034;,<br \/>\n    #       &#034;text_night&#034;: &#034;\u6674&#034;, &#034;wind360_day&#034;: 225, &#034;wind_dir_day&#034;: &#034;\u897f\u5357\u98ce&#034;, &#034;wind_scale_day&#034;: &#034;1-3&#034;,<br \/>\n    #       &#034;wind_speed_day&#034;: 3, &#034;wind360_night&#034;: 0, &#034;wind_dir_night&#034;: &#034;\u5317\u98ce&#034;, &#034;wind_scale_night&#034;: &#034;1-3&#034;,<br \/>\n    #       &#034;wind_speed_night&#034;: 16, &#034;precip&#034;: 0.0, &#034;uv_index&#034;: 3, &#034;humidity&#034;: 29, &#034;pressure&#034;: 1016,<br \/>\n    #       &#034;vis&#034;: 25, &#034;cloud&#034;: 0, &#034;update_time&#034;: &#034;2026-07-04 11:13:00&#034;},<br \/>\n    #   {&#034;id&#034;: 2, &#034;city&#034;: &#034;\u897f\u5b89&#034;, &#034;fx_date&#034;: &#034;2026-07-05&#034;, &#034;sunrise&#034;: &#034;7:20:00&#034;, &#034;sunset&#034;: &#034;17:38:00&#034;,<br \/>\n    #       &#034;moonrise&#034;: &#034;21:26:00&#034;, &#034;moonset&#034;: &#034;9:03:00&#034;, &#034;moon_phase&#034;: &#034;\u4e8f\u51f8\u6708&#034;, &#034;moon_phase_icon&#034;: &#034;805&#034;,<br \/>\n    #       &#034;temp_max&#034;: 3, &#034;temp_min&#034;: -7, &#034;icon_day&#034;: &#034;101&#034;, &#034;text_day&#034;: &#034;\u591a\u4e91&#034;, &#034;icon_night&#034;: &#034;151&#034;,<br \/>\n    #       &#034;text_night&#034;: &#034;\u591a\u4e91&#034;, &#034;wind360_day&#034;: 0, &#034;wind_dir_day&#034;: &#034;\u5317\u98ce&#034;, &#034;wind_scale_day&#034;: &#034;1-3&#034;,<br \/>\n    #       &#034;wind_speed_day&#034;: 16, &#034;wind360_night&#034;: 45, &#034;wind_dir_night&#034;: &#034;\u4e1c\u5317\u98ce&#034;, &#034;wind_scale_night&#034;: &#034;1-3&#034;,<br \/>\n    #       &#034;wind_speed_night&#034;: 3, &#034;precip&#034;: 0.0, &#034;uv_index&#034;: 2, &#034;humidity&#034;: 19, &#034;pressure&#034;: 1030, &#034;vis&#034;: 25,<br \/>\n    #       &#034;cloud&#034;: 0, &#034;update_time&#034;: &#034;2026-07-04 11:13:00&#034;}<br \/>\n    #   ]<br \/>\n    #  } <\/p>\n<p>\u57fa\u4e8e MCP (Model Context Protocol) \u534f\u8bae\u7684\u5929\u6c14\u67e5\u8be2\u670d\u52a1\u3002\u5b83\u5c01\u88c5\u4e86\u6570\u636e\u5e93\u64cd\u4f5c&#xff0c;\u5e76\u901a\u8fc7 HTTP \u63a5\u53e3\u66b4\u9732\u67e5\u8be2\u80fd\u529b&#xff0c;\u5141\u8bb8\u5916\u90e8\u7cfb\u7edf&#xff08;\u5982 AI \u6a21\u578b&#xff09;\u901a\u8fc7 SQL \u8bed\u53e5\u67e5\u8be2\u5929\u6c14\u6570\u636e<\/p>\n<h4 id=\"63-mcp\">6.3 \u542f\u52a8MCP\u670d\u52a1\u5668<\/h4>\n<p><span style=\"color:#fe2c24\">create_weather_mcp_server(<\/span>)\u51fd\u6570<\/p>\n<p>\u76ee\u6807&#xff1a;<span style=\"color:#fe2c24\">\u521b\u5efa\u5e76\u542f\u52a8\u5929\u6c14 MCP \u670d\u52a1\u5668<\/span><\/p>\n<p>\u529f\u80fd&#xff1a;\u521d\u59cb\u5316 FastMCP&#xff0c;<span style=\"color:#fe2c24\">\u6ce8\u518c query_weather \u5de5\u5177&#xff0c;<\/span><span style=\"color:#be191c\">\u542f\u52a8 FastAPI \u670d\u52a1\u5668&#xff0c;<\/span><span style=\"color:#ad720d\">\u76d1\u542c\u7aef\u53e3 6001<\/span><\/p>\n<p># \u521b\u5efa\u5e76\u8fd0\u884c MCP \u670d\u52a1\u5668\u7684\u4e3b\u51fd\u6570<br \/>\ndef create_weather_mcp_server():<br \/>\n    # \u521b\u5efa\u4e00\u4e2a FastMCP \u670d\u52a1\u5668\u5b9e\u4f8b<br \/>\n    weather_mcp &#061; FastMCP(<br \/>\n        name&#061;&#034;WeatherTools&#034;,  # \u670d\u52a1\u5668\u7684\u540d\u79f0<br \/>\n        instructions&#061;&#034;\u5929\u6c14\u67e5\u8be2\u5de5\u5177&#xff0c;\u57fa\u4e8e weather_data \u8868\u3002&#034;,  # \u670d\u52a1\u5668\u7684\u63cf\u8ff0\u6216\u6307\u4ee4&#xff0c;\u4f9b AI \u6a21\u578b\u7406\u89e3\u5176\u529f\u80fd<br \/>\n        log_level&#061;&#034;ERROR&#034;,  # \u8bbe\u7f6e\u65e5\u5fd7\u7ea7\u522b&#xff0c;\u53ea\u663e\u793a ERROR \u53ca\u4ee5\u4e0a\u7ea7\u522b\u7684\u65e5\u5fd7<br \/>\n        host&#061;&#034;127.0.0.1&#034;,  # \u670d\u52a1\u5668\u76d1\u542c\u7684 IP \u5730\u5740<br \/>\n        port&#061;8002  # \u670d\u52a1\u5668\u76d1\u542c\u7684\u7aef\u53e3\u53f7<br \/>\n    )<\/p>\n<p>    # \u5b9e\u4f8b\u5316\u4e4b\u524d\u5b9a\u4e49\u7684 WeatherService \u7c7b&#xff0c;\u7528\u4e8e\u5904\u7406\u5177\u4f53\u7684\u67e5\u8be2\u903b\u8f91<br \/>\n    service &#061; WeatherService()<\/p>\n<p>    # \u4f7f\u7528\u88c5\u9970\u5668\u5c06\u4e00\u4e2a\u51fd\u6570\u6ce8\u518c\u4e3a MCP \u670d\u52a1\u5668\u7684\u201c\u5de5\u5177\u201d&#xff08;tool&#xff09;<br \/>\n    # \u8fd9\u4f7f\u5f97 AI \u6a21\u578b\u53ef\u4ee5\u8c03\u7528\u8fd9\u4e2a\u51fd\u6570<br \/>\n    &#064;weather_mcp.tool(<br \/>\n        name&#061;&#034;query_weather&#034;,  # \u5de5\u5177\u7684\u540d\u79f0<br \/>\n        # \u5de5\u5177\u7684\u63cf\u8ff0&#xff0c;\u8be6\u7ec6\u8bf4\u660e\u4e86\u5de5\u5177\u7684\u529f\u80fd\u548c\u8f93\u5165\u53c2\u6570&#xff08;\u4e00\u4e2a SQL \u5b57\u7b26\u4e32&#xff09;\u7684\u683c\u5f0f<br \/>\n        description&#061;&#034;\u67e5\u8be2\u5929\u6c14\u6570\u636e&#xff0c;\u8f93\u5165 SQL&#xff0c;\u5982 &#039;SELECT * FROM weather_data WHERE city &#061; \\\\&#034;\u5317\u4eac\\\\&#034; AND fx_date &#061; \\\\&#034;2025-07-30\\\\&#034;&#039;&#034;<br \/>\n    )<br \/>\n    def query_weather(sql: str) -&gt; str:<br \/>\n        # \u5f53\u5de5\u5177\u88ab\u8c03\u7528\u65f6&#xff0c;\u9996\u5148\u8bb0\u5f55\u4e00\u6761\u4fe1\u606f\u65e5\u5fd7<br \/>\n        logger.info(f&#034;\u6267\u884c\u5929\u6c14\u67e5\u8be2: {sql}&#034;)<br \/>\n        # \u8c03\u7528 WeatherService \u5b9e\u4f8b\u7684 execute_query \u65b9\u6cd5\u6765\u6267\u884c SQL \u5e76\u8fd4\u56de\u7ed3\u679c<br \/>\n        return service.execute_query(sql)<\/p>\n<p>    # &#8212; \u670d\u52a1\u5668\u542f\u52a8 &#8212;<br \/>\n    # \u6253\u5370\u670d\u52a1\u5668\u4fe1\u606f\u5230\u63a7\u5236\u53f0<br \/>\n    logger.info(&#034;&#061;&#061;&#061; \u5929\u6c14MCP\u670d\u52a1\u5668\u4fe1\u606f &#061;&#061;&#061;&#034;)<br \/>\n    logger.info(f&#034;\u540d\u79f0: {weather_mcp.name}&#034;)<br \/>\n    logger.info(f&#034;\u63cf\u8ff0: {weather_mcp.instructions}&#034;)<\/p>\n<p>    # \u8fd0\u884c\u670d\u52a1\u5668&#xff0c;\u4f7f\u5176\u5f00\u59cb\u76d1\u542c\u8bf7\u6c42<br \/>\n    try:<br \/>\n        print(&#034;\u670d\u52a1\u5668\u5df2\u542f\u52a8&#xff0c;\u8bf7\u8bbf\u95ee http:\/\/127.0.0.1:8002\/mcp&#034;)<br \/>\n        # \u4f7f\u7528 streamable-http \u4f5c\u4e3a\u4f20\u8f93\u534f\u8bae\u542f\u52a8\u670d\u52a1\u5668<br \/>\n        weather_mcp.run(transport&#061;&#034;streamable-http&#034;)<br \/>\n    except Exception as e:<br \/>\n        # \u5982\u679c\u670d\u52a1\u5668\u542f\u52a8\u5931\u8d25&#xff0c;\u6253\u5370\u9519\u8bef\u4fe1\u606f<br \/>\n        print(f&#034;\u670d\u52a1\u5668\u542f\u52a8\u5931\u8d25: {e}&#034;)<\/p>\n<p># Python \u7684\u6807\u51c6\u5165\u53e3\u70b9<br \/>\n# \u5f53\u76f4\u63a5\u8fd0\u884c\u6b64\u811a\u672c\u65f6&#xff0c;\u4e0b\u9762\u7684\u4ee3\u7801\u5757\u4f1a\u88ab\u6267\u884c<br \/>\nif __name__ &#061;&#061; &#039;__main__&#039;:<br \/>\n    create_weather_mcp_server() <\/p>\n<p><span style=\"color:#fe2c24\">\/mcp_server\/mcp_weather_server.py\u6574\u4f53\u4ee3\u7801:<\/span><\/p>\n<p># -*- coding: utf-8 -*-<br \/>\n&#034;&#034;&#034;<br \/>\n\u8fd9\u662f\u4e00\u4e2a\u57fa\u4e8e FastMCP \u6846\u67b6\u7684\u5929\u6c14\u67e5\u8be2\u670d\u52a1\u3002<br \/>\n\u5b83\u8fde\u63a5 MySQL \u6570\u636e\u5e93&#xff0c;\u901a\u8fc7\u63a5\u6536 SQL \u67e5\u8be2\u8bed\u53e5\u6765\u8fd4\u56de\u5929\u6c14\u6570\u636e\u3002<br \/>\n&#034;&#034;&#034;<\/p>\n<p># \u5bfc\u5165\u5fc5\u8981\u7684\u5e93<br \/>\nimport mysql.connector  # \u7528\u4e8e\u8fde\u63a5\u548c\u64cd\u4f5c MySQL \u6570\u636e\u5e93<br \/>\nimport json  # \u7528\u4e8e\u5904\u7406 JSON \u6570\u636e\u7684\u5e8f\u5217\u5316\u548c\u53cd\u5e8f\u5217\u5316<br \/>\nfrom datetime import date, datetime, timedelta  # \u7528\u4e8e\u5904\u7406\u65e5\u671f\u548c\u65f6\u95f4\u5bf9\u8c61<br \/>\nfrom decimal import Decimal  # \u7528\u4e8e\u5904\u7406\u9ad8\u7cbe\u5ea6\u7684\u5341\u8fdb\u5236\u6570&#xff0c;\u5982\u6570\u636e\u5e93\u4e2d\u7684 DECIMAL \u7c7b\u578b<\/p>\n<p># \u4ece\u81ea\u5b9a\u4e49\u6a21\u5757\u4e2d\u5bfc\u5165 FastMCP \u7c7b&#xff0c;\u8fd9\u662f\u6784\u5efa MCP \u670d\u52a1\u5668\u7684\u6838\u5fc3<br \/>\nfrom mcp.server.fastmcp import FastMCP<\/p>\n<p># \u4ece\u672c\u5730\u914d\u7f6e\u6587\u4ef6\u548c\u65e5\u5fd7\u6a21\u5757\u4e2d\u5bfc\u5165\u914d\u7f6e\u548c\u65e5\u5fd7\u8bb0\u5f55\u5668<br \/>\nfrom config import Config<br \/>\nfrom create_logger import logger<\/p>\n<p># \u4ece\u81ea\u5b9a\u4e49\u5de5\u5177\u6a21\u5757\u4e2d\u5bfc\u5165\u65e5\u671f\u7f16\u7801\u5668\u548c\u9ed8\u8ba4\u7f16\u7801\u5668&#xff0c;\u7528\u4e8e\u683c\u5f0f\u5316\u7279\u6b8a\u6570\u636e\u7c7b\u578b<br \/>\nfrom utils.format import DateEncoder, default_encoder<\/p>\n<p># \u5b9e\u4f8b\u5316\u914d\u7f6e\u5bf9\u8c61&#xff0c;\u7528\u4e8e\u83b7\u53d6\u6570\u636e\u5e93\u8fde\u63a5\u4fe1\u606f&#xff08;host, user, password, database&#xff09;<br \/>\nconf &#061; Config()<\/p>\n<p># \u5b9a\u4e49\u5929\u6c14\u670d\u52a1\u7c7b&#xff0c;\u7528\u4e8e\u5c01\u88c5\u6240\u6709\u4e0e\u5929\u6c14\u6570\u636e\u76f8\u5173\u7684\u6570\u636e\u5e93\u64cd\u4f5c<br \/>\nclass WeatherService:<br \/>\n    def __init__(self):<br \/>\n        # \u5728\u7c7b\u521d\u59cb\u5316\u65f6&#xff0c;\u4f7f\u7528\u914d\u7f6e\u4fe1\u606f\u5efa\u7acb\u4e0e MySQL \u6570\u636e\u5e93\u7684\u8fde\u63a5<br \/>\n        # \u8fd9\u4e2a\u8fde\u63a5\u4f1a\u5728\u6574\u4e2a WeatherService \u5b9e\u4f8b\u7684\u751f\u547d\u5468\u671f\u5185\u4fdd\u6301<br \/>\n        self.conn &#061; mysql.connector.connect(<br \/>\n            host&#061;conf.host,<br \/>\n            user&#061;conf.user,<br \/>\n            password&#061;conf.password,<br \/>\n            database&#061;conf.database<br \/>\n        )<\/p>\n<p>    # \u5b9a\u4e49\u4e00\u4e2a\u6267\u884c SQL \u67e5\u8be2\u7684\u65b9\u6cd5<br \/>\n    # \u53c2\u6570: sql (str) &#8211; \u4e00\u4e2a\u5b8c\u6574\u7684 SQL \u67e5\u8be2\u5b57\u7b26\u4e32<br \/>\n    # \u8fd4\u56de: str &#8211; \u4e00\u4e2a JSON \u683c\u5f0f\u7684\u5b57\u7b26\u4e32&#xff0c;\u5305\u542b\u67e5\u8be2\u7ed3\u679c\u6216\u9519\u8bef\u4fe1\u606f<br \/>\n    def execute_query(self, sql: str) -&gt; str:<br \/>\n        try:<br \/>\n            # \u521b\u5efa\u4e00\u4e2a\u6e38\u6807&#xff08;cursor&#xff09;&#xff0c;dictionary&#061;True \u8868\u793a\u67e5\u8be2\u7ed3\u679c\u5c06\u4ee5\u5b57\u5178\u5217\u8868\u7684\u5f62\u5f0f\u8fd4\u56de<br \/>\n            # \u8fd9\u6837\u53ef\u4ee5\u901a\u8fc7\u5217\u540d&#xff08;\u5982 row[&#039;city&#039;]&#xff09;\u800c\u4e0d\u662f\u7d22\u5f15\u6765\u8bbf\u95ee\u6570\u636e<br \/>\n            cursor &#061; self.conn.cursor(dictionary&#061;True)<\/p>\n<p>            # \u6267\u884c\u4f20\u5165\u7684 SQL \u8bed\u53e5<br \/>\n            cursor.execute(sql)<\/p>\n<p>            # \u83b7\u53d6\u6240\u6709\u67e5\u8be2\u7ed3\u679c<br \/>\n            results &#061; cursor.fetchall()<\/p>\n<p>            # \u5173\u95ed\u6e38\u6807&#xff0c;\u91ca\u653e\u8d44\u6e90<br \/>\n            cursor.close()<\/p>\n<p>            # &#8212; \u6570\u636e\u683c\u5f0f\u5316 &#8212;<br \/>\n            # \u904d\u5386\u67e5\u8be2\u7ed3\u679c\u4e2d\u7684\u6bcf\u4e00\u884c&#xff08;\u6bcf\u4e2a\u7ed3\u679c\u90fd\u662f\u4e00\u4e2a\u5b57\u5178&#xff09;<br \/>\n            for result in results:<br \/>\n                # \u904d\u5386\u5b57\u5178\u4e2d\u7684\u6bcf\u4e00\u4e2a\u952e\u503c\u5bf9<br \/>\n                for key, value in result.items():<br \/>\n                    # \u68c0\u67e5\u503c\u662f\u5426\u662f\u65e5\u671f\u3001\u65f6\u95f4\u6216 Decimal \u7b49\u65e0\u6cd5\u76f4\u63a5\u88ab JSON \u5e8f\u5217\u5316\u7684\u7279\u6b8a\u7c7b\u578b<br \/>\n                    if isinstance(value, (date, datetime, timedelta, Decimal)):<br \/>\n                        # \u5982\u679c\u662f&#xff0c;\u5219\u4f7f\u7528\u81ea\u5b9a\u4e49\u7684 default_encoder \u51fd\u6570\u5c06\u5176\u8f6c\u6362\u4e3a\u5b57\u7b26\u4e32<br \/>\n                        result[key] &#061; default_encoder(value)<\/p>\n<p>            # &#8212; \u6784\u5efa\u5e76\u8fd4\u56de JSON \u54cd\u5e94 &#8212;<br \/>\n            # \u6839\u636e\u67e5\u8be2\u7ed3\u679c\u662f\u5426\u4e3a\u7a7a&#xff0c;\u6784\u5efa\u4e0d\u540c\u7684\u54cd\u5e94\u7ed3\u6784<br \/>\n            # \u5982\u679c\u6709\u6570\u636e&#xff0c;\u8fd4\u56de {&#034;status&#034;: &#034;success&#034;, &#034;data&#034;: [&#8230;]}<br \/>\n            # \u5982\u679c\u65e0\u6570\u636e&#xff0c;\u8fd4\u56de {&#034;status&#034;: &#034;no_data&#034;, &#034;message&#034;: &#034;&#8230;&#034;}<br \/>\n            response_data &#061; {&#034;status&#034;: &#034;success&#034;, &#034;data&#034;: results} if results else {&#034;status&#034;: &#034;no_data&#034;,<br \/>\n                                                                                    &#034;message&#034;: &#034;\u672a\u627e\u5230\u5929\u6c14\u6570\u636e&#xff0c;\u8bf7\u786e\u8ba4\u57ce\u5e02\u548c\u65e5\u671f\u3002&#034;}<\/p>\n<p>            # \u5c06 Python \u5b57\u5178\u5e8f\u5217\u5316\u4e3a JSON \u5b57\u7b26\u4e32<br \/>\n            # cls&#061;DateEncoder: \u4f7f\u7528\u81ea\u5b9a\u4e49\u7684 JSONEncoder \u6765\u5904\u7406\u5e8f\u5217\u5316\u8fc7\u7a0b\u4e2d\u9047\u5230\u7684\u5176\u4ed6\u7279\u6b8a\u7c7b\u578b<br \/>\n            # ensure_ascii&#061;False: \u786e\u4fdd\u4e2d\u6587\u5b57\u7b26\u4e0d\u88ab\u8f6c\u4e49&#xff0c;\u76f4\u63a5\u663e\u793a<br \/>\n            return json.dumps(response_data, cls&#061;DateEncoder, ensure_ascii&#061;False)<\/p>\n<p>        except Exception as e:<br \/>\n            # &#8212; \u5f02\u5e38\u5904\u7406 &#8212;<br \/>\n            # \u5982\u679c\u5728\u6267\u884c\u8fc7\u7a0b\u4e2d\u53d1\u751f\u4efb\u4f55\u9519\u8bef&#xff08;\u5982 SQL \u8bed\u6cd5\u9519\u8bef\u3001\u6570\u636e\u5e93\u8fde\u63a5\u5931\u8d25\u7b49&#xff09;<br \/>\n            # \u4f7f\u7528\u65e5\u5fd7\u8bb0\u5f55\u5668\u8bb0\u5f55\u9519\u8bef\u4fe1\u606f<br \/>\n            logger.error(f&#034;\u5929\u6c14\u67e5\u8be2\u9519\u8bef: {str(e)}&#034;)<\/p>\n<p>            # \u8fd4\u56de\u4e00\u4e2a\u5305\u542b\u9519\u8bef\u72b6\u6001\u7684 JSON \u5b57\u7b26\u4e32<br \/>\n            return json.dumps({&#034;status&#034;: &#034;error&#034;, &#034;message&#034;: str(e)}, ensure_ascii&#061;False)<\/p>\n<p># \u521b\u5efa\u5e76\u8fd0\u884c MCP \u670d\u52a1\u5668\u7684\u4e3b\u51fd\u6570<br \/>\ndef create_weather_mcp_server():<br \/>\n    # \u521b\u5efa\u4e00\u4e2a FastMCP \u670d\u52a1\u5668\u5b9e\u4f8b<br \/>\n    weather_mcp &#061; FastMCP(<br \/>\n        name&#061;&#034;WeatherTools&#034;,  # \u670d\u52a1\u5668\u7684\u540d\u79f0<br \/>\n        instructions&#061;&#034;\u5929\u6c14\u67e5\u8be2\u5de5\u5177&#xff0c;\u57fa\u4e8e weather_data \u8868\u3002&#034;,  # \u670d\u52a1\u5668\u7684\u63cf\u8ff0\u6216\u6307\u4ee4&#xff0c;\u4f9b AI \u6a21\u578b\u7406\u89e3\u5176\u529f\u80fd<br \/>\n        log_level&#061;&#034;ERROR&#034;,  # \u8bbe\u7f6e\u65e5\u5fd7\u7ea7\u522b&#xff0c;\u53ea\u663e\u793a ERROR \u53ca\u4ee5\u4e0a\u7ea7\u522b\u7684\u65e5\u5fd7<br \/>\n        host&#061;&#034;127.0.0.1&#034;,  # \u670d\u52a1\u5668\u76d1\u542c\u7684 IP \u5730\u5740<br \/>\n        port&#061;8002  # \u670d\u52a1\u5668\u76d1\u542c\u7684\u7aef\u53e3\u53f7<br \/>\n    )<\/p>\n<p>    # \u5b9e\u4f8b\u5316\u4e4b\u524d\u5b9a\u4e49\u7684 WeatherService \u7c7b&#xff0c;\u7528\u4e8e\u5904\u7406\u5177\u4f53\u7684\u67e5\u8be2\u903b\u8f91<br \/>\n    service &#061; WeatherService()<\/p>\n<p>    # \u4f7f\u7528\u88c5\u9970\u5668\u5c06\u4e00\u4e2a\u51fd\u6570\u6ce8\u518c\u4e3a MCP \u670d\u52a1\u5668\u7684\u201c\u5de5\u5177\u201d&#xff08;tool&#xff09;<br \/>\n    # \u8fd9\u4f7f\u5f97 AI \u6a21\u578b\u53ef\u4ee5\u8c03\u7528\u8fd9\u4e2a\u51fd\u6570<br \/>\n    &#064;weather_mcp.tool(<br \/>\n        name&#061;&#034;query_weather&#034;,  # \u5de5\u5177\u7684\u540d\u79f0<br \/>\n        # \u5de5\u5177\u7684\u63cf\u8ff0&#xff0c;\u8be6\u7ec6\u8bf4\u660e\u4e86\u5de5\u5177\u7684\u529f\u80fd\u548c\u8f93\u5165\u53c2\u6570&#xff08;\u4e00\u4e2a SQL \u5b57\u7b26\u4e32&#xff09;\u7684\u683c\u5f0f<br \/>\n        description&#061;&#034;\u67e5\u8be2\u5929\u6c14\u6570\u636e&#xff0c;\u8f93\u5165 SQL&#xff0c;\u5982 &#039;SELECT * FROM weather_data WHERE city &#061; \\\\&#034;\u5317\u4eac\\\\&#034; AND fx_date &#061; \\\\&#034;2025-07-30\\\\&#034;&#039;&#034;<br \/>\n    )<br \/>\n    def query_weather(sql: str) -&gt; str:<br \/>\n        # \u5f53\u5de5\u5177\u88ab\u8c03\u7528\u65f6&#xff0c;\u9996\u5148\u8bb0\u5f55\u4e00\u6761\u4fe1\u606f\u65e5\u5fd7<br \/>\n        logger.info(f&#034;\u6267\u884c\u5929\u6c14\u67e5\u8be2: {sql}&#034;)<br \/>\n        # \u8c03\u7528 WeatherService \u5b9e\u4f8b\u7684 execute_query \u65b9\u6cd5\u6765\u6267\u884c SQL \u5e76\u8fd4\u56de\u7ed3\u679c<br \/>\n        return service.execute_query(sql)<\/p>\n<p>    # &#8212; \u670d\u52a1\u5668\u542f\u52a8 &#8212;<br \/>\n    # \u6253\u5370\u670d\u52a1\u5668\u4fe1\u606f\u5230\u63a7\u5236\u53f0<br \/>\n    logger.info(&#034;&#061;&#061;&#061; \u5929\u6c14MCP\u670d\u52a1\u5668\u4fe1\u606f &#061;&#061;&#061;&#034;)<br \/>\n    logger.info(f&#034;\u540d\u79f0: {weather_mcp.name}&#034;)<br \/>\n    logger.info(f&#034;\u63cf\u8ff0: {weather_mcp.instructions}&#034;)<\/p>\n<p>    # \u8fd0\u884c\u670d\u52a1\u5668&#xff0c;\u4f7f\u5176\u5f00\u59cb\u76d1\u542c\u8bf7\u6c42<br \/>\n    try:<br \/>\n        print(&#034;\u670d\u52a1\u5668\u5df2\u542f\u52a8&#xff0c;\u8bf7\u8bbf\u95ee http:\/\/127.0.0.1:8002\/mcp&#034;)<br \/>\n        # \u4f7f\u7528 streamable-http \u4f5c\u4e3a\u4f20\u8f93\u534f\u8bae\u542f\u52a8\u670d\u52a1\u5668<br \/>\n        weather_mcp.run(transport&#061;&#034;streamable-http&#034;)<br \/>\n    except Exception as e:<br \/>\n        # \u5982\u679c\u670d\u52a1\u5668\u542f\u52a8\u5931\u8d25&#xff0c;\u6253\u5370\u9519\u8bef\u4fe1\u606f<br \/>\n        print(f&#034;\u670d\u52a1\u5668\u542f\u52a8\u5931\u8d25: {e}&#034;)<\/p>\n<p># Python \u7684\u6807\u51c6\u5165\u53e3\u70b9<br \/>\n# \u5f53\u76f4\u63a5\u8fd0\u884c\u6b64\u811a\u672c\u65f6&#xff0c;\u4e0b\u9762\u7684\u4ee3\u7801\u5757\u4f1a\u88ab\u6267\u884c<br \/>\nif __name__ &#061;&#061; &#039;__main__&#039;:<br \/>\n    create_weather_mcp_server()<\/p>\n<p># \u7528\u4e8e\u72ec\u7acb\u6d4b\u8bd5 WeatherService \u7c7b<br \/>\n# if __name__ &#061;&#061; &#034;__main__&#034;:<br \/>\n#     service &#061; WeatherService()<br \/>\n#     sql &#061; &#034;SELECT * FROM weather_data WHERE city&#061;&#039;\u897f\u5b89&#039; limit 2&#034;<br \/>\n#     print(service.execute_query(sql))<\/p>\n<p>    # {&#034;status&#034;: &#034;success&#034;, &#034;data&#034;: results}<\/p>\n<p>    # {&#034;status&#034;: &#034;success&#034;,<br \/>\n    # &#034;data&#034;:<br \/>\n    #   [<br \/>\n    #   {&#034;id&#034;: 1, &#034;city&#034;: &#034;\u897f\u5b89&#034;, &#034;fx_date&#034;: &#034;2026-07-04&#034;, &#034;sunrise&#034;: &#034;7:21:00&#034;,<br \/>\n    #       &#034;sunset&#034;: &#034;17:37:00&#034;, &#034;moonrise&#034;: &#034;20:21:00&#034;, &#034;moonset&#034;: &#034;8:41:00&#034;,<br \/>\n    #       &#034;moon_phase&#034;: &#034;\u4e8f\u51f8\u6708&#034;, &#034;moon_phase_icon&#034;: &#034;805&#034;, &#034;temp_max&#034;: 12,<br \/>\n    #       &#034;temp_min&#034;: -2, &#034;icon_day&#034;: &#034;100&#034;, &#034;text_day&#034;: &#034;\u6674&#034;, &#034;icon_night&#034;: &#034;150&#034;,<br \/>\n    #       &#034;text_night&#034;: &#034;\u6674&#034;, &#034;wind360_day&#034;: 225, &#034;wind_dir_day&#034;: &#034;\u897f\u5357\u98ce&#034;, &#034;wind_scale_day&#034;: &#034;1-3&#034;,<br \/>\n    #       &#034;wind_speed_day&#034;: 3, &#034;wind360_night&#034;: 0, &#034;wind_dir_night&#034;: &#034;\u5317\u98ce&#034;, &#034;wind_scale_night&#034;: &#034;1-3&#034;,<br \/>\n    #       &#034;wind_speed_night&#034;: 16, &#034;precip&#034;: 0.0, &#034;uv_index&#034;: 3, &#034;humidity&#034;: 29, &#034;pressure&#034;: 1016,<br \/>\n    #       &#034;vis&#034;: 25, &#034;cloud&#034;: 0, &#034;update_time&#034;: &#034;2026-07-04 11:13:00&#034;},<br \/>\n    #   {&#034;id&#034;: 2, &#034;city&#034;: &#034;\u897f\u5b89&#034;, &#034;fx_date&#034;: &#034;2026-07-05&#034;, &#034;sunrise&#034;: &#034;7:20:00&#034;, &#034;sunset&#034;: &#034;17:38:00&#034;,<br \/>\n    #       &#034;moonrise&#034;: &#034;21:26:00&#034;, &#034;moonset&#034;: &#034;9:03:00&#034;, &#034;moon_phase&#034;: &#034;\u4e8f\u51f8\u6708&#034;, &#034;moon_phase_icon&#034;: &#034;805&#034;,<br \/>\n    #       &#034;temp_max&#034;: 3, &#034;temp_min&#034;: -7, &#034;icon_day&#034;: &#034;101&#034;, &#034;text_day&#034;: &#034;\u591a\u4e91&#034;, &#034;icon_night&#034;: &#034;151&#034;,<br \/>\n    #       &#034;text_night&#034;: &#034;\u591a\u4e91&#034;, &#034;wind360_day&#034;: 0, &#034;wind_dir_day&#034;: &#034;\u5317\u98ce&#034;, &#034;wind_scale_day&#034;: &#034;1-3&#034;,<br \/>\n    #       &#034;wind_speed_day&#034;: 16, &#034;wind360_night&#034;: 45, &#034;wind_dir_night&#034;: &#034;\u4e1c\u5317\u98ce&#034;, &#034;wind_scale_night&#034;: &#034;1-3&#034;,<br \/>\n    #       &#034;wind_speed_night&#034;: 3, &#034;precip&#034;: 0.0, &#034;uv_index&#034;: 2, &#034;humidity&#034;: 19, &#034;pressure&#034;: 1030, &#034;vis&#034;: 25,<br \/>\n    #       &#034;cloud&#034;: 0, &#034;update_time&#034;: &#034;2026-07-04 11:13:00&#034;}<br \/>\n    #   ]<br \/>\n    #  } <\/p>\n<p>\u5ba2\u6237\u7aef\u6d4b\u8bd5&#xff1a;<\/p>\n<p>\u4f4d\u7f6e&#xff1a;<span style=\"color:#fe2c24\">\/test\/test_weather_mcp_server.py<\/span><\/p>\n<p>\u5f02\u6b65 Python \u811a\u672c&#xff0c;\u7528\u4e8e\u8fde\u63a5\u5e76\u6d4b\u8bd5\u4e4b\u524d\u521b\u5efa\u7684\u00a0WeatherTools\u00a0MCP \u670d\u52a1\u5668,\u3002\u5b83\u6a21\u62df\u4e86\u4e00\u4e2a AI \u5ba2\u6237\u7aef&#xff0c;\u901a\u8fc7 MCP \u534f\u8bae\u4e0e\u670d\u52a1\u5668\u901a\u4fe1&#xff0c;\u5e76\u8c03\u7528\u5176\u63d0\u4f9b\u7684\u00a0query_weather\u00a0\u5de5\u5177<\/p>\n<p># -*- coding: utf-8 -*-<br \/>\n&#034;&#034;&#034;<br \/>\n\u8fd9\u662f\u4e00\u4e2a\u7528\u4e8e\u6d4b\u8bd5 WeatherTools MCP \u670d\u52a1\u5668\u7684\u5ba2\u6237\u7aef\u811a\u672c\u3002<br \/>\n\u5b83\u4f7f\u7528\u5f02\u6b65 I\/O \u6765\u8fde\u63a5\u670d\u52a1\u5668\u3001\u83b7\u53d6\u5de5\u5177\u5217\u8868\u5e76\u6267\u884c\u67e5\u8be2\u3002<br \/>\n&#034;&#034;&#034;<\/p>\n<p># \u5bfc\u5165\u5fc5\u8981\u7684\u5e93<br \/>\nimport asyncio  # \u7528\u4e8e\u7f16\u5199\u5f02\u6b65\u4ee3\u7801&#xff0c;\u5904\u7406\u5e76\u53d1\u64cd\u4f5c<br \/>\nimport json  # \u7528\u4e8e\u89e3\u6790\u4ece\u670d\u52a1\u5668\u8fd4\u56de\u7684 JSON \u5b57\u7b26\u4e32<\/p>\n<p># \u4ece langchain_mcp_adapters \u5e93\u4e2d\u5bfc\u5165\u5de5\u5177&#xff0c;\u7528\u4e8e\u4ece MCP \u4f1a\u8bdd\u4e2d\u52a0\u8f7d\u53ef\u7528\u5de5\u5177<br \/>\nfrom langchain_mcp_adapters.tools import load_mcp_tools<\/p>\n<p># \u4ece mcp \u5e93\u4e2d\u5bfc\u5165\u6838\u5fc3\u5ba2\u6237\u7aef\u7c7b<br \/>\nfrom mcp import ClientSession<br \/>\n# \u4ece mcp \u5e93\u4e2d\u5bfc\u5165\u7528\u4e8e\u5efa\u7acb streamable-http \u8fde\u63a5\u7684\u5ba2\u6237\u7aef\u51fd\u6570<br \/>\nfrom mcp.client.streamable_http import streamablehttp_client<\/p>\n<p># \u5b9a\u4e49\u8981\u8fde\u63a5\u7684 MCP \u670d\u52a1\u5668\u5730\u5740<br \/>\n# \u8fd9\u4e0e\u60a8\u4e4b\u524d\u542f\u52a8\u7684\u670d\u52a1\u5668\u5730\u5740\u548c\u7aef\u53e3\u4e00\u81f4<br \/>\nserver_url &#061; &#034;http:\/\/127.0.0.1:8002\/mcp&#034;<\/p>\n<p># \u5b9a\u4e49\u4e00\u4e2a\u5f02\u6b65\u51fd\u6570\u6765\u6267\u884c\u6d4b\u8bd5<br \/>\nasync def test_weather_mcp():<br \/>\n    try:<br \/>\n        # &#8212; 1. \u5efa\u7acb\u4e0e\u670d\u52a1\u5668\u7684\u8fde\u63a5 &#8212;<br \/>\n        # \u4f7f\u7528 streamablehttp_client \u4f5c\u4e3a\u5f02\u6b65\u4e0a\u4e0b\u6587\u7ba1\u7406\u5668\u6765\u8fde\u63a5\u5230\u670d\u52a1\u5668<br \/>\n        # \u5b83\u4f1a\u8fd4\u56de\u4e00\u5bf9\u8bfb\u5199\u901a\u9053 (read, write) \u548c\u4e00\u4e2a get_session_id \u51fd\u6570&#xff08;\u6b64\u5904\u7528 _ \u5ffd\u7565&#xff09;<br \/>\n        async with streamablehttp_client(server_url) as (read, write, _):<\/p>\n<p>            # &#8212; 2. \u521d\u59cb\u5316 MCP \u4f1a\u8bdd &#8212;<br \/>\n            # \u4f7f\u7528\u4e0a\u4e00\u6b65\u83b7\u53d6\u7684\u8bfb\u5199\u901a\u9053\u521b\u5efa\u4e00\u4e2a ClientSession \u5b9e\u4f8b<br \/>\n            async with ClientSession(read, write) as session:<br \/>\n                try:<br \/>\n                    # \u5411\u670d\u52a1\u5668\u53d1\u9001\u521d\u59cb\u5316\u8bf7\u6c42&#xff0c;\u5efa\u7acb MCP \u534f\u8bae\u4f1a\u8bdd<br \/>\n                    await session.initialize()<br \/>\n                    print(&#034;\u4f1a\u8bdd\u521d\u59cb\u5316\u6210\u529f&#xff0c;\u53ef\u4ee5\u5f00\u59cb\u8c03\u7528\u5de5\u5177\u3002&#034;)<\/p>\n<p>                    # &#8212; 3. \u83b7\u53d6\u670d\u52a1\u5668\u63d0\u4f9b\u7684\u5de5\u5177\u5217\u8868 &#8212;<br \/>\n                    # \u8c03\u7528 load_mcp_tools \u51fd\u6570&#xff0c;\u5b83\u4f1a\u81ea\u52a8\u5411\u670d\u52a1\u5668\u67e5\u8be2\u5e76\u52a0\u8f7d\u6240\u6709\u53ef\u7528\u7684\u5de5\u5177<br \/>\n                    tools &#061; await load_mcp_tools(session)<br \/>\n                    # \u6253\u5370\u5de5\u5177\u5217\u8868&#xff0c;\u7528\u4e8e\u9a8c\u8bc1\u8fde\u63a5\u548c\u5de5\u5177\u53d1\u73b0\u662f\u5426\u6210\u529f<br \/>\n                    print(f&#034;tools&#8211;&gt;{tools}&#034;)<\/p>\n<p>                    # &#8212; 4. \u6d4b\u8bd5\u8c03\u7528\u5de5\u5177&#xff1a;\u67e5\u8be2\u6307\u5b9a\u65e5\u671f\u5929\u6c14 &#8212;<br \/>\n                    # \u6784\u9020\u4e00\u4e2a SQL \u67e5\u8be2\u5b57\u7b26\u4e32&#xff0c;\u4f5c\u4e3a\u5de5\u5177\u7684\u8f93\u5165\u53c2\u6570<br \/>\n                    sql &#061; &#034;SELECT * FROM weather_data WHERE city &#061; &#039;\u897f\u5b89&#039; AND fx_date &#061; &#039;2026-07-04&#039;&#034;<\/p>\n<p>                    # \u4f7f\u7528 session.call_tool \u65b9\u6cd5\u8c03\u7528\u670d\u52a1\u5668\u4e0a\u540d\u4e3a &#034;query_weather&#034; \u7684\u5de5\u5177<br \/>\n                    # \u7b2c\u4e00\u4e2a\u53c2\u6570\u662f\u5de5\u5177\u540d&#xff0c;\u7b2c\u4e8c\u4e2a\u53c2\u6570\u662f\u4e00\u4e2a\u5b57\u5178&#xff0c;\u5305\u542b\u5de5\u5177\u6240\u9700\u7684\u53c2\u6570<br \/>\n                    result &#061; await session.call_tool(&#034;query_weather&#034;, {&#034;sql&#034;: sql})<\/p>\n<p>                    # \u6253\u5370\u539f\u59cb\u8fd4\u56de\u7ed3\u679c&#xff0c;\u7528\u4e8e\u8c03\u8bd5<br \/>\n                    print(11111, result)<br \/>\n                    # \u6ce8\u610f&#xff1a;result \u4e0d\u662f\u4e00\u4e2a\u7b80\u5355\u7684\u5b57\u7b26\u4e32&#xff0c;\u800c\u662f\u4e00\u4e2a\u5305\u542b TextContent \u548c structuredContent \u7684\u5bf9\u8c61<\/p>\n<p>                    # \u68c0\u67e5 result \u662f\u5426\u4e3a\u5b57\u7b26\u4e32\u7c7b\u578b<br \/>\n                    print(22222, isinstance(result, str))<br \/>\n                    # \u8f93\u51fa\u4e3a False&#xff0c;\u8bc1\u5b9e result \u662f\u4e00\u4e2a\u590d\u6742\u5bf9\u8c61<\/p>\n<p>                    # \u5c1d\u8bd5\u5c06 result \u89e3\u6790\u4e3a JSON<br \/>\n                    # \u8fd9\u91cc\u7684\u903b\u8f91\u6709\u8bef&#xff0c;\u56e0\u4e3a result \u672c\u8eab\u4e0d\u662f JSON \u5b57\u7b26\u4e32&#xff0c;\u6240\u4ee5 json.loads(result) \u4f1a\u5931\u8d25<br \/>\n                    # \u6b63\u786e\u7684\u505a\u6cd5\u662f\u63d0\u53d6 result.content[0].text \u6216 result.structuredContent[&#039;result&#039;]<br \/>\n                    result_data &#061; json.loads(result) if isinstance(result, str) else result<\/p>\n<p>                    # \u6253\u5370\u6700\u7ec8\u5904\u7406\u540e\u7684\u7ed3\u679c\u6570\u636e<br \/>\n                    print(f&#034;\u6307\u5b9a\u65e5\u671f\u5929\u6c14\u7ed3\u679c&#xff1a;{result_data}&#034;)<br \/>\n                    # \u6b64\u65f6 result_data \u4ecd\u7136\u662f\u539f\u59cb\u7684\u590d\u6742\u5bf9\u8c61&#xff0c;\u5305\u542b\u4e86\u670d\u52a1\u5668\u8fd4\u56de\u7684 JSON \u5b57\u7b26\u4e32<\/p>\n<p>                    # &#8212; 5. (\u5df2\u6ce8\u91ca) \u6d4b\u8bd5\u8c03\u7528\u5de5\u5177&#xff1a;\u67e5\u8be2\u672a\u67653\u5929\u5929\u6c14 &#8212;<br \/>\n                    # \u4ee5\u4e0b\u662f\u53e6\u4e00\u4e2a\u6d4b\u8bd5\u7528\u4f8b&#xff0c;\u7528\u4e8e\u67e5\u8be2\u4e00\u4e2a\u65e5\u671f\u8303\u56f4\u5185\u7684\u5929\u6c14<br \/>\n                    # sql_range &#061; &#034;SELECT * FROM weather_data WHERE city &#061; &#039;\u897f\u5b89&#039; AND fx_date BETWEEN &#039;2026-07-04&#039; AND &#039;2026-07-06&#039;&#034;<br \/>\n                    # result_range &#061; await session.call_tool(&#034;query_weather&#034;, {&#034;sql&#034;: sql_range})<br \/>\n                    # result_range_data &#061; json.loads(result_range) if isinstance(result_range, str) else result_range<br \/>\n                    # print(f&#034;\u5929\u6c14\u8303\u56f4\u67e5\u8be2\u7ed3\u679c&#xff1a;{result_range_data}&#034;)<\/p>\n<p>                except Exception as e:<br \/>\n                    # \u6355\u83b7\u5e76\u6253\u5370\u5728\u4f1a\u8bdd\u5185\u90e8\u53d1\u751f\u7684\u4efb\u4f55\u9519\u8bef&#xff08;\u5982\u5de5\u5177\u8c03\u7528\u5931\u8d25&#xff09;<br \/>\n                    print(f&#034;\u5929\u6c14 MCP \u6d4b\u8bd5\u51fa\u9519&#xff1a;{str(e)}&#034;)<\/p>\n<p>    except Exception as e:<br \/>\n        # \u6355\u83b7\u5e76\u6253\u5370\u5728\u8fde\u63a5\u6216\u4f1a\u8bdd\u521d\u59cb\u5316\u9636\u6bb5\u53d1\u751f\u7684\u9519\u8bef<br \/>\n        print(f&#034;\u8fde\u63a5\u6216\u4f1a\u8bdd\u521d\u59cb\u5316\u65f6\u53d1\u751f\u9519\u8bef: {e}&#034;)<br \/>\n        print(&#034;\u8bf7\u786e\u8ba4\u670d\u52a1\u7aef\u811a\u672c\u5df2\u542f\u52a8\u5e76\u8fd0\u884c\u5728 http:\/\/127.0.0.1:8002\/mcp&#034;)<\/p>\n<p># Python \u7684\u6807\u51c6\u5165\u53e3\u70b9<br \/>\n# \u4f7f\u7528 asyncio.run() \u6765\u8fd0\u884c\u9876\u5c42\u7684\u5f02\u6b65\u51fd\u6570<br \/>\nif __name__ &#061;&#061; &#034;__main__&#034;:<br \/>\n    asyncio.run(test_weather_mcp()) <\/p>\n<h3 id=\"7-mcp\">7.\u7968\u52a1MCP\u670d\u52a1\u5668<\/h3>\n<p><span style=\"color:#fe2c24\">mcp_ticket_server.py&#xff1a;<\/span>\u7968\u52a1 MCP \u670d\u52a1\u5668&#xff0c;\u63d0\u4f9b<span style=\"color:#fe2c24\"> train_tickets\u3001flight_tickets \u548c concert_tickets \u8868\u7684 SELECT \u67e5\u8be2\u63a5\u53e3<\/span>&#xff0c;\u8fd4\u56de JSON \u683c\u5f0f\u7ed3\u679c<\/p>\n<p>\u6838\u5fc3\u529f\u80fd&#xff1a;<\/p>\n<ul>\n<li>\u521d\u59cb\u5316 MySQL \u6570\u636e\u5e93\u8fde\u63a5<\/li>\n<li>\u6267\u884c SELECT \u67e5\u8be2&#xff0c;\u8fd4\u56de JSON \u683c\u5f0f\u7ed3\u679c<\/li>\n<li>\u683c\u5f0f\u5316\u65e5\u671f\u548c\u6570\u503c\u5b57\u6bb5&#xff0c;\u786e\u4fdd JSON \u5e8f\u5217\u5316\u517c\u5bb9<\/li>\n<li>\u901a\u8fc7 FastAPI \u63d0\u4f9b HTTP \u63a5\u53e3&#xff0c;\u54cd\u5e94 MCP \u5de5\u5177\u8c03\u7528<\/li>\n<\/ul>\n<h4 id=\"71-ticketservice\">7.1 TicketService\u7c7b<\/h4>\n<p>\u76ee\u6807&#xff1a;\u63d0\u4f9b\u7968\u52a1\u6570\u636e\u67e5\u8be2\u670d\u52a1&#xff0c;<span style=\"color:#fe2c24\">\u54cd\u5e94\u4ee3\u7406\u7684 SQL \u8bf7\u6c42<\/span><\/p>\n<p>\u529f\u80fd&#xff1a;\u521d\u59cb\u5316 MySQL \u8fde\u63a5&#xff0c;\u6267\u884c SELECT \u67e5\u8be2&#xff0c;\u683c\u5f0f\u5316\u7ed3\u679c\u4e3a JSON<\/p>\n<p>\u4f4d\u7f6e&#xff1a;<span style=\"color:#fe2c24\">\/query_data\/query_ticket.py<\/span><\/p>\n<p>\u7968\u52a1\u67e5\u8be2\u670d\u52a1&#xff08;TicketService&#xff09;&#xff0c;\u5b83\u7684\u6838\u5fc3\u903b\u8f91\u4e0e\u4e4b\u524d\u7684\u5929\u6c14\u670d\u52a1\u975e\u5e38\u76f8\u4f3c&#xff0c;\u4e3b\u8981\u662f\u8d1f\u8d23\u8fde\u63a5\u6570\u636e\u5e93\u3001\u6267\u884c SQL \u5e76\u8fd4\u56de JSON \u683c\u5f0f\u7684\u7ed3\u679c<\/p>\n<p># \u5bfc\u5165\u5fc5\u8981\u7684\u5e93<br \/>\nimport mysql.connector  # \u7528\u4e8e\u8fde\u63a5\u548c\u64cd\u4f5c MySQL \u6570\u636e\u5e93<br \/>\nimport json  # \u7528\u4e8e\u5904\u7406 JSON \u6570\u636e\u7684\u5e8f\u5217\u5316\u548c\u53cd\u5e8f\u5217\u5316<br \/>\nfrom datetime import date, datetime, timedelta  # \u7528\u4e8e\u5904\u7406\u65e5\u671f\u548c\u65f6\u95f4\u5bf9\u8c61<br \/>\nfrom decimal import Decimal  # \u7528\u4e8e\u5904\u7406\u9ad8\u7cbe\u5ea6\u7684\u5341\u8fdb\u5236\u6570&#xff08;\u5982\u6570\u636e\u5e93\u4e2d\u7684\u91d1\u989d\u3001DECIMAL \u7c7b\u578b&#xff09;<\/p>\n<p># \u4ece mcp \u5e93\u4e2d\u5bfc\u5165 FastMCP \u7c7b&#xff0c;\u7528\u4e8e\u6784\u5efa MCP \u670d\u52a1\u5668&#xff08;\u867d\u7136\u5728\u6b64\u4ee3\u7801\u7247\u6bb5\u4e2d\u672a\u4f7f\u7528&#xff0c;\u4f46\u5df2\u5bfc\u5165&#xff09;<br \/>\nfrom mcp.server.fastmcp import FastMCP<\/p>\n<p># \u4ece\u672c\u5730\u81ea\u5b9a\u4e49\u6a21\u5757\u4e2d\u5bfc\u5165\u914d\u7f6e\u3001\u65e5\u5fd7\u548c\u683c\u5f0f\u5316\u5de5\u5177<br \/>\nfrom config import Config<br \/>\nfrom create_logger import logger<br \/>\nfrom utils.format import DateEncoder, default_encoder<\/p>\n<p># \u5b9e\u4f8b\u5316\u914d\u7f6e\u5bf9\u8c61&#xff0c;\u7528\u4e8e\u83b7\u53d6\u6570\u636e\u5e93\u8fde\u63a5\u4fe1\u606f&#xff08;host, user, password, database&#xff09;<br \/>\nconf &#061; Config()<\/p>\n<p># \u5b9a\u4e49\u7968\u52a1\u670d\u52a1\u7c7b&#xff0c;\u5c01\u88c5\u6240\u6709\u4e0e\u7968\u52a1\u6570\u636e\u76f8\u5173\u7684\u6570\u636e\u5e93\u64cd\u4f5c<br \/>\nclass TicketService:<br \/>\n    def __init__(self):<br \/>\n        # \u5728\u7c7b\u521d\u59cb\u5316\u65f6&#xff0c;\u4f7f\u7528\u914d\u7f6e\u4fe1\u606f\u5efa\u7acb\u4e0e MySQL \u6570\u636e\u5e93\u7684\u8fde\u63a5<br \/>\n        # \u8fd9\u4e2a\u8fde\u63a5\u4f1a\u5728\u6574\u4e2a TicketService \u5b9e\u4f8b\u7684\u751f\u547d\u5468\u671f\u5185\u4fdd\u6301<br \/>\n        self.conn &#061; mysql.connector.connect(<br \/>\n            host&#061;conf.host,<br \/>\n            user&#061;conf.user,<br \/>\n            password&#061;conf.password,<br \/>\n            database&#061;conf.database<br \/>\n        )<\/p>\n<p>    # \u5b9a\u4e49\u4e00\u4e2a\u6267\u884c SQL \u67e5\u8be2\u7684\u65b9\u6cd5<br \/>\n    # \u53c2\u6570: sql (str) &#8211; \u4e00\u4e2a\u5b8c\u6574\u7684 SQL \u67e5\u8be2\u5b57\u7b26\u4e32<br \/>\n    # \u8fd4\u56de: str &#8211; \u4e00\u4e2a JSON \u683c\u5f0f\u7684\u5b57\u7b26\u4e32&#xff0c;\u5305\u542b\u67e5\u8be2\u7ed3\u679c\u6216\u9519\u8bef\u4fe1\u606f<br \/>\n    def execute_query(self, sql: str) -&gt; str:<br \/>\n        try:<br \/>\n            # \u521b\u5efa\u4e00\u4e2a\u6e38\u6807&#xff08;cursor&#xff09;&#xff0c;dictionary&#061;True \u8868\u793a\u67e5\u8be2\u7ed3\u679c\u5c06\u4ee5\u5b57\u5178\u5217\u8868\u7684\u5f62\u5f0f\u8fd4\u56de<br \/>\n            # \u8fd9\u6837\u53ef\u4ee5\u901a\u8fc7\u5217\u540d&#xff08;\u5982 row[&#039;city&#039;]&#xff09;\u800c\u4e0d\u662f\u7d22\u5f15\u6765\u8bbf\u95ee\u6570\u636e<br \/>\n            cursor &#061; self.conn.cursor(dictionary&#061;True)<\/p>\n<p>            # \u6267\u884c\u4f20\u5165\u7684 SQL \u8bed\u53e5<br \/>\n            cursor.execute(sql)<\/p>\n<p>            # \u83b7\u53d6\u6240\u6709\u67e5\u8be2\u7ed3\u679c<br \/>\n            results &#061; cursor.fetchall()<\/p>\n<p>            # \u5173\u95ed\u6e38\u6807&#xff0c;\u91ca\u653e\u8d44\u6e90<br \/>\n            cursor.close()<\/p>\n<p>            # &#8212; \u6570\u636e\u683c\u5f0f\u5316 &#8212;<br \/>\n            # \u904d\u5386\u67e5\u8be2\u7ed3\u679c\u4e2d\u7684\u6bcf\u4e00\u884c&#xff08;\u6bcf\u4e2a\u7ed3\u679c\u90fd\u662f\u4e00\u4e2a\u5b57\u5178&#xff09;<br \/>\n            for result in results:<br \/>\n                # \u904d\u5386\u5b57\u5178\u4e2d\u7684\u6bcf\u4e00\u4e2a\u952e\u503c\u5bf9<br \/>\n                for key, value in result.items():<br \/>\n                    # \u68c0\u67e5\u503c\u662f\u5426\u662f\u65e5\u671f\u3001\u65f6\u95f4\u6216 Decimal \u7b49\u65e0\u6cd5\u76f4\u63a5\u88ab JSON \u5e8f\u5217\u5316\u7684\u7279\u6b8a\u7c7b\u578b<br \/>\n                    if isinstance(value, (date, datetime, timedelta, Decimal)):<br \/>\n                        # \u5982\u679c\u662f&#xff0c;\u5219\u4f7f\u7528\u81ea\u5b9a\u4e49\u7684 default_encoder \u51fd\u6570\u5c06\u5176\u8f6c\u6362\u4e3a\u5b57\u7b26\u4e32<br \/>\n                        result[key] &#061; default_encoder(value)<\/p>\n<p>            # &#8212; \u6784\u5efa\u5e76\u8fd4\u56de JSON \u54cd\u5e94 &#8212;<br \/>\n            # \u6839\u636e\u67e5\u8be2\u7ed3\u679c\u662f\u5426\u4e3a\u7a7a&#xff0c;\u6784\u5efa\u4e0d\u540c\u7684\u54cd\u5e94\u7ed3\u6784<br \/>\n            # \u5982\u679c\u6709\u6570\u636e&#xff0c;\u8fd4\u56de {&#034;status&#034;: &#034;success&#034;, &#034;data&#034;: [&#8230;]}<br \/>\n            # \u5982\u679c\u65e0\u6570\u636e&#xff0c;\u8fd4\u56de {&#034;status&#034;: &#034;no_data&#034;, &#034;message&#034;: &#034;\u672a\u627e\u5230\u7968\u52a1\u6570\u636e&#xff0c;\u8bf7\u786e\u8ba4\u67e5\u8be2\u6761\u4ef6\u3002&#034;}<br \/>\n            response_data &#061; {&#034;status&#034;: &#034;success&#034;, &#034;data&#034;: results} if results else {<br \/>\n                &#034;status&#034;: &#034;no_data&#034;,<br \/>\n                &#034;message&#034;: &#034;\u672a\u627e\u5230\u7968\u52a1\u6570\u636e&#xff0c;\u8bf7\u786e\u8ba4\u67e5\u8be2\u6761\u4ef6\u3002&#034;<br \/>\n            }<\/p>\n<p>            # \u5c06 Python \u5b57\u5178\u5e8f\u5217\u5316\u4e3a JSON \u5b57\u7b26\u4e32<br \/>\n            # cls&#061;DateEncoder: \u4f7f\u7528\u81ea\u5b9a\u4e49\u7684 JSONEncoder \u6765\u5904\u7406\u5e8f\u5217\u5316\u8fc7\u7a0b\u4e2d\u9047\u5230\u7684\u5176\u4ed6\u7279\u6b8a\u7c7b\u578b<br \/>\n            # ensure_ascii&#061;False: \u786e\u4fdd\u4e2d\u6587\u5b57\u7b26\u4e0d\u88ab\u8f6c\u4e49&#xff0c;\u76f4\u63a5\u663e\u793a<br \/>\n            return json.dumps(response_data, cls&#061;DateEncoder, ensure_ascii&#061;False)<\/p>\n<p>        except Exception as e:<br \/>\n            # &#8212; \u5f02\u5e38\u5904\u7406 &#8212;<br \/>\n            # \u5982\u679c\u5728\u6267\u884c\u8fc7\u7a0b\u4e2d\u53d1\u751f\u4efb\u4f55\u9519\u8bef&#xff08;\u5982 SQL \u8bed\u6cd5\u9519\u8bef\u3001\u6570\u636e\u5e93\u8fde\u63a5\u5931\u8d25\u7b49&#xff09;<br \/>\n            # \u4f7f\u7528\u65e5\u5fd7\u8bb0\u5f55\u5668\u8bb0\u5f55\u9519\u8bef\u4fe1\u606f<br \/>\n            logger.error(f&#034;\u7968\u52a1\u67e5\u8be2\u9519\u8bef: {str(e)}&#034;)<\/p>\n<p>            # \u8fd4\u56de\u4e00\u4e2a\u5305\u542b\u9519\u8bef\u72b6\u6001\u7684 JSON \u5b57\u7b26\u4e32<br \/>\n            return json.dumps({&#034;status&#034;: &#034;error&#034;, &#034;message&#034;: str(e)}, ensure_ascii&#061;False) <\/p>\n<p><span style=\"color:#fe2c24\">\u603b\u7ed3:<\/span>\u4ee3\u7801\u662f\u4e00\u4e2a\u6807\u51c6\u7684\u6570\u636e\u5e93\u67e5\u8be2\u5c01\u88c5\u5c42\u3002\u5b83\u63a5\u6536 SQL \u8bed\u53e5&#xff0c;\u5904\u7406\u4e86\u67e5\u8be2\u8fc7\u7a0b\u4e2d\u53ef\u80fd\u51fa\u73b0\u7684\u7279\u6b8a\u6570\u636e\u7c7b\u578b&#xff08;\u5982\u65e5\u671f\u3001\u91d1\u989d&#xff09;&#xff0c;\u7edf\u4e00\u4e86\u6210\u529f\u3001\u65e0\u6570\u636e\u548c\u5f02\u5e38\u4e09\u79cd\u60c5\u51b5\u7684\u8fd4\u56de\u683c\u5f0f&#xff0c;\u6700\u7ec8\u8f93\u51fa\u6807\u51c6\u7684 JSON \u5b57\u7b26\u4e32<\/p>\n<h4 id=\"72-mcp\">7.2 \u542f\u52a8MCP \u670d\u52a1\u5668<\/h4>\n<p><span style=\"color:#fe2c24\">create_ticket_mcp_server()\u51fd\u6570<\/span><\/p>\n<p>\u76ee\u6807&#xff1a;<span style=\"color:#be191c\">\u521b\u5efa\u5e76\u542f\u52a8\u7968\u52a1 MCP \u670d\u52a1\u5668<\/span><\/p>\n<p>\u529f\u80fd&#xff1a;\u521d\u59cb\u5316 FastMCP&#xff0c;<span style=\"color:#be191c\">\u6ce8\u518c query_tickets \u5de5\u5177<\/span>&#xff0c;\u542f\u52a8 FastAPI \u670d\u52a1\u5668&#xff0c;\u76d1\u542c\u7aef\u53e3 6002<\/p>\n<p>\u4f4d\u7f6e: <span style=\"color:#fe2c24\">\/mcp_server\/mcp_ticket_server.py<\/span><\/p>\n<p># -*- coding: utf-8 -*-<br \/>\n&#034;&#034;&#034;<br \/>\n\u7968\u52a1 MCP \u670d\u52a1\u5668\u542f\u52a8\u811a\u672c\u3002<br \/>\n\u6b64\u811a\u672c\u8d1f\u8d23\u521b\u5efa\u4e00\u4e2a MCP \u670d\u52a1\u5668&#xff0c;\u5e76\u5c06 TicketService \u7684\u67e5\u8be2\u529f\u80fd\u6ce8\u518c\u4e3a\u5de5\u5177\u3002<br \/>\n&#034;&#034;&#034;<\/p>\n<p># \u5bfc\u5165\u5fc5\u8981\u7684\u5e93<br \/>\nimport mysql.connector<br \/>\nimport json<br \/>\nfrom datetime import date, datetime, timedelta<br \/>\nfrom decimal import Decimal<\/p>\n<p># \u4ece mcp \u5e93\u4e2d\u5bfc\u5165 FastMCP&#xff0c;\u8fd9\u662f\u6784\u5efa MCP \u670d\u52a1\u5668\u7684\u6838\u5fc3\u7c7b<br \/>\nfrom mcp.server.fastmcp import FastMCP<\/p>\n<p># \u5bfc\u5165\u81ea\u5b9a\u4e49\u6a21\u5757<br \/>\nfrom config import Config<br \/>\nfrom create_logger import logger<br \/>\nfrom utils.format import DateEncoder, default_encoder<br \/>\n# \u5bfc\u5165\u4e4b\u524d\u5b9a\u4e49\u7684\u7968\u52a1\u670d\u52a1\u7c7b<br \/>\nfrom query_data.query_ticket import TicketService<\/p>\n<p># \u5b9e\u4f8b\u5316\u914d\u7f6e\u5bf9\u8c61&#xff0c;\u7528\u4e8e\u52a0\u8f7d\u6570\u636e\u5e93\u8fde\u63a5\u4fe1\u606f<br \/>\nconf &#061; Config()<\/p>\n<p># \u5b9a\u4e49\u4e00\u4e2a\u51fd\u6570\u6765\u521b\u5efa\u5e76\u8fd0\u884c\u7968\u52a1 MCP \u670d\u52a1\u5668<br \/>\ndef create_ticket_mcp_server():<br \/>\n    # &#8212; 1. \u521b\u5efa FastMCP \u670d\u52a1\u5668\u5b9e\u4f8b &#8212;<br \/>\n    # name: \u670d\u52a1\u5668\u7684\u540d\u79f0&#xff0c;\u5ba2\u6237\u7aef\u4f1a\u53d1\u73b0\u5e76\u4f7f\u7528\u8fd9\u4e2a\u540d\u5b57<br \/>\n    # instructions: \u670d\u52a1\u5668\u7684\u6307\u4ee4\u6216\u63cf\u8ff0&#xff0c;\u544a\u8bc9 AI \u8fd9\u4e2a\u5de5\u5177\u662f\u505a\u4ec0\u4e48\u7684<br \/>\n    # log_level: \u8bbe\u7f6e\u65e5\u5fd7\u7ea7\u522b\u4e3a ERROR&#xff0c;\u53ea\u8bb0\u5f55\u9519\u8bef\u4fe1\u606f<br \/>\n    # host &amp; port: \u670d\u52a1\u5668\u76d1\u542c\u7684\u5730\u5740\u548c\u7aef\u53e3<br \/>\n    ticket_mcp &#061; FastMCP(<br \/>\n        name&#061;&#034;TicketTools&#034;,<br \/>\n        instructions&#061;&#034;\u7968\u52a1\u67e5\u8be2\u5de5\u5177&#xff0c;\u57fa\u4e8e train_tickets, flight_tickets, concert_tickets \u8868\u3002\u53ea\u652f\u6301\u67e5\u8be2\u3002&#034;,<br \/>\n        log_level&#061;&#034;ERROR&#034;,<br \/>\n        host&#061;&#034;127.0.0.1&#034;,<br \/>\n        port&#061;8001<br \/>\n    )<\/p>\n<p>    # &#8212; 2. \u5b9e\u4f8b\u5316\u4e1a\u52a1\u903b\u8f91\u670d\u52a1\u5bf9\u8c61 &#8212;<br \/>\n    # \u521b\u5efa\u4e00\u4e2a TicketService \u5b9e\u4f8b&#xff0c;\u7528\u4e8e\u5904\u7406\u5177\u4f53\u7684\u6570\u636e\u5e93\u67e5\u8be2\u903b\u8f91<br \/>\n    service &#061; TicketService()<\/p>\n<p>    # &#8212; 3. \u6ce8\u518c MCP \u5de5\u5177 &#8212;<br \/>\n    # \u4f7f\u7528 &#064;ticket_mcp.tool \u88c5\u9970\u5668\u5c06\u4e00\u4e2a\u666e\u901a\u51fd\u6570\u6ce8\u518c\u4e3a MCP \u5de5\u5177<br \/>\n    &#064;ticket_mcp.tool(<br \/>\n        name&#061;&#034;query_tickets&#034;,  # \u5de5\u5177\u7684\u540d\u79f0&#xff0c;\u5ba2\u6237\u7aef\u5c06\u901a\u8fc7\u6b64\u540d\u79f0\u8c03\u7528<br \/>\n        description&#061;&#034;\u67e5\u8be2\u7968\u52a1\u6570\u636e&#xff0c;\u8f93\u5165 SQL&#xff0c;\u5982 &#039;SELECT * FROM train_tickets WHERE departure_city &#061; \\\\&#034;\u5317\u4eac\\\\&#034; AND arrival_city &#061; \\\\&#034;\u4e0a\u6d77\\\\&#034;&#039;&#034;  # \u5de5\u5177\u7684\u63cf\u8ff0&#xff0c;\u5e2e\u52a9 AI \u7406\u89e3\u5982\u4f55\u4f7f\u7528\u5b83<br \/>\n    )<br \/>\n    def query_tickets(sql: str) -&gt; str:<br \/>\n        # \u8fd9\u662f\u4e00\u4e2a\u666e\u901a\u7684 Python \u51fd\u6570&#xff0c;\u4f46\u88ab\u88c5\u9970\u5668\u5305\u88c5\u540e\u6210\u4e3a\u4e86\u4e00\u4e2a MCP \u5de5\u5177<br \/>\n        # \u5f53\u5ba2\u6237\u7aef\u8c03\u7528 &#039;query_tickets&#039; \u5de5\u5177\u65f6&#xff0c;\u8fd9\u4e2a\u51fd\u6570\u5c31\u4f1a\u88ab\u6267\u884c<\/p>\n<p>        # \u8bb0\u5f55\u65e5\u5fd7&#xff0c;\u65b9\u4fbf\u8c03\u8bd5\u548c\u8ffd\u8e2a<br \/>\n        logger.info(f&#034;\u6267\u884c\u7968\u52a1\u67e5\u8be2: {sql}&#034;)<\/p>\n<p>        # \u8c03\u7528 TicketService \u5b9e\u4f8b\u7684 execute_query \u65b9\u6cd5\u6765\u6267\u884c SQL \u5e76\u83b7\u53d6\u7ed3\u679c<br \/>\n        # \u7136\u540e\u5c06\u7ed3\u679c&#xff08;\u4e00\u4e2a JSON \u5b57\u7b26\u4e32&#xff09;\u8fd4\u56de\u7ed9\u5ba2\u6237\u7aef<br \/>\n        return service.execute_query(sql)<\/p>\n<p>    # &#8212; 4. \u6253\u5370\u670d\u52a1\u5668\u4fe1\u606f &#8212;<br \/>\n    logger.info(&#034;&#061;&#061;&#061; \u7968\u52a1MCP\u670d\u52a1\u5668\u4fe1\u606f &#061;&#061;&#061;&#034;)<br \/>\n    logger.info(f&#034;\u540d\u79f0: {ticket_mcp.name}&#034;)<br \/>\n    logger.info(f&#034;\u63cf\u8ff0: {ticket_mcp.instructions}&#034;)<\/p>\n<p>    # &#8212; 5. \u542f\u52a8\u670d\u52a1\u5668 &#8212;<br \/>\n    try:<br \/>\n        print(&#034;\u670d\u52a1\u5668\u5df2\u542f\u52a8&#xff0c;\u8bf7\u8bbf\u95ee http:\/\/127.0.0.1:8001\/mcp&#034;)<br \/>\n        # \u8fd0\u884c\u670d\u52a1\u5668&#xff0c;\u5e76\u6307\u5b9a\u4f20\u8f93\u65b9\u5f0f\u4e3a &#034;streamable-http&#034;<br \/>\n        # \u8fd9\u662f\u4e00\u79cd\u57fa\u4e8e HTTP \u957f\u8fde\u63a5\u7684\u901a\u4fe1\u65b9\u5f0f&#xff0c;\u9002\u5408\u6d41\u5f0f\u6570\u636e\u4f20\u8f93<br \/>\n        ticket_mcp.run(transport&#061;&#034;streamable-http&#034;)<br \/>\n    except Exception as e:<br \/>\n        # \u6355\u83b7\u5e76\u6253\u5370\u542f\u52a8\u8fc7\u7a0b\u4e2d\u53ef\u80fd\u51fa\u73b0\u7684\u4efb\u4f55\u9519\u8bef<br \/>\n        print(f&#034;\u670d\u52a1\u5668\u542f\u52a8\u5931\u8d25: {e}&#034;)<\/p>\n<p># \u8c03\u7528\u51fd\u6570&#xff0c;\u542f\u52a8\u670d\u52a1\u5668<br \/>\ncreate_ticket_mcp_server() <\/p>\n<p>MCP \u670d\u52a1\u5668\u542f\u52a8\u811a\u672c&#xff0c;\u5b83\u6574\u5408\u4e86\u4e4b\u524d\u5b9a\u4e49\u7684\u00a0TicketService\u00a0\u7c7b&#xff0c;\u5c06\u7968\u52a1\u67e5\u8be2\u529f\u80fd\u901a\u8fc7 MCP \u534f\u8bae\u66b4\u9732\u51fa\u53bb<\/p>\n<p><span style=\"color:#fe2c24\">\u603b\u7ed3:<\/span>\u00a0\u4ee3\u7801\u662f\u6574\u4e2a\u7968\u52a1\u67e5\u8be2\u670d\u52a1\u7684\u5165\u53e3\u70b9\u3002\u5b83\u5b8c\u6210\u4e86\u4ee5\u4e0b\u51e0\u4ef6\u4e8b&#xff1a;<\/p>\n<li>\u914d\u7f6e\u670d\u52a1\u5668&#xff1a;\u4f7f\u7528\u00a0FastMCP\u00a0\u7c7b\u521b\u5efa\u4e86\u4e00\u4e2a\u540d\u4e3a\u00a0TicketTools\u00a0\u7684\u670d\u52a1\u5668\u5b9e\u4f8b&#xff0c;\u5e76\u8bbe\u7f6e\u4e86\u5176\u540d\u79f0\u3001\u63cf\u8ff0\u3001\u76d1\u542c\u5730\u5740\u548c\u7aef\u53e3<\/li>\n<li>\u96c6\u6210\u4e1a\u52a1\u903b\u8f91&#xff1a;\u5b9e\u4f8b\u5316\u4e86\u00a0TicketService\u00a0\u7c7b&#xff0c;\u5c06\u6570\u636e\u5e93\u64cd\u4f5c\u7684\u80fd\u529b\u5f15\u5165<\/li>\n<li>\u66b4\u9732\u5de5\u5177&#xff1a;\u901a\u8fc7\u00a0&#064;ticket_mcp.tool\u00a0\u88c5\u9970\u5668&#xff0c;\u5c06\u00a0query_tickets\u00a0\u51fd\u6570\u6ce8\u518c\u4e3a\u4e00\u4e2a\u53ef\u4f9b\u5916\u90e8\u8c03\u7528\u7684 MCP \u5de5\u5177,\u3002\u8fd9\u4e2a\u5de5\u5177\u63a5\u6536\u4e00\u4e2a SQL \u5b57\u7b26\u4e32\u4f5c\u4e3a\u53c2\u6570&#xff0c;\u5e76\u8fd4\u56de\u67e5\u8be2\u7ed3\u679c\u7684 JSON \u5b57\u7b26\u4e32<\/li>\n<li>\u542f\u52a8\u670d\u52a1&#xff1a;\u6700\u540e&#xff0c;\u8c03\u7528\u00a0ticket_mcp.run()\u00a0\u65b9\u6cd5&#xff0c;\u4ee5\u00a0streamable-http\u00a0\u6a21\u5f0f\u542f\u52a8\u670d\u52a1\u5668&#xff0c;\u4f7f\u5176\u5f00\u59cb\u76d1\u542c\u5ba2\u6237\u7aef\u7684\u8fde\u63a5\u548c\u8bf7\u6c42<\/li>\n<p>\u5ba2\u6237\u7aef\u6d4b\u8bd5&#xff1a;<\/p>\n<p>\u4f4d\u7f6e&#xff1a;<span style=\"color:#fe2c24\">\/test\/test_ticket_mcp_server.py<\/span><\/p>\n<p>import asyncio<br \/>\nimport json<\/p>\n<p># \u4ece langchain_mcp_adapters \u5e93\u4e2d\u5bfc\u5165\u5de5\u5177&#xff0c;\u7528\u4e8e\u81ea\u52a8\u53d1\u73b0\u548c\u52a0\u8f7d MCP \u670d\u52a1\u5668\u63d0\u4f9b\u7684\u5de5\u5177<br \/>\nfrom langchain_mcp_adapters.tools import load_mcp_tools<\/p>\n<p># \u4ece mcp \u5e93\u4e2d\u5bfc\u5165\u6838\u5fc3\u5ba2\u6237\u7aef\u7c7b&#xff0c;\u7528\u4e8e\u5efa\u7acb\u4f1a\u8bdd<br \/>\nfrom mcp import ClientSession<\/p>\n<p># \u4ece mcp \u5e93\u4e2d\u5bfc\u5165\u7528\u4e8e\u5efa\u7acb streamable-http \u8fde\u63a5\u7684\u5ba2\u6237\u7aef\u51fd\u6570<br \/>\nfrom mcp.client.streamable_http import streamablehttp_client<\/p>\n<p># \u5b9a\u4e49\u8981\u8fde\u63a5\u7684 MCP \u670d\u52a1\u5668\u5730\u5740&#xff0c;\u4e0e\u60a8\u63d0\u4f9b\u7684\u7968\u52a1\u670d\u52a1\u5668\u5730\u5740\u4e00\u81f4<br \/>\nserver_url &#061; &#034;http:\/\/127.0.0.1:8001\/mcp&#034;<\/p>\n<p>async def test_ticket_mcp():<br \/>\n    try:<br \/>\n        # &#8212; 1. \u5efa\u7acb\u4e0e\u670d\u52a1\u5668\u7684\u8fde\u63a5 &#8212;<br \/>\n        # \u4f7f\u7528 streamablehttp_client \u4f5c\u4e3a\u5f02\u6b65\u4e0a\u4e0b\u6587\u7ba1\u7406\u5668\u6765\u8fde\u63a5\u5230\u670d\u52a1\u5668<br \/>\n        # \u5b83\u4f1a\u8fd4\u56de\u4e00\u5bf9\u8bfb\u5199\u901a\u9053 (read, write) \u548c\u4e00\u4e2a get_session_id \u51fd\u6570&#xff08;\u6b64\u5904\u7528 _ \u5ffd\u7565&#xff09;<br \/>\n        async with streamablehttp_client(server_url) as (read, write, _):<\/p>\n<p>            # &#8212; 2. \u521d\u59cb\u5316 MCP \u4f1a\u8bdd &#8212;<br \/>\n            # \u4f7f\u7528\u4e0a\u4e00\u6b65\u83b7\u53d6\u7684\u8bfb\u5199\u901a\u9053\u521b\u5efa\u4e00\u4e2a ClientSession \u5b9e\u4f8b<br \/>\n            async with ClientSession(read, write) as session:<br \/>\n                try:<br \/>\n                    # \u5411\u670d\u52a1\u5668\u53d1\u9001\u521d\u59cb\u5316\u8bf7\u6c42&#xff0c;\u5efa\u7acb MCP \u534f\u8bae\u4f1a\u8bdd<br \/>\n                    await session.initialize()<br \/>\n                    print(&#034;\u4f1a\u8bdd\u521d\u59cb\u5316\u6210\u529f&#xff0c;\u53ef\u4ee5\u5f00\u59cb\u8c03\u7528\u5de5\u5177\u3002&#034;)<\/p>\n<p>                    # &#8212; 3. \u83b7\u53d6\u670d\u52a1\u5668\u63d0\u4f9b\u7684\u5de5\u5177\u5217\u8868 &#8212;<br \/>\n                    # \u8c03\u7528 load_mcp_tools \u51fd\u6570&#xff0c;\u5b83\u4f1a\u81ea\u52a8\u5411\u670d\u52a1\u5668\u67e5\u8be2\u5e76\u52a0\u8f7d\u6240\u6709\u53ef\u7528\u7684\u5de5\u5177<br \/>\n                    tools &#061; await load_mcp_tools(session)<br \/>\n                    print(f&#034;tools&#8211;&gt;{tools}&#034;)<\/p>\n<p>                    # &#8212; 4. \u6d4b\u8bd5\u8c03\u7528\u5de5\u5177&#xff1a;\u67e5\u8be2\u673a\u7968 &#8212;<br \/>\n                    # \u6784\u9020\u4e00\u4e2a SQL \u67e5\u8be2\u5b57\u7b26\u4e32&#xff0c;\u7528\u4e8e\u67e5\u8be2\u4ece\u4e0a\u6d77\u5230\u5317\u4eac\u7684\u516c\u52a1\u8231\u673a\u7968<br \/>\n                    sql_flights &#061; &#034;SELECT * FROM flight_tickets WHERE departure_city &#061; &#039;\u4e0a\u6d77&#039; AND arrival_city &#061; &#039;\u5317\u4eac&#039; AND DATE(departure_time) &#061; &#039;2025-10-28&#039; AND cabin_type &#061; &#039;\u516c\u52a1\u8231&#039;&#034;<br \/>\n                    # \u4f7f\u7528 session.call_tool \u65b9\u6cd5\u8c03\u7528\u670d\u52a1\u5668\u4e0a\u540d\u4e3a &#034;query_tickets&#034; \u7684\u5de5\u5177<br \/>\n                    result_flights &#061; await session.call_tool(&#034;query_tickets&#034;, {&#034;sql&#034;: sql_flights})<br \/>\n                    # \u5904\u7406\u8fd4\u56de\u7ed3\u679c&#xff0c;\u5c1d\u8bd5\u5c06\u5176\u89e3\u6790\u4e3a JSON<br \/>\n                    result_flights_data &#061; json.loads(result_flights) if isinstance(result_flights, str) else result_flights<br \/>\n                    print(f&#034;\u673a\u7968\u67e5\u8be2\u7ed3\u679c&#xff1a;{result_flights_data}&#034;)<\/p>\n<p>                    # &#8212; 5. \u6d4b\u8bd5\u8c03\u7528\u5de5\u5177&#xff1a;\u67e5\u8be2\u706b\u8f66\u7968 &#8212;<br \/>\n                    # \u6784\u9020\u4e00\u4e2a SQL \u67e5\u8be2\u5b57\u7b26\u4e32&#xff0c;\u7528\u4e8e\u67e5\u8be2\u4ece\u5317\u4eac\u5230\u4e0a\u6d77\u7684\u4e8c\u7b49\u5ea7\u706b\u8f66\u7968<br \/>\n                    sql_trains &#061; &#034;SELECT * FROM train_tickets WHERE departure_city &#061; &#039;\u5317\u4eac&#039; AND arrival_city &#061; &#039;\u4e0a\u6d77&#039; AND DATE(departure_time) &#061; &#039;2025-10-22&#039; AND seat_type &#061; &#039;\u4e8c\u7b49\u5ea7&#039;&#034;<br \/>\n                    # \u8c03\u7528\u5de5\u5177\u5e76\u5904\u7406\u7ed3\u679c<br \/>\n                    result_trains &#061; await session.call_tool(&#034;query_tickets&#034;, {&#034;sql&#034;: sql_trains})<br \/>\n                    result_trains_data &#061; json.loads(result_trains) if isinstance(result_trains, str) else result_trains<br \/>\n                    print(f&#034;\u706b\u8f66\u7968\u67e5\u8be2\u7ed3\u679c&#xff1a;{result_trains_data}&#034;)<\/p>\n<p>                    # &#8212; 6. \u6d4b\u8bd5\u8c03\u7528\u5de5\u5177&#xff1a;\u67e5\u8be2\u6f14\u5531\u4f1a\u7968 &#8212;<br \/>\n                    # \u6784\u9020\u4e00\u4e2a SQL \u67e5\u8be2\u5b57\u7b26\u4e32&#xff0c;\u7528\u4e8e\u67e5\u8be2\u5317\u4eac\u5200\u90ce\u6f14\u5531\u4f1a\u7684\u770b\u53f0\u7968<br \/>\n                    sql_concerts &#061; &#034;SELECT * FROM concert_tickets WHERE city &#061; &#039;\u5317\u4eac&#039; AND artist &#061; &#039;\u5200\u90ce&#039; AND DATE(start_time) &#061; &#039;2025-10-31&#039; AND ticket_type &#061; &#039;\u770b\u53f0&#039;&#034;<br \/>\n                    # \u8c03\u7528\u5de5\u5177\u5e76\u5904\u7406\u7ed3\u679c<br \/>\n                    result_concerts &#061; await session.call_tool(&#034;query_tickets&#034;, {&#034;sql&#034;: sql_concerts})<br \/>\n                    result_concerts_data &#061; json.loads(result_concerts) if isinstance(result_concerts, str) else result_concerts<br \/>\n                    print(f&#034;\u6f14\u5531\u4f1a\u7968\u67e5\u8be2\u7ed3\u679c&#xff1a;{result_concerts_data}&#034;)<\/p>\n<p>                except Exception as e:<br \/>\n                    # \u6355\u83b7\u5e76\u6253\u5370\u5728\u4f1a\u8bdd\u5185\u90e8\u53d1\u751f\u7684\u4efb\u4f55\u9519\u8bef&#xff08;\u5982\u5de5\u5177\u8c03\u7528\u5931\u8d25&#xff09;<br \/>\n                    print(f&#034;\u7968\u52a1 MCP \u6d4b\u8bd5\u51fa\u9519&#xff1a;{str(e)}&#034;)<\/p>\n<p>    except Exception as e:<br \/>\n        # \u6355\u83b7\u5e76\u6253\u5370\u5728\u8fde\u63a5\u6216\u4f1a\u8bdd\u521d\u59cb\u5316\u9636\u6bb5\u53d1\u751f\u7684\u9519\u8bef<br \/>\n        print(f&#034;\u8fde\u63a5\u6216\u4f1a\u8bdd\u521d\u59cb\u5316\u65f6\u53d1\u751f\u9519\u8bef: {e}&#034;)<br \/>\n        print(&#034;\u8bf7\u786e\u8ba4\u670d\u52a1\u7aef\u811a\u672c\u5df2\u542f\u52a8\u5e76\u8fd0\u884c\u5728 http:\/\/127.0.0.1:8001\/mcp&#034;)<\/p>\n<p># Python \u7684\u6807\u51c6\u5165\u53e3\u70b9<br \/>\n# \u4f7f\u7528 asyncio.run() \u6765\u8fd0\u884c\u9876\u5c42\u7684\u5f02\u6b65\u51fd\u6570<br \/>\nif __name__ &#061;&#061; &#034;__main__&#034;:<br \/>\n    asyncio.run(test_ticket_mcp()) <\/p>\n<p>\u6d4b\u8bd5\u00a0\u7968\u52a1 MCP \u670d\u52a1\u5668\u00a0\u7684\u5ba2\u6237\u7aef\u811a\u672c: \u5b83\u901a\u8fc7\u5f02\u6b65\u65b9\u5f0f\u8fde\u63a5\u5230\u8fd0\u884c\u5728\u00a08001\u00a0\u7aef\u53e3\u7684\u670d\u52a1\u5668&#xff0c;\u5e76\u4f9d\u6b21\u6d4b\u8bd5\u4e86\u673a\u7968\u3001\u706b\u8f66\u7968\u548c\u6f14\u5531\u4f1a\u95e8\u7968\u7684\u67e5\u8be2\u529f\u80fd<\/p>\n<p><span style=\"color:#fe2c24\">\u603b\u7ed3: <\/span>\u4ee3\u7801\u662f\u4e00\u4e2a\u5b8c\u6574\u7684 MCP \u5ba2\u6237\u7aef\u6d4b\u8bd5\u811a\u672c&#xff0c;\u5b83\u6a21\u62df\u4e86 AI \u4ee3\u7406\u4e0e\u7968\u52a1\u670d\u52a1\u4ea4\u4e92\u7684\u5168\u8fc7\u7a0b:<\/p>\n<li>\u5efa\u7acb\u8fde\u63a5&#xff1a;\u4f7f\u7528\u00a0<span style=\"color:#fe2c24\">streamablehttp_client\u00a0<\/span>\u8fde\u63a5\u5230\u8fd0\u884c\u5728\u00a08001\u00a0\u7aef\u53e3\u7684\u7968\u52a1 MCP \u670d\u52a1\u5668<\/li>\n<li>\u521d\u59cb\u5316\u4f1a\u8bdd&#xff1a;\u901a\u8fc7\u00a0<span style=\"color:#fe2c24\">ClientSession<\/span>\u00a0\u4e0e\u670d\u52a1\u5668\u5efa\u7acb\u4e00\u4e2a MCP \u534f\u8bae\u4f1a\u8bdd<\/li>\n<li>\u53d1\u73b0\u5de5\u5177&#xff1a;\u4f7f\u7528\u00a0<span style=\"color:#be191c\">load_mcp_tools\u00a0<\/span>\u81ea\u52a8\u83b7\u53d6\u670d\u52a1\u5668\u4e0a\u6240\u6709\u53ef\u7528\u7684\u5de5\u5177\u5217\u8868<\/li>\n<li>\u8c03\u7528\u5de5\u5177&#xff1a;\u811a\u672c\u4f9d\u6b21\u6784\u9020\u4e86\u4e09\u4e2a\u4e0d\u540c\u7684 SQL \u67e5\u8be2&#xff0c;\u5206\u522b\u7528\u4e8e\u6d4b\u8bd5\u673a\u7968\u3001\u706b\u8f66\u7968\u548c\u6f14\u5531\u4f1a\u95e8\u7968\u7684\u67e5\u8be2\u529f\u80fd&#xff0c;\u5e76\u901a\u8fc7\u00a0session.call_tool\u00a0\u65b9\u6cd5\u8c03\u7528\u8fdc\u7a0b\u7684\u00a0query_tickets\u00a0\u5de5\u5177<\/li>\n<li>\u5904\u7406\u7ed3\u679c&#xff1a;\u811a\u672c\u63a5\u6536\u670d\u52a1\u5668\u8fd4\u56de\u7684\u7ed3\u679c&#xff0c;\u5e76\u5c1d\u8bd5\u5c06\u5176\u89e3\u6790\u4e3a JSON \u683c\u5f0f\u540e\u6253\u5370\u51fa\u6765<\/li>\n<h3 id=\"8-mcp\">8.\u8ba2\u7968MCP\u670d\u52a1\u5668<\/h3>\n<p><span style=\"color:#fe2c24\">mcp_order_server.py:<\/span>\u8ba2\u7968 MCP \u670d\u52a1\u5668,\u901a\u8fc7\u8c03\u7528API\u5b8c\u6210\u706b\u8f66\u7968,\u98de\u673a\u7968\u548c\u6f14\u5531\u4f1a\u7968\u7684\u9884\u5b9a<\/p>\n<p>\u6838\u5fc3\u529f\u80fd&#xff1a;<\/p>\n<ul>\n<li>\u706b\u8f66\u7968\u9884\u5b9a\u3001\u98de\u673a\u7968\u9884\u5b9a\u3001\u6f14\u51fa\u7968\u9884\u5b9a<\/li>\n<li>\u901a\u8fc7 FastAPI \u63d0\u4f9b HTTP \u63a5\u53e3&#xff0c;\u54cd\u5e94 MCP \u5de5\u5177\u8c03\u7528<\/li>\n<\/ul>\n<p>\u4f4d\u7f6e&#xff1a;\/<span style=\"color:#fe2c24\">mcp_server\/mcp_order_server.py<\/span><\/p>\n<p>from mcp.server.fastmcp import FastMCP<\/p>\n<p>from config import Config<br \/>\nfrom create_logger import logger<\/p>\n<p># \u52a0\u8f7d\u914d\u7f6e\u5e76\u521b\u5efa\u65e5\u5fd7\u8bb0\u5f55\u5668<br \/>\nconf &#061; Config()<\/p>\n<p># &#8212; 1. \u521b\u5efa FastMCP \u5b9e\u4f8b &#8212;<br \/>\n# \u521d\u59cb\u5316\u4e00\u4e2a\u540d\u4e3a &#034;OrderTools&#034; \u7684 MCP \u670d\u52a1\u5668\u5b9e\u4f8b<br \/>\n# &#8211; name: \u670d\u52a1\u5668\u7684\u540d\u79f0<br \/>\n# &#8211; instructions: \u670d\u52a1\u5668\u7684\u529f\u80fd\u63cf\u8ff0&#xff0c;\u4f1a\u63d0\u4f9b\u7ed9\u5ba2\u6237\u7aef<br \/>\n# &#8211; log_level: \u65e5\u5fd7\u7ea7\u522b&#xff0c;\u8bbe\u7f6e\u4e3a &#034;ERROR&#034;<br \/>\n# &#8211; host: \u670d\u52a1\u5668\u76d1\u542c\u7684\u4e3b\u673a\u5730\u5740<br \/>\n# &#8211; port: \u670d\u52a1\u5668\u76d1\u542c\u7684\u7aef\u53e3\u53f7&#xff0c;\u6b64\u5904\u4e3a 8003<br \/>\norder_mcp &#061; FastMCP(<br \/>\n    name&#061;&#034;OrderTools&#034;,<br \/>\n    instructions&#061;&#034;\u7968\u52a1\u9884\u5b9a\u5de5\u5177&#xff0c;\u901a\u8fc7\u8c03\u7528API\u5b8c\u6210\u706b\u8f66\u7968\u3001\u98de\u673a\u7968\u548c\u6f14\u5531\u4f1a\u7968\u7684\u9884\u5b9a\u3002&#034;,<br \/>\n    log_level&#061;&#034;ERROR&#034;,<br \/>\n    host&#061;&#034;127.0.0.1&#034;,<br \/>\n    port&#061;8003<br \/>\n)<\/p>\n<p># &#8212; 2. \u5b9a\u4e49\u5de5\u5177&#xff1a;\u9884\u5b9a\u706b\u8f66\u7968 &#8212;<br \/>\n# \u4f7f\u7528 &#064;order_mcp.tool \u88c5\u9970\u5668\u5c06\u4e00\u4e2a\u666e\u901a\u51fd\u6570\u6ce8\u518c\u4e3a MCP \u5de5\u5177<br \/>\n&#064;order_mcp.tool(<br \/>\n    name&#061;&#034;order_train&#034;,  # \u5de5\u5177\u7684\u552f\u4e00\u6807\u8bc6\u540d<br \/>\n    description&#061;&#034;\u6839\u636e\u65f6\u95f4\u3001\u8f66\u6b21\u3001\u5ea7\u4f4d\u7c7b\u578b\u3001\u6570\u91cf\u9884\u5b9a\u706b\u8f66\u7968&#034;  # \u5de5\u5177\u7684\u529f\u80fd\u63cf\u8ff0<br \/>\n)<br \/>\ndef order_train(departure_date: str, train_number: str, seat_type: str, number: int) -&gt; str:<br \/>\n    &#039;&#039;&#039;<br \/>\n    Args:<br \/>\n        departure_date (str): \u51fa\u53d1\u65e5\u671f&#xff0c;\u5982 &#039;2025-10-30&#039;<br \/>\n        train_number (str): \u706b\u8f66\u8f66\u6b21&#xff0c;\u5982 &#039;G346&#039;<br \/>\n        seat_type (str): \u5ea7\u4f4d\u7c7b\u578b&#xff0c;\u5982 &#039;\u4e8c\u7b49\u5ea7&#039;<br \/>\n        number (int): \u8ba2\u8d2d\u5f20\u6570<br \/>\n    &#039;&#039;&#039;<br \/>\n    # \u8bb0\u5f55\u8ba2\u7968\u65e5\u5fd7<br \/>\n    logger.info(f&#034;\u6b63\u5728\u8ba2\u8d2d\u706b\u8f66\u7968: {departure_date}, {train_number}, {seat_type}, {number}&#034;)<br \/>\n    logger.info(f&#034;\u606d\u559c&#xff0c;\u706b\u8f66\u7968\u9884\u5b9a\u6210\u529f&#xff01;&#034;)<br \/>\n    # \u8fd4\u56de\u9884\u5b9a\u6210\u529f\u7684\u6d88\u606f<br \/>\n    return &#034;\u606d\u559c&#xff0c;\u706b\u8f66\u7968\u9884\u5b9a\u6210\u529f&#xff01;&#034;<\/p>\n<p># &#8212; 3. \u5b9a\u4e49\u5de5\u5177&#xff1a;\u9884\u5b9a\u98de\u673a\u7968 &#8212;<br \/>\n&#064;order_mcp.tool(<br \/>\n    name&#061;&#034;order_flight&#034;,<br \/>\n    description&#061;&#034;\u6839\u636e\u65f6\u95f4\u3001\u73ed\u6b21\u3001\u5ea7\u4f4d\u7c7b\u578b\u3001\u6570\u91cf\u9884\u5b9a\u98de\u673a\u7968&#034;<br \/>\n)<br \/>\ndef order_flight(departure_date: str, flight_number: str, seat_type: str, number: int) -&gt; str:<br \/>\n    &#039;&#039;&#039;<br \/>\n    Args:<br \/>\n        departure_date (str): \u51fa\u53d1\u65e5\u671f&#xff0c;\u5982 &#039;2025-10-30&#039;<br \/>\n        flight_number (str): \u98de\u673a\u73ed\u6b21&#xff0c;\u5982 &#039;CA6557&#039;<br \/>\n        seat_type (str): \u5ea7\u4f4d\u7c7b\u578b&#xff0c;\u5982 &#039;\u7ecf\u6d4e\u8231&#039;<br \/>\n        number (int): \u8ba2\u8d2d\u5f20\u6570<br \/>\n    &#039;&#039;&#039;<br \/>\n    # \u8bb0\u5f55\u8ba2\u7968\u65e5\u5fd7<br \/>\n    logger.info(f&#034;\u6b63\u5728\u8ba2\u8d2d\u98de\u673a\u7968: {departure_date}, {flight_number}, {seat_type}, {number}&#034;)<br \/>\n    logger.info(f&#034;\u606d\u559c&#xff0c;\u98de\u673a\u7968\u9884\u5b9a\u6210\u529f&#xff01;&#034;)<br \/>\n    # \u8fd4\u56de\u9884\u5b9a\u6210\u529f\u7684\u6d88\u606f<br \/>\n    return &#034;\u606d\u559c&#xff0c;\u98de\u673a\u7968\u9884\u5b9a\u6210\u529f&#xff01;&#034;<\/p>\n<p># &#8212; 4. \u5b9a\u4e49\u5de5\u5177&#xff1a;\u9884\u5b9a\u6f14\u5531\u4f1a\u7968 &#8212;<br \/>\n&#064;order_mcp.tool(<br \/>\n    name&#061;&#034;order_concert&#034;,<br \/>\n    description&#061;&#034;\u6839\u636e\u65f6\u95f4\u3001\u660e\u661f\u3001\u573a\u5730\u3001\u5ea7\u4f4d\u7c7b\u578b\u3001\u6570\u91cf\u9884\u5b9a\u6f14\u51fa\u7968&#034;<br \/>\n)<br \/>\ndef order_concert(start_date: str, aritist: str, venue: str, seat_type: str, number: int) -&gt; str:<br \/>\n    &#039;&#039;&#039;<br \/>\n    Args:<br \/>\n        start_date (str): \u5f00\u59cb\u65e5\u671f&#xff0c;\u5982 &#039;2025-10-30&#039;<br \/>\n        aritist (str): \u660e\u661f&#xff0c;\u5982 &#039;\u5200\u90ce&#039;<br \/>\n        venue (str): \u573a\u5730&#xff0c;\u5982 &#039;\u4e0a\u6d77\u4f53\u80b2\u9986&#039;<br \/>\n        seat_type (str): \u5ea7\u4f4d\u7c7b\u578b&#xff0c;\u5982 &#039;\u770b\u53f0&#039;<br \/>\n        number (int): \u8ba2\u8d2d\u5f20\u6570<br \/>\n    &#039;&#039;&#039;<br \/>\n    # \u8bb0\u5f55\u8ba2\u7968\u65e5\u5fd7<br \/>\n    logger.info(f&#034;\u6b63\u5728\u8ba2\u8d2d\u6f14\u51fa\u7968: {start_date}, {aritist}, {venue}, {seat_type}, {number}&#034;)<br \/>\n    logger.info(f&#034;\u606d\u559c&#xff0c;\u6f14\u51fa\u7968\u9884\u5b9a\u6210\u529f&#xff01;&#034;)<br \/>\n    # \u8fd4\u56de\u9884\u5b9a\u6210\u529f\u7684\u6d88\u606f<br \/>\n    return &#034;\u606d\u559c&#xff0c;\u6f14\u51fa\u7968\u9884\u5b9a\u6210\u529f&#xff01;&#034;<\/p>\n<p># &#8212; 5. \u521b\u5efa\u5e76\u8fd0\u884c\u670d\u52a1\u5668 &#8212;<br \/>\ndef create_order_mcp_server():<br \/>\n    # \u6253\u5370\u670d\u52a1\u5668\u4fe1\u606f\u5230\u65e5\u5fd7<br \/>\n    logger.info(&#034;&#061;&#061;&#061; \u7968\u52a1\u9884\u5b9aMCP\u670d\u52a1\u5668\u4fe1\u606f &#061;&#061;&#061;&#034;)<br \/>\n    logger.info(f&#034;\u540d\u79f0: {order_mcp.name}&#034;)<br \/>\n    logger.info(f&#034;\u63cf\u8ff0: {order_mcp.instructions}&#034;)<\/p>\n<p>    # \u8fd0\u884c\u670d\u52a1\u5668<br \/>\n    try:<br \/>\n        print(&#034;\u670d\u52a1\u5668\u5df2\u542f\u52a8&#xff0c;\u8bf7\u8bbf\u95ee http:\/\/127.0.0.1:8003\/mcp&#034;)<br \/>\n        # \u542f\u52a8\u670d\u52a1\u5668&#xff0c;\u5e76\u6307\u5b9a\u4f7f\u7528 &#034;streamable-http&#034; \u4f5c\u4e3a\u4f20\u8f93\u534f\u8bae<br \/>\n        order_mcp.run(transport&#061;&#034;streamable-http&#034;)<br \/>\n    except Exception as e:<br \/>\n        print(f&#034;\u670d\u52a1\u5668\u542f\u52a8\u5931\u8d25: {e}&#034;)<\/p>\n<p># Python \u7684\u6807\u51c6\u5165\u53e3\u70b9<br \/>\nif __name__ &#061;&#061; &#034;__main__&#034;:<br \/>\n    # \u8c03\u7528\u51fd\u6570\u542f\u52a8\u670d\u52a1\u5668<br \/>\n    create_order_mcp_server() <\/p>\n<p>\u57fa\u4e8e FastMCP \u6846\u67b6\u6784\u5efa\u7684\u00a0\u7968\u52a1\u9884\u5b9a MCP \u670d\u52a1\u5668\u3002\u5b83\u5b9a\u4e49\u4e86\u4e09\u4e2a\u6838\u5fc3\u5de5\u5177&#xff0c;\u5206\u522b\u7528\u4e8e\u9884\u5b9a\u706b\u8f66\u7968\u3001\u98de\u673a\u7968\u548c\u6f14\u5531\u4f1a\u95e8\u7968&#xff0c;\u5e76\u901a\u8fc7\u00a0streamable-http\u00a0\u534f\u8bae\u5728\u00a08003\u00a0\u7aef\u53e3\u5bf9\u5916\u63d0\u4f9b\u670d\u52a1<\/p>\n<p>\u5ba2\u6237\u7aef\u6d4b\u8bd5&#xff1a;<\/p>\n<p>\u4f4d\u7f6e&#xff1a;<span style=\"color:#fe2c24\">\/test\/test_order_mcp_server.py<\/span><\/p>\n<p>import asyncio<br \/>\nimport json<\/p>\n<p># \u4ece LangChain \u5bfc\u5165\u6784\u5efa Agent \u6240\u9700\u7684\u6838\u5fc3\u7ec4\u4ef6<br \/>\nfrom langchain.agents import create_tool_calling_agent, AgentExecutor<br \/>\nfrom langchain_core.prompts import ChatPromptTemplate<br \/>\nfrom langchain_mcp_adapters.tools import load_mcp_tools<br \/>\nfrom langchain_openai import ChatOpenAI<\/p>\n<p># \u4ece MCP \u5e93\u5bfc\u5165\u5efa\u7acb\u5ba2\u6237\u7aef\u4f1a\u8bdd\u6240\u9700\u7684\u7ec4\u4ef6<br \/>\nfrom mcp import ClientSession<br \/>\nfrom mcp.client.streamable_http import streamablehttp_client<\/p>\n<p># \u4ece\u9879\u76ee\u914d\u7f6e\u4e2d\u5bfc\u5165\u914d\u7f6e\u548c\u65e5\u5fd7\u8bb0\u5f55\u5668<br \/>\nfrom config import Config<br \/>\nfrom create_logger import logger<\/p>\n<p>conf &#061; Config()<\/p>\n<p># &#8212; 1. \u521d\u59cb\u5316\u5927\u8bed\u8a00\u6a21\u578b (LLM) &#8212;<br \/>\n# \u4f7f\u7528 ChatOpenAI \u7c7b\u521d\u59cb\u5316\u4e00\u4e2a LLM \u5b9e\u4f8b<br \/>\n# \u6a21\u578b\u7684\u540d\u79f0\u3001API \u5730\u5740\u548c\u5bc6\u94a5\u90fd\u4ece\u914d\u7f6e\u6587\u4ef6\u4e2d\u52a0\u8f7d<br \/>\nllm &#061; ChatOpenAI(<br \/>\n    model&#061;conf.model_name,<br \/>\n    base_url&#061;conf.base_url,<br \/>\n    api_key&#061;conf.api_key,<br \/>\n    temperature&#061;0.1  # \u8bbe\u7f6e\u8f83\u4f4e\u7684\u6e29\u5ea6&#xff0c;\u4f7f\u6a21\u578b\u8f93\u51fa\u66f4\u786e\u5b9a<br \/>\n)<\/p>\n<p># &#8212; 2. \u5b9a\u4e49\u5f02\u6b65\u7684\u7968\u52a1\u9884\u5b9a\u4e3b\u51fd\u6570 &#8212;<br \/>\nasync def order_tickets(query):<br \/>\n    try:<br \/>\n        # &#8212; 2.1 \u5efa\u7acb\u4e0e MCP \u670d\u52a1\u5668\u7684\u8fde\u63a5 &#8212;<br \/>\n        # \u4f7f\u7528 streamablehttp_client \u8fde\u63a5\u5230\u7968\u52a1\u9884\u5b9a\u670d\u52a1\u5668<br \/>\n        async with streamablehttp_client(&#034;http:\/\/127.0.0.1:8003\/mcp&#034;) as (read, write, _):<br \/>\n            # \u4f7f\u7528\u8bfb\u5199\u901a\u9053\u521b\u5efa\u4e00\u4e2a MCP \u5ba2\u6237\u7aef\u4f1a\u8bdd<br \/>\n            async with ClientSession(read, write) as session:<br \/>\n                try:<br \/>\n                    # \u521d\u59cb\u5316\u4f1a\u8bdd<br \/>\n                    await session.initialize()<\/p>\n<p>                    # &#8212; 2.2 \u52a8\u6001\u52a0\u8f7d\u5de5\u5177 &#8212;<br \/>\n                    # \u4ece\u5df2\u8fde\u63a5\u7684 MCP \u670d\u52a1\u5668\u81ea\u52a8\u53d1\u73b0\u5e76\u52a0\u8f7d\u6240\u6709\u53ef\u7528\u7684\u5de5\u5177<br \/>\n                    # \u8fd9\u4e9b\u5de5\u5177&#xff08;\u5982 order_train, order_flight&#xff09;\u5c06\u4f5c\u4e3a Agent \u7684\u201c\u624b\u201d<br \/>\n                    tools &#061; await load_mcp_tools(session)<\/p>\n<p>                    # &#8212; 2.3 \u521b\u5efa Agent \u7684\u63d0\u793a\u8bcd\u6a21\u677f &#8212;<br \/>\n                    # \u5b9a\u4e49 Agent \u7684\u884c\u4e3a\u51c6\u5219\u548c\u5bf9\u8bdd\u7ed3\u6784<br \/>\n                    prompt &#061; ChatPromptTemplate.from_messages([<br \/>\n                        (&#034;system&#034;,<br \/>\n                         &#034;\u4f60\u662f\u4e00\u4e2a\u7968\u52a1\u9884\u5b9a\u52a9\u624b&#xff0c;\u80fd\u591f\u8c03\u7528\u5de5\u5177\u6765\u5b8c\u6210\u706b\u8f66\u7968\u3001\u98de\u673a\u7968\u6216\u6f14\u51fa\u7968\u7684\u9884\u5b9a\u3002\u4f60\u9700\u8981\u4ed4\u7ec6\u5206\u6790\u5de5\u5177\u9700\u8981\u7684\u53c2\u6570&#xff0c;\u7136\u540e\u4ece\u7528\u6237\u63d0\u4f9b\u7684\u4fe1\u606f\u4e2d\u63d0\u53d6\u4fe1\u606f\u3002\u5982\u679c\u7528\u6237\u63d0\u4f9b\u7684\u4fe1\u606f\u4e0d\u8db3\u4ee5\u63d0\u53d6\u5230\u8c03\u7528\u5de5\u5177\u6240\u6709\u5fc5\u8981\u53c2\u6570&#xff0c;\u5219\u5411\u7528\u6237\u8ffd\u95ee&#xff0c;\u4ee5\u83b7\u53d6\u8be5\u4fe1\u606f\u3002\u4e0d\u80fd\u81ea\u5df1\u7f16\u64b0\u53c2\u6570\u3002&#034;),<br \/>\n                        (&#034;human&#034;, &#034;{input}&#034;),<br \/>\n                        (&#034;placeholder&#034;, &#034;{agent_scratchpad}&#034;),<br \/>\n                    ])<\/p>\n<p>                    # &#8212; 2.4 \u6784\u5efa\u5e76\u6267\u884c Agent &#8212;<br \/>\n                    # 1. \u521b\u5efa\u5de5\u5177\u8c03\u7528 Agent&#xff1a;\u5c06 LLM\u3001\u5de5\u5177\u548c\u63d0\u793a\u8bcd\u6a21\u677f\u7ec4\u5408\u5728\u4e00\u8d77<br \/>\n                    agent &#061; create_tool_calling_agent(llm, tools, prompt)<\/p>\n<p>                    # 2. \u521b\u5efa Agent \u6267\u884c\u5668&#xff1a;\u8d1f\u8d23\u8fd0\u884c Agent \u7684\u903b\u8f91&#xff0c;verbose&#061;True \u4f1a\u6253\u5370\u8be6\u7ec6\u8fc7\u7a0b<br \/>\n                    agent_executor &#061; AgentExecutor(agent&#061;agent, tools&#061;tools, verbose&#061;True)<\/p>\n<p>                    # 3. \u8c03\u7528 Agent&#xff1a;\u5c06\u7528\u6237\u7684\u67e5\u8be2\u4f20\u5165&#xff0c;\u5e76\u7b49\u5f85\u6267\u884c\u7ed3\u679c<br \/>\n                    response &#061; await agent_executor.ainvoke({&#034;input&#034;: query})<\/p>\n<p>                    # \u8fd4\u56de Agent \u7684\u6700\u7ec8\u8f93\u51fa<br \/>\n                    return response[&#039;output&#039;]<br \/>\n                except Exception as e:<br \/>\n                    # \u6355\u83b7\u5e76\u8bb0\u5f55\u4f1a\u8bdd\u5185\u90e8\u7684\u9519\u8bef<br \/>\n                    logger.info(f&#034;\u7968\u52a1 MCP \u6d4b\u8bd5\u51fa\u9519&#xff1a;{str(e)}&#034;)<br \/>\n                    return f&#034;\u7968\u52a1 MCP \u67e5\u8be2\u51fa\u9519&#xff1a;{str(e)}&#034;<br \/>\n    except Exception as e:<br \/>\n        # \u6355\u83b7\u5e76\u8bb0\u5f55\u8fde\u63a5\u6216\u4f1a\u8bdd\u521d\u59cb\u5316\u7684\u9519\u8bef<br \/>\n        logger.error(f&#034;\u8fde\u63a5\u6216\u4f1a\u8bdd\u521d\u59cb\u5316\u65f6\u53d1\u751f\u9519\u8bef: {e}&#034;)<br \/>\n        return &#034;\u8fde\u63a5\u6216\u4f1a\u8bdd\u521d\u59cb\u5316\u65f6\u53d1\u751f\u9519\u8bef&#034;<\/p>\n<p># &#8212; 3. \u4e3b\u7a0b\u5e8f\u5165\u53e3 &#8212;<br \/>\nif __name__ &#061;&#061; &#034;__main__&#034;:<br \/>\n    # \u521b\u5efa\u4e00\u4e2a\u7b80\u5355\u7684\u547d\u4ee4\u884c\u4ea4\u4e92\u5faa\u73af<br \/>\n    while True:<br \/>\n        query &#061; input(&#034;\u8bf7\u8f93\u5165\u67e5\u8be2&#xff1a;&#034;)<br \/>\n        if query &#061;&#061; &#034;exit&#034;:<br \/>\n            break<br \/>\n        # \u8fd0\u884c\u5f02\u6b65\u7684 order_tickets \u51fd\u6570\u5e76\u6253\u5370\u7ed3\u679c<br \/>\n        print(asyncio.run(order_tickets(query))) <\/p>\n<p>\u57fa\u4e8e LangChain \u6846\u67b6\u6784\u5efa\u7684\u00a0AI \u7968\u52a1\u9884\u5b9a\u52a9\u624b\u3002\u5b83\u4f5c\u4e3a\u5ba2\u6237\u7aef&#xff0c;\u8fde\u63a5\u5230\u8fd0\u884c\u5728\u00a08003\u00a0\u7aef\u53e3\u7684\u7968\u52a1\u9884\u5b9a MCP \u670d\u52a1\u5668&#xff0c;\u901a\u8fc7\u5927\u8bed\u8a00\u6a21\u578b&#xff08;LLM&#xff09;\u7406\u89e3\u7528\u6237\u610f\u56fe&#xff0c;\u5e76\u81ea\u52a8\u8c03\u7528\u76f8\u5e94\u7684\u5de5\u5177\u6765\u5b8c\u6210\u706b\u8f66\u7968\u3001\u98de\u673a\u7968\u6216\u6f14\u5531\u4f1a\u95e8\u7968\u7684\u9884\u5b9a<\/p>\n<p id=\"articleContentId\">\u3010\u4e0a\u4e00\u7bc7\u3011\u3010AI\u5927\u6a21\u578b\u5e94\u7528\u5f00\u53d1\u3011\u3010\u9879\u76ee\u5b9e\u6218\u301134.\u57fa\u4e8eA2A\u534f\u8bae\u7684\u667a\u80fd\u52a9\u624b(\u591a\u667a\u80fd\u4f53)(\u4e8c)\u9879\u76ee\u5b9e\u73b0\u4e4b\u9879\u76ee\u67b6\u6784\u56fe&amp;\u914d\u7f6e\u6a21\u5757&amp;\u6570\u636e\u6a21\u5757<\/p>\n<p>\u3010\u4e0b\u4e00\u7bc7\u3011\u3010AI\u5927\u6a21\u578b\u5e94\u7528\u5f00\u53d1\u3011\u3010\u9879\u76ee\u5b9e\u6218\u301136.\u57fa\u4e8eA2A\u534f\u8bae\u7684\u667a\u80fd\u52a9\u624b(\u591a\u667a\u80fd\u4f53)(\u56db)\u9879\u76ee\u5b9e\u73b0\u4e4b\u5929\u6c14Agent\u670d\u52a1\u5668&amp;\u7968\u52a1\u5458Agent\u670d\u52a1\u5668&amp;\u8ba2\u7968Agent\u670d\u52a1\u5668<\/p>\n","protected":false},"excerpt":{"rendered":"<p>6.\u5929\u6c14MCP\u670d\u52a1\u5668 mcp_weather_server\u5929\u6c14 MCP \u670d\u52a1\u5668&#xff0c;\u63d0\u4f9b weather_data \u8868\u7684 SELECT \u67e5\u8be2\u63a5\u53e3&#xff0c;\u8fd4\u56de JSON \u683c\u5f0f\u7ed3\u679c \u6838\u5fc3\u529f\u80fd&#xff1a; \u521d\u59cb\u5316 MySQL \u6570\u636e\u5e93\u8fde\u63a5  \u6267\u884c SELECT \u67e5\u8be2&#xff0c;\u8fd4\u56de JSON \u683c\u5f0f\u7ed3\u679c  \u683c\u5f0f\u5316\u65e5\u671f\u548c\u6570\u503c\u5b57\u6bb5&#xff0c;\u786e\u4fdd JSON \u5e8f\u5217\u5316\u517c\u5bb9  \u901a\u8fc7 FastAPI \u63d0\u4f9b HTTP \u63a5\u53e3&#xff0c;\u54cd\u5e94 MCP \u5de5\u5177\u8c03\u7528  6.1<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[8072,11993,11994,3422,74],"topic":[],"class_list":["post-105783","post","type-post","status-publish","format-standard","hentry","category-server","tag-8072","tag-mcp","tag-a2a","tag-agent"],"yoast_head":"<!-- This site is optimized with the Yoast SEO plugin v20.3 - https:\/\/yoast.com\/wordpress\/plugins\/seo\/ -->\n<title>\u3010AI\u5927\u6a21\u578b\u5e94\u7528\u5f00\u53d1\u3011\u3010\u9879\u76ee\u5b9e\u6218\u301135.\u57fa\u4e8eA2A\u534f\u8bae\u7684\u667a\u80fd\u52a9\u624b(\u591a\u667a\u80fd\u4f53)(\u4e09)\u9879\u76ee\u5b9e\u73b0\u4e4b\u5929\u6c14MCP\u670d\u52a1\u5668&amp;\u7968\u52a1\u5458MCP\u670d\u52a1\u5668&amp;\u8ba2\u7968MCP\u670d\u52a1\u5668 - \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\/105783.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u3010AI\u5927\u6a21\u578b\u5e94\u7528\u5f00\u53d1\u3011\u3010\u9879\u76ee\u5b9e\u6218\u301135.\u57fa\u4e8eA2A\u534f\u8bae\u7684\u667a\u80fd\u52a9\u624b(\u591a\u667a\u80fd\u4f53)(\u4e09)\u9879\u76ee\u5b9e\u73b0\u4e4b\u5929\u6c14MCP\u670d\u52a1\u5668&amp;\u7968\u52a1\u5458MCP\u670d\u52a1\u5668&amp;\u8ba2\u7968MCP\u670d\u52a1\u5668 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"6.\u5929\u6c14MCP\u670d\u52a1\u5668 mcp_weather_server\u5929\u6c14 MCP \u670d\u52a1\u5668&#xff0c;\u63d0\u4f9b weather_data \u8868\u7684 SELECT \u67e5\u8be2\u63a5\u53e3&#xff0c;\u8fd4\u56de JSON \u683c\u5f0f\u7ed3\u679c \u6838\u5fc3\u529f\u80fd&#xff1a; \u521d\u59cb\u5316 MySQL \u6570\u636e\u5e93\u8fde\u63a5 \u6267\u884c SELECT \u67e5\u8be2&#xff0c;\u8fd4\u56de JSON \u683c\u5f0f\u7ed3\u679c \u683c\u5f0f\u5316\u65e5\u671f\u548c\u6570\u503c\u5b57\u6bb5&#xff0c;\u786e\u4fdd JSON \u5e8f\u5217\u5316\u517c\u5bb9 \u901a\u8fc7 FastAPI \u63d0\u4f9b HTTP \u63a5\u53e3&#xff0c;\u54cd\u5e94 MCP \u5de5\u5177\u8c03\u7528 6.1\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/105783.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-09-15T16:56:38+00:00\" \/>\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=\"17 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/105783.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/105783.html\",\"name\":\"\u3010AI\u5927\u6a21\u578b\u5e94\u7528\u5f00\u53d1\u3011\u3010\u9879\u76ee\u5b9e\u6218\u301135.\u57fa\u4e8eA2A\u534f\u8bae\u7684\u667a\u80fd\u52a9\u624b(\u591a\u667a\u80fd\u4f53)(\u4e09)\u9879\u76ee\u5b9e\u73b0\u4e4b\u5929\u6c14MCP\u670d\u52a1\u5668&amp;\u7968\u52a1\u5458MCP\u670d\u52a1\u5668&amp;\u8ba2\u7968MCP\u670d\u52a1\u5668 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-09-15T16:56:38+00:00\",\"dateModified\":\"2026-09-15T16:56:38+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/105783.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/105783.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/105783.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u3010AI\u5927\u6a21\u578b\u5e94\u7528\u5f00\u53d1\u3011\u3010\u9879\u76ee\u5b9e\u6218\u301135.\u57fa\u4e8eA2A\u534f\u8bae\u7684\u667a\u80fd\u52a9\u624b(\u591a\u667a\u80fd\u4f53)(\u4e09)\u9879\u76ee\u5b9e\u73b0\u4e4b\u5929\u6c14MCP\u670d\u52a1\u5668&amp;\u7968\u52a1\u5458MCP\u670d\u52a1\u5668&amp;\u8ba2\u7968MCP\u670d\u52a1\u5668\"}]},{\"@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":"\u3010AI\u5927\u6a21\u578b\u5e94\u7528\u5f00\u53d1\u3011\u3010\u9879\u76ee\u5b9e\u6218\u301135.\u57fa\u4e8eA2A\u534f\u8bae\u7684\u667a\u80fd\u52a9\u624b(\u591a\u667a\u80fd\u4f53)(\u4e09)\u9879\u76ee\u5b9e\u73b0\u4e4b\u5929\u6c14MCP\u670d\u52a1\u5668&amp;\u7968\u52a1\u5458MCP\u670d\u52a1\u5668&amp;\u8ba2\u7968MCP\u670d\u52a1\u5668 - \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\/105783.html","og_locale":"zh_CN","og_type":"article","og_title":"\u3010AI\u5927\u6a21\u578b\u5e94\u7528\u5f00\u53d1\u3011\u3010\u9879\u76ee\u5b9e\u6218\u301135.\u57fa\u4e8eA2A\u534f\u8bae\u7684\u667a\u80fd\u52a9\u624b(\u591a\u667a\u80fd\u4f53)(\u4e09)\u9879\u76ee\u5b9e\u73b0\u4e4b\u5929\u6c14MCP\u670d\u52a1\u5668&amp;\u7968\u52a1\u5458MCP\u670d\u52a1\u5668&amp;\u8ba2\u7968MCP\u670d\u52a1\u5668 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"6.\u5929\u6c14MCP\u670d\u52a1\u5668 mcp_weather_server\u5929\u6c14 MCP \u670d\u52a1\u5668&#xff0c;\u63d0\u4f9b weather_data \u8868\u7684 SELECT \u67e5\u8be2\u63a5\u53e3&#xff0c;\u8fd4\u56de JSON \u683c\u5f0f\u7ed3\u679c \u6838\u5fc3\u529f\u80fd&#xff1a; \u521d\u59cb\u5316 MySQL \u6570\u636e\u5e93\u8fde\u63a5 \u6267\u884c SELECT \u67e5\u8be2&#xff0c;\u8fd4\u56de JSON \u683c\u5f0f\u7ed3\u679c \u683c\u5f0f\u5316\u65e5\u671f\u548c\u6570\u503c\u5b57\u6bb5&#xff0c;\u786e\u4fdd JSON \u5e8f\u5217\u5316\u517c\u5bb9 \u901a\u8fc7 FastAPI \u63d0\u4f9b HTTP \u63a5\u53e3&#xff0c;\u54cd\u5e94 MCP \u5de5\u5177\u8c03\u7528 6.1","og_url":"https:\/\/www.wsisp.com\/helps\/105783.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-09-15T16:56:38+00:00","author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"17 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/105783.html","url":"https:\/\/www.wsisp.com\/helps\/105783.html","name":"\u3010AI\u5927\u6a21\u578b\u5e94\u7528\u5f00\u53d1\u3011\u3010\u9879\u76ee\u5b9e\u6218\u301135.\u57fa\u4e8eA2A\u534f\u8bae\u7684\u667a\u80fd\u52a9\u624b(\u591a\u667a\u80fd\u4f53)(\u4e09)\u9879\u76ee\u5b9e\u73b0\u4e4b\u5929\u6c14MCP\u670d\u52a1\u5668&amp;\u7968\u52a1\u5458MCP\u670d\u52a1\u5668&amp;\u8ba2\u7968MCP\u670d\u52a1\u5668 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-09-15T16:56:38+00:00","dateModified":"2026-09-15T16:56:38+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/105783.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/105783.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/105783.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"\u3010AI\u5927\u6a21\u578b\u5e94\u7528\u5f00\u53d1\u3011\u3010\u9879\u76ee\u5b9e\u6218\u301135.\u57fa\u4e8eA2A\u534f\u8bae\u7684\u667a\u80fd\u52a9\u624b(\u591a\u667a\u80fd\u4f53)(\u4e09)\u9879\u76ee\u5b9e\u73b0\u4e4b\u5929\u6c14MCP\u670d\u52a1\u5668&amp;\u7968\u52a1\u5458MCP\u670d\u52a1\u5668&amp;\u8ba2\u7968MCP\u670d\u52a1\u5668"}]},{"@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\/105783","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=105783"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/105783\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=105783"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=105783"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=105783"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=105783"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}