AWS Amplify升级后AppSync订阅报DuplicatedOperationError求助

可能的原因及修复方案 #

1. 检查订阅操作ID重复问题 #

• 确认客户端代码中是否重复使用了同一个操作ID发起订阅请求。Amplify升级后可能对操作ID的唯一性校验更严格，若多个订阅实例共用同一ID，会触发该错误。
• 修复：确保每个订阅请求生成唯一的操作ID，可使用UUID或时间戳拼接生成，避免硬编码固定ID。

2. 排查订阅客户端实例重复创建 #

• 检查前端代码中是否存在重复初始化订阅客户端或多次调用同一订阅函数的情况。比如在组件挂载时重复订阅，未在卸载时取消订阅，导致同一用户建立多个相同订阅连接。
• 修复：
  • 使用组件生命周期（如React的useEffect）管理订阅，在卸载时调用unsubscribe()方法清理订阅。
  • 全局维护订阅实例缓存，避免重复创建相同条件的订阅。

3. 验证GraphQL订阅定义的正确性 #

• 虽然之前正常运行，但升级Amplify后可能对订阅的@aws_subscribe指令解析逻辑有变化。检查自定义订阅的参数是否正确关联到突变的字段：
  • 确保userID参数在对应的createNotification/updateNotification突变中存在，且订阅的过滤逻辑正确映射。
  • 重新生成Amplify GraphQL客户端代码：执行amplify codegen，确保生成的订阅函数与最新的schema定义同步。

4. 检查Amplify版本兼容性 #

• 部分Amplify版本更新可能存在客户端与AppSync服务端的兼容性问题。尝试回退到之前能正常运行的Amplify版本，或升级到最新稳定版：
  • 回退版本：npm install aws-amplify@<旧版本号>
  • 升级到最新版：npm install aws-amplify@latest

5. 排查AppSync服务端配置 #

• 登录AWS控制台，检查AppSync API的订阅配置是否正常：
  • 确认数据源、解析器无异常，订阅的触发器（mutations）是否正确关联。
  • 查看AppSync的CloudWatch日志，获取更详细的错误上下文，定位具体是哪个订阅操作触发了重复ID。

示例代码调整（React场景） #

如果使用React，确保订阅在组件挂载时只初始化一次，并在卸载时清理：

import { API, graphqlOperation } from 'aws-amplify';
import { onCreateNotificationForUser, onUpdateNotificationForUser } from './graphql/subscriptions';

function NotificationComponent({ userId }) {
  useEffect(() => {
    // 生成唯一操作ID
    const createOpId = `create-notif-${Date.now()}`;
    const updateOpId = `update-notif-${Date.now()}`;

    // 订阅创建通知
    const createSubscription = API.graphql({
      query: onCreateNotificationForUser,
      variables: { userID: userId },
      operationId: createOpId // 指定唯一ID
    }).subscribe({
      next: (data) => console.log('Create notification:', data),
      error: (err) => console.error('Create subscribe error:', err)
    });

    // 订阅更新通知
    const updateSubscription = API.graphql({
      query: onUpdateNotificationForUser,
      variables: { userID: userId },
      operationId: updateOpId // 指定唯一ID
    }).subscribe({
      next: (data) => console.log('Update notification:', data),
      error: (err) => console.error('Update subscribe error:', err)
    });

    // 组件卸载时取消订阅
    return () => {
      createSubscription.unsubscribe();
      updateSubscription.unsubscribe();
    };
  }, [userId]);

  return <div>Notification Component</div>;
}

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