Amplify GraphQL订阅返回null问题排查求助

听起来你遇到了Amplify GraphQL订阅返回null但数据库已正常写入的典型问题，结合你的代码和描述，我整理了几个可能的原因和对应的调试方法：

可能的原因 #

1. 订阅过滤条件与实际记录不匹配 #

你在订阅时用了{owner: user.username}作为过滤变量，但如果修改应用后，上传图片的Mutation没有正确设置Photo记录的owner字段（比如拼写错误、改用了其他字段名如userId，或者没有从Auth获取正确的username），就会导致订阅的过滤条件匹配不到新创建的记录，AppSync会返回null。

2. GraphQL订阅权限配置变更 #

如果修改了GraphQL Schema的@auth规则，或者更新了Amplify的权限配置，可能导致当前用户没有权限订阅新创建的Photo记录。比如原来的规则允许owner订阅自己的资源，但修改后权限范围缩小，AppSync会因为权限不足返回null（即使数据库里已经有记录）。

3. 订阅响应的字段缺失或Schema不匹配 #

如果你修改了Photo类型的Schema（比如删除了albumId字段，或者调整了字段名称），但订阅的payload没有同步更新，可能导致data.value.data.onCreatePhoto为null——不过你刷新页面后查询正常，这个可能性相对低，但也需要排查。

4. 订阅初始化的异步时序问题 #

你的setupSubscription是异步函数，useEffect的清理函数可能在订阅还未初始化完成时就执行，导致订阅失效；或者props.id在订阅初始化时还未正确赋值，不过这种情况一般会导致后续逻辑不执行，而不是返回null。

调试方法 #

1. 在AppSync控制台直接测试订阅 #

登录AWS控制台打开你的AppSync API，进入Queries页面：

• 手动编写订阅查询：

  subscription OnCreatePhoto($owner: String!) {
    onCreatePhoto(owner: $owner) {
      id
      albumId
      owner
      # 其他你需要的字段
    }
  }
  

• 传入变量{"owner": "你的当前用户username"}，然后触发上传图片的操作，观察返回的响应。如果这里也返回null，说明问题在后端（Schema、权限或Mutation）；如果返回正常，那问题出在前端代码。

2. 检查上传Mutation的字段赋值 #

查看你上传图片时调用的创建Photo的Mutation代码，确认owner字段确实被设置为当前用户的username：

// 示例代码，确保owner字段正确赋值
const user = await Auth.currentAuthenticatedUser();
await API.graphql(graphqlOperation(createPhoto, {
  input: {
    albumId: props.id,
    owner: user.username, // 这里要和订阅的过滤字段一致
    // 其他字段
  }
}));

3. 验证GraphQL Schema的权限规则 #

检查你的Schema中Photo类型的@auth配置，确保订阅权限和查询权限一致：

type Photo @model @auth(rules: [
  { allow: owner, ownerField: "owner", operations: [create, read, update, delete, subscribe] }
]) {
  id: ID!
  albumId: ID!
  owner: String!
  # 其他字段
}

注意operations里要包含subscribe，否则用户无法订阅自己的记录。

4. 打印完整的订阅响应 #

修改你的console.log，打印整个响应对象，看看是否有错误信息：

next: (data) => {
  console.log('full subscription response:', data);
  // 后续代码
}

有时候AppSync会在data.value.errors里返回权限错误或字段缺失的提示，而只在data部分返回null。

5. 完善订阅的清理逻辑 #

由于setupSubscription是异步函数，可能存在清理函数执行时subscription还未赋值的情况，修改清理函数避免报错：

return () => {
  if (subscription) {
    subscription.unsubscribe();
  }
};

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