函数调用

{
  "name": "search_database",
  "description": "搜索产品数据库",
  "parameters": {
    "type": "object",
    "properties": {
      "query": {
        "type": "string",
        "description": "搜索关键词"
      },
      "filters": {
        "type": "object",
        "properties": {
          "category": {"type": "string"},
          "price_range": {
            "type": "object",
            "properties": {
              "min": {"type": "number"},
              "max": {"type": "number"}
            }
          }
        }
      },
      "limit": {
        "type": "integer",
        "default": 10
      }
    },
    "required": ["query"]
  }
}

# 1. 用户请求
user_message = "帮我找价格在1000-2000元的笔记本电脑"

# 2. 模型决策
response = llm.chat(
    messages=[{"role": "user", "content": user_message}],
    tools=[search_database_tool]
)

# 3. 函数执行
if response.tool_calls:
    tool_call = response.tool_calls[0]
    result = execute_function(
        name=tool_call.name,
        arguments=tool_call.arguments
    )
    
# 4. 结果整合
final_response = llm.chat(
    messages=[
        {"role": "user", "content": user_message},
        {"role": "assistant", "tool_calls": [tool_call]},
        {"role": "tool", "content": result}
    ]
)

# 传统串行：8秒
weather = get_weather("Beijing")  # 2s
news = get_news("Beijing")        # 3s  
events = get_events("Beijing")    # 3s

# 并行优化：3秒
results = await asyncio.gather(
    get_weather("Beijing"),
    get_news("Beijing"),
    get_events("Beijing")
)

// MCP工具定义
{
  "tool": {
    "name": "database_query",
    "description": "Query SQL database",
    "inputSchema": {
      "type": "object",
      "properties": {
        "sql": {"type": "string"},
        "database": {"type": "string"}
      }
    }
  }
}

@require_permissions(["read:database", "write:logs"])
def sensitive_function(params):
    # 执行前验证权限
    if not check_user_permissions(current_user, required_perms):
        raise PermissionError("Insufficient permissions")
    
    # 记录审计日志
    audit_log.record(user=current_user, action="database_query", params=params)
    
    # 执行实际操作
    return execute_query(params)

tools = [
    check_order_status,      # 查询订单
    process_refund,          # 处理退款
    update_shipping_address, # 更新地址
    escalate_to_human       # 转人工
]

tools = [
    query_database,         # SQL查询
    create_visualization,   # 生成图表
    export_report,         # 导出报告
    schedule_analysis      # 定时分析
]

tools = [
    deploy_application,    # 部署应用
    rollback_version,      # 版本回滚
    check_system_health,   # 健康检查
    alert_oncall_team     # 告警通知
]