如何通过AppSync与Amplify阻止删除关联Task的DynamoDB TaskType？

嘿，我来帮你搞定这个需求！要阻止删除关联了Task的TaskType，咱们可以借助AppSync的Lambda 触发器或者Pipeline Resolver来实现——核心逻辑就是在执行TaskType删除操作前，先检查有没有关联的Task存在，如果有就抛出错误终止删除，具体步骤如下：

1. 创建检查关联任务的Lambda函数 #

首先写一个Lambda函数，用来查询要删除的TaskType是否有对应的关联Task。这里假设你的Task表因为@connection的关系，自动生成了taskTypeId字段（关联TaskType的id），如果没有的话，需要先给Task表创建一个基于taskTypeId的全局二级索引（GSI）。

下面是Node.js版本的Lambda示例代码：

const AWS = require('aws-sdk');
const dynamodb = new AWS.DynamoDB.DocumentClient();

exports.handler = async (event) => {
  // 获取要删除的TaskType的ID
  const taskTypeId = event.arguments.input.id;

  // 查询是否存在关联的Task
  const queryParams = {
    TableName: 'Task', // 注意替换成你实际的DynamoDB Task表名（可能带环境后缀）
    IndexName: 'taskTypeId-index', // 替换成你创建的GSI名称
    KeyConditionExpression: 'taskTypeId = :taskTypeId',
    ExpressionAttributeValues: {
      ':taskTypeId': taskTypeId
    },
    Limit: 1 // 只要找到一个关联任务就足够，无需查询全部
  };

  try {
    const queryResult = await dynamodb.query(queryParams).promise();
    if (queryResult.Items.length > 0) {
      // 存在关联任务，抛出错误阻止删除
      throw new Error('无法删除该TaskType：当前存在关联的Task条目');
    }
    // 无关联任务，返回原始输入，允许后续删除操作
    return event.arguments.input;
  } catch (error) {
    // 将错误抛出给AppSync，终止流程
    throw new Error(error.message);
  }
};

记得给这个Lambda函数配置DynamoDB的Query权限，确保它能访问Task表。

2. 配置AppSync的Delete Resolver #

接下来需要把这个检查逻辑接入到TaskType的删除流程中，推荐用Pipeline Resolver来实现，这样可以保留原来的DynamoDB删除逻辑，只在前面加一个检查步骤：

• 打开AppSync控制台，找到你的API，进入Schema页面，定位到TaskType类型的deleteTaskType字段
• 将原来的Resolver类型从DynamoDB改成Pipeline
• 添加一个新的Function，选择你刚才创建的Lambda函数，设置为前置执行的步骤
• 再添加一个Function，选择原来的DynamoDB删除Resolver（或者重新配置一个DynamoDB Delete操作的Function）
• 保存配置后，AppSync会先执行Lambda检查，如果检查通过，再执行删除操作；如果检查到关联Task，就会抛出错误，删除流程终止

备选方案：直接用Lambda作为Delete Resolver #

如果你不想用Pipeline Resolver，也可以直接把deleteTaskType的Resolver替换成Lambda函数，在函数里先完成关联检查，确认无关联后再调用DynamoDB的Delete API执行删除操作。这种方式更灵活，但需要自己处理删除逻辑，示例代码可以在上面的Lambda基础上添加删除逻辑：

// 检查完成后添加删除逻辑
const deleteParams = {
  TableName: 'TaskType',
  Key: {
    id: taskTypeId
  }
};
await dynamodb.delete(deleteParams).promise();
return { id: taskTypeId, ...event.arguments.input };

注意事项 #

• 如果你的Task和TaskType不是通过taskTypeId关联，而是通过orgID和type字段匹配，那需要调整Lambda里的查询条件，比如查询Task表中orgID等于当前TaskType的orgID且type等于TaskType的type，同时要给Task表创建对应的GSI
• 确保Lambda函数的执行角色有足够的权限访问DynamoDB的Task和TaskType表

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