联网搜索

import os
import dashscope

response = dashscope.Generation.call(
  api_key=os.getenv("DASHSCOPE_API_KEY"),
  model="qwen-plus",
  messages=[{"role": "user", "content": "杭州明天天气是什么？"}],
  enable_search=True,
  search_options={
    "enable_source": True,
    "enable_citation": True,
    "citation_format": "[ref_<number>]"
  },
  result_format="message"
)
for web in response.output.search_info["search_results"]:
  print(f"[{web['index']}]: [{web['title']}]({web['url']})")
print(response.output.choices[0].message.content)

import os
from openai import OpenAI

client = OpenAI(
  api_key=os.getenv("DASHSCOPE_API_KEY"),
  base_url="https://dashscope.aliyuncs.com/compatible-mode/v1",
)
completion = client.chat.completions.create(
  model="qwen-plus",
  messages=[{"role": "user", "content": "结合近期AI热点新闻，预测AI的发展趋势"}],
  extra_body={
    "enable_thinking": True,
    "enable_search": True,
    "search_options": {
      "forced_search": True,
      "search_strategy": "max"
    }
  },
  stream=True,
  stream_options={"include_usage": True}
)

is_answering = False
for chunk in completion:
  if not chunk.choices:
    print(chunk.usage)
    continue
  delta = chunk.choices[0].delta
  if hasattr(delta, "reasoning_content") and delta.reasoning_content:
    print(delta.reasoning_content, end="", flush=True)
  elif delta.content:
    if not is_answering:
      print("\n--- 回复 ---")
      is_answering = True
    print(delta.content, end="", flush=True)