AWS Lambda函数访问Amplify Datastore的可行性及参考资料咨询

可行性结论 #

完全支持在Lambda函数中直接操作Amplify Datastore，无需绕路调用原生DynamoDB接口。Amplify Datastore是基于AppSync GraphQL API与DynamoDB实现的封装层，服务端环境可通过Amplify服务端SDK直接调用其操作能力，完全符合你提到的S3 → Lambda触发 → 写入Amplify Datastore的业务链路要求。

核心实现步骤 #

• 第一步：在Lambda的部署包中引入对应语言的Amplify服务端依赖，以Node.js环境为例，安装依赖命令为：
  npm install @aws-amplify/datastore aws-amplify
• 第二步：为Lambda执行角色配置必要权限，添加appsync:GraphQL操作许可，资源范围指定为你Amplify项目关联的AppSync API的ARN即可。
• 第三步：在Lambda代码初始化阶段完成Amplify配置，传入项目的AppSync端点、区域、授权模式等参数，无需配置客户端侧的离线持久化能力。
• 第四步：导入Amplify CLI自动生成的业务模型定义文件，直接调用Datastore提供的CRUD方法即可完成数据写入，示例代码逻辑如下：

  import { Amplify } from 'aws-amplify';
  import { DataStore } from '@aws-amplify/datastore';
  import { FileRecord } from './models'; // 替换为你自己的业务模型名
  
  Amplify.configure({
    api: {
      GraphQL: {
        endpoint: process.env.APPSYNC_ENDPOINT,
        region: process.env.AWS_REGION,
        defaultAuthMode: 'IAM'
      }
    }
  });
  
  export const handler = async (event) => {
    // 从S3触发事件中解析文件相关信息
    const s3FileInfo = event.Records[0].s3;
    // 写入数据到Amplify Datastore
    await DataStore.save(
      new FileRecord({
        fileName: s3FileInfo.object.key,
        bucketName: s3FileInfo.bucket.name,
        uploadTimestamp: new Date().toISOString()
      })
    );
    return { statusCode: 200 };
  };
  

注意事项 #

• 服务端调用Datastore时不要开启本地持久化配置，避免Lambda运行环境产生不必要的存储开销。
• 写入Datastore的数据会自动触发Datastore的同步逻辑，所有在线客户端会自动收到数据更新通知，和客户端侧直接操作Datastore的效果完全一致。

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