AWS Amplify Gen2：Schema层触发Lambda实现模型更新求和

根据你的需求，这里提供几种可行的触发Lambda执行求和操作的方案：

1. 在应用层直接调用Lambda #

既然你已经有应用层的updateChild方法，最直接的方式就是在更新子模型后，主动调用求和Lambda函数。这种方式可控性强，无需修改Schema层配置：

import { LambdaClient, InvokeCommand } from "@aws-sdk/client-lambda";

// 初始化Lambda客户端
const lambdaClient = new LambdaClient({ region: "你的AWS区域" });

async updateChild(child: childUpdateType): SingularReturnValue<childUpdateType> {
  try {
    const updatedChild = await client.models.child.update(child);
    
    // 触发求和Lambda，传递父ID用于计算该父模型下所有子项的总和
    const invokeParams = {
      FunctionName: "你的求和Lambda函数名称",
      Payload: JSON.stringify({ parentId: updatedChild.parentId })
    };
    await lambdaClient.send(new InvokeCommand(invokeParams));
    
    return updatedChild;
  } catch (error) {
    console.error("Error updating child", child.id);
    throw error;
  }
}

2. 配置数据库触发器 #

如果你的数据库支持（比如AWS Aurora、RDS），可以直接在数据库层面创建触发器，当child表发生更新操作时自动触发Lambda。这种方式无需修改应用代码，所有更新操作（不管来自哪里）都会触发求和逻辑：

以AWS Aurora为例，创建触发器的SQL示例：

CREATE TRIGGER trigger_child_after_update
AFTER UPDATE ON child
FOR EACH ROW
CALL mysql.lambda_async('你的求和Lambda函数名称', JSON_OBJECT('parentId', NEW.parentId));

3. 利用框架生命周期钩子（如Amplify） #

如果使用的是Amplify这类后端框架，部分版本支持在模型上绑定生命周期钩子（比如afterUpdate），直接关联到Lambda函数。修改你的Schema定义如下：

child: a
  .model({
    id: a.id().required(),
    name: a.string().required(),
    parentId: a.id().required(),
    parent: a.belongsTo("parent", "parentId"),
  })
  .authorization((allow) => [allow.publicApiKey()])
  .hooks({
    // 绑定afterUpdate事件到指定Lambda函数
    afterUpdate: [a.function("sumChildValues")]
  }),

需要确保你已经在项目中配置了名为sumChildValues的Lambda函数，该函数会接收模型更新的事件数据，从中提取parentId并执行求和操作。

方案对比 #

• 应用层调用：实现简单，逻辑清晰，但如果有多个更新child的入口，需要确保每个入口都添加Lambda调用，容易遗漏。
• 数据库触发器：全局生效，无需修改应用代码，但依赖数据库特性，调试和排查问题相对复杂。
• 框架生命周期钩子：符合框架设计规范，无需重复编写调用逻辑，但需要确认所用框架支持该特性。

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