AWS AppSync是否支持循环引用及Lambda解析器绑定函数返回异常排查

首先明确：AWS AppSync完全支持存在循环引用的GraphQL Schema #

你给出的Schema结构是合法的，可以直接在AppSync中正常部署，不需要调整Schema本身。

问题出现的原因 #

• 你参考的是普通Node.js GraphQL服务（如Apollo Server）的实现逻辑，这类服务会自动执行返回对象上绑定的字段解析函数，但AppSync的Lambda解析器不支持该逻辑：Lambda返回的所有内容都会被直接序列化为JSON，函数类型的字段会被自动丢弃，这就是为什么日志中能看到绑定的getUser函数，但实际返回给AppSync的响应中没有user字段。
• 你当前的解析器架构不符合AppSync的设计规范：AppSync采用字段级解析器的设计，每个字段的解析逻辑需要单独配置，而不是在根解析器的返回对象上绑定函数实现嵌套字段解析。

解决方案 #

步骤1：调整基础解析逻辑 #

首先修改你当前的Query.allPosts解析器，只需要返回Post的基础字段，同时额外返回关联的用户ID（你代码中用的是item.PK作为用户ID，确保该值被正确放到返回的Post对象中，不需要在Schema中声明userId字段，该字段只会在解析器上下文中传递）：

// 简化后的allPosts解析器逻辑
export const handler = async (event: Event) => {
  if (event.info.fieldName === "allPosts") {
    const data = await client
      .query({
        TableName: process.env.TABLE_NAME,
        KeyConditionExpression: "#t = :sk",
        IndexName: "GSI",
        ProjectionExpression: "#d, PK",
        ExpressionAttributeNames: {
          "#t": "type",
          "#d": "data",
        },
        ExpressionAttributeValues: {
          ":sk": "post",
        },
      })
      .promise();
    return data.Items?.map((item) => ({
      ...item.data,
      userId: item.PK, // 额外返回用户ID，供后续Post.user解析器使用
    }));
  }
  return null;
};

步骤2：新增字段级解析器 #

在AppSync控制台为两个嵌套字段分别配置独立的Lambda解析器：

1. Post.user字段解析器：
   逻辑：从父对象（即上一步返回的Post对象）中获取userId，查询DynamoDB返回对应用户的基础信息，同时额外返回用户ID供后续User.posts解析器使用：

   export const handler = async (event) => {
     // event.source就是父级Post对象
     const userId = event.source.userId;
     const res = await client.query({
       TableName: process.env.TABLE_NAME,
       KeyConditionExpression: "PK = :pk AND SK = :sk",
       ExpressionAttributeValues: {
         ":pk": userId,
         ":sk": "profile",
       },
     }).promise();
     if (!res.Items?.length) return null;
     return {
       ...res.Items[0].data,
       userId: userId, // 传递用户ID给下一级解析器
     };
   };
   

2. User.posts字段解析器：
   逻辑：从父对象（User对象）中获取userId，查询DynamoDB返回该用户发布的所有帖子，注意修正你原有getPost函数中的查询条件错误，原条件查的是用户资料不是帖子：

   export const handler = async (event) => {
     const userId = event.source.userId;
     const res = await client.query({
       TableName: process.env.TABLE_NAME,
       KeyConditionExpression: "PK = :pk AND begins_with(SK, :postPrefix)",
       ExpressionAttributeValues: {
         ":pk": userId,
         ":postPrefix": "post#", // 按照你实际的SK前缀调整
       },
     }).promise();
     return res.Items?.map(item => ({
       ...item.data,
       userId: userId,
     })) || [];
   };
   

步骤3：配置查询深度限制 #

为了避免恶意的无限嵌套查询，你可以在AppSync控制台的「设置」中开启查询深度限制，设置合理的最大嵌套层级即可。

内容的提问来源于stack exchange，提问作者plutolaser