AWS Amplify Data Gen2调用team.members()返回陈旧数据问题

核心原因 #

Amplify Data客户端默认启用本地缓存以提升查询性能。当通过Lambda直接操作DynamoDB表更新数据时，该变更不会触发Amplify客户端缓存的同步机制，导致后续调用team.members()时读取的是缓存中的陈旧数据。而observeQuery通过AppSync实时订阅直接从后端拉取最新数据，因此能获取正确结果。

解决方案 #

方案1：使用Amplify Data API执行更新（推荐） #

放弃直接操作DynamoDB，改用Amplify生成的模型API更新Team和Member的owners数组，Amplify会自动处理缓存同步：

// 更新Team的owners数组
const updatedTeam = await client.models.Team.update({
  id: team.id,
  owners: [...team.owners, memberId]
});

// 更新Member的owners数组
const updatedMember = await client.models.Member.update({
  id: entity.id,
  owners: [...owners]
});

方案2：查询时强制跳过缓存 #

若需保留Lambda直接更新逻辑，可在查询时指定忽略缓存，直接从网络获取最新数据：

const { data: teamMembers } = await team.members({
  cachePolicy: 'network-only' // 强制走网络请求，不读取本地缓存
});

方案3：手动清除对应模型缓存 #

Lambda更新完成后，前端手动清除Member模型的缓存，确保后续查询获取最新数据：

// 清除Member模型的所有缓存
await client.models.Member.clearCache();

// 或精准清除特定Team关联的Member缓存
await client.models.Member.clearCache({
  filter: { teamId: { eq: team.id } }
});

// 再执行查询
const { data: teamMembers } = await team.members();

方案4：Lambda中调用AppSync Mutation（进阶） #

让Lambda通过AppSync执行Mutation而非直接写DynamoDB，AppSync会自动触发缓存更新和实时订阅通知：

import { AppSyncClient, gql } from '@aws-sdk/client-appsync';

const appSyncClient = new AppSyncClient({
  region: process.env.AWS_REGION,
  credentials: { /* 配置Lambda的IAM权限 */ }
});

// 更新Team的Mutation
const updateTeamMutation = gql`
  mutation UpdateTeam($input: UpdateTeamInput!) {
    updateTeam(input: $input) {
      id
      owners
    }
  }
`;

await appSyncClient.mutate({
  mutation: updateTeamMutation,
  variables: {
    input: {
      id: team.id,
      owners: [...team.owners, memberId]
    }
  }
});

额外检查点 #

确认Lambda中owners数组的存储格式与Amplify一致：Amplify将字符串数组存为DynamoDB的L类型（列表），每个元素为S类型（字符串），你的Lambda代码已正确处理该格式，无需调整。

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