AWS Appsync GraphQL订阅事件中的空数据

Question

我有一个使用AWS AppSync服务提供的GraphQL API的应用程序。它使用GraphQL订阅来接近实时发送不同客户端之间的消息。有一个突变pushItems配置有解析器，该解析器具有“无”数据源，并将请求数据未修改的请求数据转发至subscription OnIteMchange。

该应用程序已经有几年没有使用了，现在当我尝试触发订阅事件时，我会在订阅客户端上遇到错误。以前这无问题。

{
  "data": {
    "onItemChange": null
  },
  "errors": [
    {
      "message": "Cannot return null for non-nullable type: 'ID' within parent 'Item' (/onItemChange/id)",
      "path": [
        "onItemChange",
        "id"
      ]
    }
  ]
}

错误消息建议item对象中的属性id是无效的，但是当我从AWS Appsync Web控制台发送带有硬编码字符串的突变时ID，即使突变响应包含应将应该转发给订阅客户端的正确数据，我仍然会遇到相同的问题。

我在AWS AppSync中创建了最小的配置来重现该问题，如下所述。 AppSync服务是否有可能改变了过去几年处理订阅数据的方式？

GraphQL架构

schema {
  query: Query
  mutation: Mutation
  subscription: Subscription
}

type Query {
  getItem(id: ID!): Item
}

type Mutation {
  pushItems(
    items: [ItemInput]
  ): [Item]}

type Subscription {
  onItemChange: Item
  @aws_subscribe(
    mutations: [
    "pushItems"
    ]
  )
}

type Item {
  id: ID!
}

input ItemInput {
  id: ID!
}

解析器映射用于突变pushItems

请求：

{
  "version" : "2017-02-28",
  "payload": $util.toJson($context.arguments.items)
}

响应：

$util.toJson($context.result)

示例查询

以下查询可用于在AWS Appsync Web控制台中重现该问题。首先，订阅onIteMchange：

subscription MySubscription {
  onItemChange {
    id
  }
}

然后（在其他浏览器选项卡中）将一些数据发送到pushitems：

mutation MyMutation {
  pushItems(items: [{id: "foo"}]) {
    id
  }
}

Answer 1

您正在返回突变中的一组项目，因此您应该将订阅返回类型更新为[项目]

type Subscription {
    onItemChange: [Item]  <--- HERE
        @aws_subscribe(mutations: ["pushItems"])
}