跳转到内容

TypeScript Strands Agent 连接到关系数据库

connection 生成器将 TypeScript Strands Agent 连接到 关系数据库 项目,使 Prisma 客户端在您的 agent 工厂内可用。

在使用此生成器之前,请确保您拥有:

  1. 一个 ts#strands-agent 项目
  2. 一个 ts#rdb 项目
  1. 安装 Nx Console VSCode Plugin 如果您尚未安装
  2. 在VSCode中打开Nx控制台
  3. 点击 Generate (UI) 在"Common Nx Commands"部分
  4. 搜索 @aws/nx-plugin - connection
  5. 填写必需参数
    • 点击 Generate

    选择您的 Strands Agent 项目作为源,选择您的关系数据库项目作为目标。如果项目包含多个 agent 组件,请指定 sourceComponent 以消除歧义。

    参数 类型 默认值 描述
    sourceProject 必需 string - 源项目
    targetProject 必需 string - 要连接到的目标项目
    sourceComponent string - 要从其连接的源组件(组件名称、相对于源项目根目录的路径或生成器 ID)。使用 '.' 显式选择项目作为源。
    targetComponent string - 要连接到的目标组件(组件名称、相对于目标项目根目录的路径或生成器 ID)。使用 '.' 显式选择项目作为目标。

    生成器修改单个文件:

    • 文件夹packages/my-service/src/my-agent
      • agent.ts getAgent 内获取 Prisma 客户端并可用于工具

    此外,agent 的 <agent-name>-serve-local 目标会更新为依赖于数据库的 serve-local 目标。

    Prisma 客户端直接在 getAgent() 内获取,而不是通过函数参数传递。这与 strands-agent 运行时传播会话上下文的方式一致 —— withSessionId 包装 getAgent 并为每个会话缓存一个 Agent 实例,因此 getPrisma() 每个会话最多调用一次。

    getAgent 被更新为在其主体顶部导入并调用 Prisma getter:

    packages/my-service/src/my-agent/agent.ts
    import { getPrisma as getMyDb } from ':my-scope/my-db';
    export const getAgent = async () => {
    const myDb = await getMyDb();
    return new Agent({ /* use myDb in tools */ });
    };

    使用不同的目标再次运行生成器会将第二个数据库添加到第一个数据库旁边:

    packages/my-service/src/my-agent/agent.ts
    import { getPrisma as getMyDb } from ':my-scope/my-db';
    import { getPrisma as getOtherDb } from ':my-scope/other-db';
    export const getAgent = async () => {
    const myDb = await getMyDb();
    const otherDb = await getOtherDb();
    return new Agent({ /* use both clients in tools */ });
    };

    生成的 agent 构造实现了 IGrantableIConnectable,因此您可以直接在构造上授予对数据库的网络和 IAM 访问权限。

    packages/infra/src/stacks/application-stack.ts
    import { MyDatabase } from ':my-scope/common-constructs';
    const db = new MyDatabase(this, 'Db', { vpc, ... });
    const myAgent = new MyAgent(this, 'MyAgent', { vpc, ... });
    db.allowDefaultPortFrom(myAgent);
    db.grantConnect(myAgent);

    allowDefaultPortFrom 打开安全组规则,以便 agent 运行时可以访问数据库端口。grantConnect 向 agent 的执行角色授予 IAM rds-db:connect 权限。

    Terminal window
    pnpm nx <agent-name>-serve-local <project-name>

    这将启动 agent 和所有连接的数据库。SERVE_LOCAL=true 环境变量使每个 Prisma 客户端连接到其本地 Docker 数据库而不是 Aurora。