如何编写AppSync解析器实现与现有GraphQL API的1:1请求映射？

我完全理解你的痛点——AppSync默认示例只讲了参数转发，没提如何精准传递前端的查询结构（包括字段子集和嵌套对象），而且调试起来确实有点麻烦。不过其实AppSync提供了工具来实现你要的1:1精准转发，下面一步步讲怎么做：

核心思路：动态提取前端查询的选择集 #

关键是利用AppSync的$util.transform.toGraphQLSelectionSet()工具，它能把当前解析器上下文里的前端请求选择集（就是你要的{ id, name, children { id, name } }这种结构）转换成标准的GraphQL选择字符串，这样你就能把这个选择集直接嵌入到转发给微服务的查询里，让微服务只返回前端需要的字段，而不是全量数据。

具体实现步骤 #

1. 为每个微服务创建HTTP数据源 #

在AppSync控制台里，给每个微服务的GraphQL端点创建一个独立的HTTP数据源：

• 选择HTTP类型，填入微服务的GraphQL端点URL（比如https://your-microservice-1.com/graphql）
• 配置认证方式（如果微服务需要API密钥、JWT或其他认证，要在这里设置对应的头部或参数）

2. 构建AppSync聚合Schema #

你的聚合Schema要和各个微服务的Schema对齐，比如：

type AType {
  id: Int!
  name: String!
  children: [BType]
  # 加上其他微服务AType里的标量字段
}

type BType {
  id: Int!
  name: String!
  # 加上其他微服务BType里的标量字段
}

type Query {
  a(id: ID): AType # 对应微服务1的查询
  as: [AType]       # 对应微服务1的列表查询
  # 加上其他微服务的Query字段，比如b(id: ID): BType等
}

确保字段名、类型和各个微服务完全一致，避免转发查询时出错。

3. 编写解析器模板（核心部分） #

针对每个Query字段和嵌套字段，编写解析器模板，动态生成转发的查询。

示例1：单个AType查询的解析器（对应微服务1的a(id: ID)）

这个模板会提取前端请求的所有字段（包括嵌套的children），生成精准的查询转发给微服务：

# 提取前端请求的选择集，包括嵌套字段
#set($selectionSet = $util.transform.toGraphQLSelectionSet($context.selectionSet))

# 动态构造要转发的GraphQL查询
#set($query = "query GetA($id: ID!) { a(id: $id) $selectionSet }")

{
  "version": "2018-05-29",
  "method": "POST",
  "resourcePath": "/graphql",
  "params": {
    "body": {
      "query": "$util.escapeJavaScript($query)",
      "variables": {
        "id": "$context.args.id"
      }
    },
    "headers": {
      "Content-Type": "application/json",
      # 如果微服务需要认证头，比如JWT，这里转发前端传来的头
      "x-access-token": "$context.request.headers.x-access-token"
    }
  }
}

当前端请求{ a(id: 1) { id, name, children { id, name } } }时，生成的转发查询会是：

query GetA($id: ID!) { a(id: $id) { id, name, children { id, name } } }

微服务只会返回这些字段，完美匹配需求。

示例2：AType列表查询的解析器（对应微服务1的as）

如果是列表查询，逻辑类似，不需要变量的话可以简化：

#set($selectionSet = $util.transform.toGraphQLSelectionSet($context.selectionSet))
#set($query = "query ListAs { as $selectionSet }")

{
  "version": "2018-05-29",
  "method": "POST",
  "resourcePath": "/graphql",
  "params": {
    "body": {
      "query": "$util.escapeJavaScript($query)"
    },
    "headers": {
      "Content-Type": "application/json"
    }
  }
}

嵌套字段的处理

如果children字段来自同一个微服务，上面的模板已经自动包含了嵌套的选择集，不需要额外处理。如果children来自另一个微服务，那你需要给AType.children字段单独写解析器，转发到对应的数据源，逻辑和上面一样——提取children的选择集，构造查询发送到对应的微服务。

4. 调试技巧：查看$context对象 #

你说看不到$ctx对象？其实可以在解析器里添加日志输出，把$context的内容打印到CloudWatch：

# 把context对象转成JSON打印到日志
$utils.log($util.toJson($context))

# 后面是正常的解析器逻辑
#set($selectionSet = $util.transform.toGraphQLSelectionSet($context.selectionSet))
...

然后去CloudWatch的Logs > Log Groups里找到AppSync的日志组（名字类似AWSAppSync-API-xxxxxx），就能看到完整的$context结构，包括selectionSet、args、request等所有信息，方便你调整模板。

注意事项 #

• 字段一致性：确保AppSync聚合Schema和微服务Schema的字段名、类型完全一致，否则转发的查询会报错。
• 认证转发：如果微服务需要认证，一定要在解析器的headers里正确转发前端的认证信息（比如JWT令牌、API密钥）。
• 变量安全：用variables传递参数，不要直接硬编码到查询字符串里，避免GraphQL注入风险。

这样配置后，前端只需要调用AppSync的单一端点，发送的查询会被精准转发到对应的微服务，而且只获取需要的字段，完全符合你的需求。

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