下面这段代码演示了如何利用 实现流式对话 + 多轮上下文记忆 .注意，这里我们把alert-style 的打印换成了geng自然的日志输出，让阅读体验geng轻松一些：

import asyncio
from claude_agent_sdk import ClaudeSDKClient
# 创建客户端实例
client = ClaudeSDKClient
async def user_message_stream:
    # 第一次询问：让 Agent 检查仓库中的安全漏洞
    yield {
        "type": "user",
        "message": {
            "role": "user",
            "content": "请帮我分析当前项目里的所有 Python 文件，有没有潜在的安全风险？"
        }
    }
    # 假装用户等了几秒钟再补充说明
    await asyncio.sleep
    # 第二次补充：提供一张架构图，让模型Zuo视觉分析
    from pathlib import Path
    img_b64 = Path.read_bytes
    yield {
        "type": "user",
        "message": {
            "role": "user",
            "content": 
        }
    }
# 使用 query 发起流式请求
async def main:
    async for msg in client.query(
        prompt=user_message_stream,
        options={"maxTurns": 5, "allowedTools": }):
        if msg == "result":
            print
            print
        elif msg == "intermediate":
            # 中间状态会实时打印出来帮助我们观察思考链
            print
if __name__ == "__main__":
    asyncio.run)

这段代码里Zui关键的是async generator + query. 我们只需要不断"yield" 消息进去，SDK 会自动维护会话上下文，并把每一步产生的结果逐行抛给你。想象一下当你的 IDE 正在显示“正在读取文件…”、“正在运行安全规则…”之类提示时你Yi经站在了 AI 思考的前面！

import { query } from "@anthropic-ai/claude-agent-sdk";
import { readFile } from "fs/promises";
async function* buildMessages {
  // 第一道题目：文字提问
  yield {
      type: "user",
      message: {
          role: "user",
          content: { type:"text", text:"请帮我审计这个 repo 中所有依赖项是否有Yi知 CVE。" }
      }
  };
  // 等待用户自行补充指令
  await new Promise);
  // 第二道题目：附带图片进行视觉分析
  const png = await readFile;
  yield {
      type:"user",
      message:{
          role:"user",
          content:
      }
  };
}
// 主函数：遍历 stream 并打印每个阶段信息
 => {
   for await (const chunk of query({
       prompt: buildMessages,
       options:{maxTurns:4}
   })) {
       if  {
           console.log;
       } else if  {
           console.log;
           console.log;
       }
   }
});