qwen.py 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110
  1. import dashscope
  2. class QwenClient:
  3. def __init__(self):
  4. self.api_key = "sk-1022fe8e15ff4e0e9abc20541b281165"
  5. def search_and_chat(
  6. self,
  7. model="qwen3-max",
  8. system_prompt="You are a helpful assistant.",
  9. user_prompt="",
  10. search_strategy="max",
  11. ):
  12. """
  13. 搜索并聊天
  14. Args:
  15. model: 模型名称,默认为qwen3-max
  16. system_prompt: 系统提示词
  17. user_prompt: 用户提示词
  18. search_strategy: 搜索策略,可选值: turbo, max, agent
  19. Returns:
  20. dict: 包含回复内容和搜索结果
  21. """
  22. try:
  23. messages = [
  24. {"role": "system", "content": system_prompt},
  25. {"role": "user", "content": user_prompt},
  26. ]
  27. response = dashscope.Generation.call(
  28. api_key=self.api_key,
  29. model=model,
  30. messages=messages,
  31. enable_search=True,
  32. search_options={
  33. "forced_search": True,
  34. "enable_source": True,
  35. "search_strategy": search_strategy,
  36. },
  37. result_format="message",
  38. )
  39. if response.status_code != 200:
  40. raise Exception(f"API调用失败: {response.message}")
  41. content = response["output"]["choices"][0]["message"]["content"]
  42. search_results = []
  43. if hasattr(response.output, "search_info") and response.output.search_info:
  44. search_results = response.output.search_info.get("search_results", [])
  45. return {"content": content, "search_results": search_results}
  46. except Exception as e:
  47. raise Exception(f"QwenClient search_and_chat失败: {str(e)}")
  48. if __name__ == "__main__":
  49. client = QwenClient()
  50. # 测试
  51. try:
  52. # result = client.chat(user_prompt="hello")
  53. # print(result)
  54. user_prompt = """你是一个专业的信息搜索专家,负责从网络中搜索某个工具的页面操作路径
  55. **名词解释**
  56. 页面操作路径:表示在网页上使用某个工具完成某个功能需要进行的必要操作。通常是分步骤操作,最后形成一个完整的页面操作路径。
  57. 比如:1. 打开xxx网站, 2. 输入xxx提示词, 3. 点击确认按钮, 4. 等待图片生成完成, 5. 返回图片的url
  58. **任务目标**
  59. 搜索并整理 新红热搜词榜单功能 的页面操作路径
  60. **数据要求**
  61. - 操作页面必须是官方网站,排除任何第三方网站、移动端APP、PC软件
  62. - 页面操作路径数据最好有详细的操作步骤,如果没有,也可以是简单的操作步骤描述。步骤中如果包含账号注册/登录,需要去除,我们假设网站已经成功登录了
  63. - 页面操作路径数据要排除关于API的调用数据
  64. - 保留原始链接用于追溯,输出在 content_link 字段
  65. - 整理工具的核心功能名称和功能描述
  66. - 如果有多份数据,保留和任务目标最相关的一份数据即可
  67. **输出要求:**
  68. 严格按照以下JSON格式输出,不添加任何其他文字说明:
  69. {
  70. "content_link": "原始链接地址",
  71. "功能名称": "具体功能名称",
  72. "功能描述": "功能用途和作用描述",
  73. "页面操作路径": "完整的页面操作路径"
  74. }"""
  75. # user_prompt = "请搜索 白瓜AI 官网"
  76. result = client.search_and_chat(
  77. user_prompt=user_prompt, search_strategy="agent"
  78. )
  79. print("=" * 20 + "搜索结果" + "=" * 20)
  80. for web in result["search_results"]:
  81. print(f"[{web['index']}]: [{web['title']}]({web['url']})")
  82. print("=" * 20 + "回复内容" + "=" * 20)
  83. print(result["content"])
  84. except Exception as e:
  85. print(f"错误: {e}")