AWS Amplify DataStore新增项同步延迟：如何让Lambda立即访问？

问题根源 #

Amplify DataStore是离线优先的架构，调用DataStore.save()时会先写入本地缓存，再异步同步到云端DynamoDB，这个同步过程通常需要几秒到几分钟，导致第三方立即调用Lambda查询时，云端还没有数据。

可行解决方案 #

• 直接使用Amplify API写入云端
  如果业务不需要离线功能，放弃DataStore的本地缓存特性，直接用Amplify GraphQL/REST API将数据写入云端DynamoDB。写入操作完成后，数据会立即存在于云端，Lambda查询不会有延迟。
  示例代码（Vue中使用GraphQL API）：

  import { API, graphqlOperation } from 'aws-amplify';
  import { createItem } from './graphql/mutations';
  
  // 直接写入云端，而非DataStore
  const saveItemToCloud = async (newItem) => {
    await API.graphql(graphqlOperation(createItem, { input: newItem }));
    // 写入完成后即可通知第三方调用Lambda
  };
  

• 监听DataStore云端同步完成事件
  若必须保留离线功能，可监听DataStore的同步状态，确认数据同步到云端后，再触发第三方的Lambda调用。
  示例代码：

  import { DataStore } from 'aws-amplify';
  import { Item } from './models';
  
  const saveItemAndWaitSync = async (newItem) => {
    const savedItem = await DataStore.save(newItem);
    
    // 监听该Item的同步状态
    const subscription = DataStore.observe(Item, savedItem.id).subscribe((msg) => {
      // 确认同步完成（根据Amplify版本，状态字段可能为synced/READY等）
      if (msg.opType === 'UPDATE' && msg.element._version !== undefined) {
        // 同步完成，触发第三方调用Lambda
        notifyThirdParty();
        subscription.unsubscribe(); // 取消监听
      }
    });
  };
  

  注意：不同Amplify版本的同步状态标识可能有差异，需参考对应版本的文档调整判断逻辑。

• 设置Lambda查询的强一致性
  DynamoDB默认查询是最终一致性，写入后副本同步需要时间。可以在Lambda的查询参数中开启ConsistentRead: true，强制读取主节点的数据，保证强一致性。
  示例代码（Lambda中）：

  const AWS = require('aws-sdk');
  const docClient = new AWS.DynamoDB.DocumentClient();
  
  exports.handler = async (event) => {
    const params = {
      TableName: 'YourDynamoDBTable',
      KeyConditionExpression: 'id = :itemId',
      ExpressionAttributeValues: { ':itemId': event.itemId },
      ConsistentRead: true // 开启强一致性查询
    };
    
    const result = await docClient.query(params).promise();
    return result.Items;
  };
  

  注意：强一致性查询会消耗双倍的读取容量单位（RCU），需评估成本影响。

• 改用DynamoDB Streams触发Lambda
  调整业务流程，不让第三方主动调用Lambda，而是通过DynamoDB Streams实现数据写入后自动触发Lambda。当Item成功写入DynamoDB时，流会推送事件到Lambda，确保Lambda处理时数据已存在。
  操作步骤：

  1. 在DynamoDB控制台开启表的流功能（选择"新图像"或"新旧图像"）；
  2. 在Lambda控制台配置该DynamoDB流作为触发器；
  3. Lambda中通过event.Records获取新增的Item数据，进行后续处理。

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