1. 项目概述：当AI遇上气象服务

最近在测试DeepSeek系列大模型时，发现其函数调用能力特别适合做垂直领域Agent开发。就拿天气查询这个高频场景来说，传统天气API只能返回结构化数据，而结合大模型的自然语言处理能力，我们可以打造一个能理解复杂需求、支持多轮对话的智能天气助手。这个周末我花了些时间完整走通了开发流程，以下是具体实现方案和踩坑记录。

2. 技术选型与架构设计

2.1 核心组件拆解

整个系统需要三个关键部分协同工作：

1. 大模型中枢：采用DeepSeek最新开源模型作为决策核心，负责意图识别、对话管理和结果生成
2. 天气数据源：对比了多家气象服务商后，选择高德天气API（日均100万次免费调用）
3. 函数调用桥接层：用FastAPI搭建中间件处理API签名、参数转换和结果缓存

2.2 数据流设计

典型查询会经历以下处理流程：

用户提问 → 模型意图识别 → 提取地点/时间参数 → 调用天气API → 原始数据格式化 → 生成自然语言回复

特别要注意时区转换问题——国内API返回的是UTC+8时间，而国际用户可能期望本地时区显示。我在函数调用层内置了时区自动检测逻辑，根据IP地址自动转换时间表述。

3. 关键实现步骤

3.1 环境准备

需要安装这些核心依赖：

pip install deepseek-llm fastapi requests python-dotenv

创建.env文件存放敏感配置：

DEEPSEEK_KEY=your_api_key_here AMAP_WEATHER_KEY=your_weather_key

3.2 函数注册样板代码

这是让模型理解天气查询能力的核心配置：

weather_tools = [ { "type": "function", "function": { "name": "get_current_weather", "description": "获取指定城市的实时天气数据", "parameters": { "type": "object", "properties": { "location": { "type": "string", "description": "城市名称，如'北京市'" }, "unit": { "type": "string", "enum": ["celsius", "fahrenheit"], "default": "celsius" } }, "required": ["location"] } } } ]

3.3 API响应处理技巧

高德API返回的数据结构较复杂，需要做智能降噪：

def simplify_weather_data(raw_data): # 提取核心指标 return { "temp": raw_data['live']['temperature'], "humidity": raw_data['live']['humidity'], "wind": f"{raw_data['live']['winddirection']}风{raw_data['live']['windpower']}级", "report_time": raw_data['live']['reporttime'].split()[1] }

4. 高级功能实现

4.1 多轮对话记忆

通过session_id维护对话上下文：

from collections import defaultdict session_contexts = defaultdict(dict) def handle_followup(query, session_id): if "昨天" in query and session_contexts[session_id].get('last_query'): # 自动关联前次查询地点 params['location'] = session_contexts[session_id]['location'] params['date'] = calculate_relative_date(-1)

4.2 预警信息突出显示

对气象灾害预警做特殊处理：

response_template = """ 当前{location}天气： 🌡温度：{temp}°C 💧湿度：{humidity}% 🌬{wind} {% if alarm %} ⚠️气象预警：{alarm} {% endif %} """

5. 部署优化方案

5.1 性能调优实测

三个关键优化点：

1. 启用gzip压缩后API响应体积减少73%
2. 对城市坐标做本地缓存，减少地理编码API调用
3. 使用uvicorn workers=4 时QPS可达120+

5.2 安全防护措施

必须实现的防护策略：

• API密钥轮换机制（每周自动更新）
• 请求频率限制（IP+user_token双维度）
• SQL注入过滤（虽然参数经过模型清洗，仍需防范）

6. 典型问题排查

6.1 地点歧义处理

当用户查询"北京天气"时，模型可能混淆：

• 北京市朝阳区
• 吉林省长春市朝阳区

解决方案是在函数调用时追加行政层级校验：

def validate_location(location): if '朝阳' in location and '北京' not in location: return ask_for_clarification()

6.2 单位转换陷阱

华氏度转换时容易犯的错误：

# 错误做法：直接 (temp * 9/5) + 32 # 正确做法：先检查原始数据是否已是华氏度 if unit == 'fahrenheit' and not is_fahrenheit(raw_temp): converted = (float(raw_temp) * 9/5) + 32

7. 扩展应用场景

基于这个基础框架，还可以扩展这些实用功能：

• 天气对农业活动的影响建议（结合农作物生长周期）
• 航班延误预测（整合历史气象数据）
• 穿衣推荐系统（加入体感温度算法）

我在项目仓库里放了完整的docker-compose部署文件，包含Prometheus监控看板配置。实际运行中发现内存占用会随时间增长，后来通过定期清理对话缓存解决了这个问题。建议每24小时重启一次容器服务，这对API服务来说是可接受的维护窗口。