如何在AWS Amplify GraphQL中删除Image时批量删除关联的JobListingImage？

环境信息 #

• 类别：API.graphql mutation
• Amplify版本：8.0.1
• 服务：AppSync

问题背景 #

在Amplify GraphQL Schema中，JobListing和Image均标记@model注解，二者为**多对多（ManyToMany）**关系。删除Image记录时，需同步删除所有关联的JobListingImage中间表记录。直接遍历删除的方式在数据量较大（如10万条）时效率极低，无法满足需求。

此前尝试的代码无法实现批量删除，代码片段如下：

const handleDelete = async (id, name) => {
  try {
    await API.graphql({
      query: deleteJobListingImages,
      variables: {
        input: {
          imageID: id,
          imageemployerID: Auth.user.attributes["custom:id"],
        },
      },
      authMode: "AMAZON_COGNITO_USER_POOLS",
    });
    await Storage.remove(name, {
      level: "protected",
    });
    await API.graphql({
      query: deleteImage,
      variables: {
        input: {
          id: id,
          employerID: Auth.user.attributes["custom:id"],
        },
      },
      authMode: "AMAZON_COGNITO_USER_POOLS",
    });  
  } catch (err) {
    console.log(err);
  }
}; 

解决方案 #

方法1：自定义批量删除解析器 #

Amplify默认不支持批量操作，需自定义AppSync解析器实现批量删除：

1. 在GraphQL Schema中新增自定义mutation：

type Mutation {
  deleteJobListingImagesByImageId(imageId: ID!, employerId: ID!): Boolean
}

2. 编写VTL解析器模板，调用DynamoDB的BatchWriteItem接口，根据imageId和employerId批量删除关联的JobListingImage记录。注意BatchWriteItem单次最多处理25条数据，需在模板中实现分页循环逻辑，确保所有关联记录被清理。

方法2：DynamoDB流+Lambda自动级联删除 #

通过DynamoDB流监听Image表的删除事件，自动触发Lambda清理关联记录：

1. 开启Image表的DynamoDB流，设置捕获删除事件。
2. 创建Lambda函数，当收到Image删除事件时，查询所有匹配imageId和employerId的JobListingImage记录，调用DynamoDB批量删除接口完成清理。
3. 为Lambda配置IAM权限，允许其访问DynamoDB的查询与批量删除操作。

方法3：前端分页批量删除（小数据量场景） #

若数据规模不大，可优化前端代码实现分页删除：

1. 分页查询所有关联的JobListingImage记录ID。
2. 分批次调用删除mutation（每批次最多25条），直至所有记录删除完毕。

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