如何实现Aurora PostgreSQL插入X表后触发Lambda调用Step Function？

1. 配置Aurora PostgreSQL的插入触发Lambda #

在Aurora PostgreSQL中创建触发器，当X表插入数据时主动调用第一个Lambda函数：

• 先启用aws_lambda扩展，允许PostgreSQL调用Lambda：

  CREATE EXTENSION IF NOT EXISTS aws_lambda;
  

• 创建PL/pgSQL触发器函数，将插入数据转为JSON并触发Lambda：

  CREATE OR REPLACE FUNCTION trigger_x_table_insert()
  RETURNS TRIGGER AS $$
  DECLARE
      lambda_payload JSON;
  BEGIN
      -- 替换为X表的实际字段
      lambda_payload := json_build_object(
          'id', NEW.id,
          'business_column1', NEW.column1,
          'business_column2', NEW.column2
      );
      -- 替换为你的第一个Lambda的ARN
      PERFORM aws_lambda.invoke(
          'arn:aws:lambda:us-east-1:123456789012:function:TriggerStepFunctionLambda',
          lambda_payload
      );
      RETURN NEW;
  END;
  $$ LANGUAGE plpgsql;
  

• 为X表绑定INSERT触发器：

  CREATE TRIGGER x_table_insert_trigger
  AFTER INSERT ON X
  FOR EACH ROW
  EXECUTE FUNCTION trigger_x_table_insert();
  

• 确保Aurora关联的IAM角色拥有lambda:InvokeFunction权限，允许调用目标Lambda。

2. 编写第一个Lambda函数（触发Step Function） #

用C#实现Lambda逻辑，接收Aurora传来的插入数据，调用Step Function的启动接口：

• 安装NuGet依赖：AWSStepFunctions
• 代码示例：

  using Amazon.StepFunctions;
  using Amazon.StepFunctions.Model;
  using System.Text.Json;
  
  public class TriggerStepFunctionHandler
  {
      private readonly AmazonStepFunctionsClient _sfClient;
      // 替换为你的Step Function ARN
      private const string _stateMachineArn = "arn:aws:states:us-east-1:123456789012:stateMachine:AuroraTriggeredWorkflow";
  
      public TriggerStepFunctionHandler()
      {
          _sfClient = new AmazonStepFunctionsClient();
      }
  
      public async Task FunctionHandler(JsonElement input, ILambdaContext context)
      {
          var startRequest = new StartExecutionRequest
          {
              StateMachineArn = _stateMachineArn,
              Input = JsonSerializer.Serialize(input)
          };
  
          await _sfClient.StartExecutionAsync(startRequest);
      }
  }
  

• 给该Lambda的IAM角色添加states:StartExecution权限，允许启动目标Step Function。

3. 设计Step Function状态机 #

定义状态机的JSON配置，核心是调用执行EF查询的Lambda：

{
  "Comment": "Aurora插入触发的EF查询工作流",
  "StartAt": "ExecuteEFQuery",
  "States": {
    "ExecuteEFQuery": {
      "Type": "Task",
      // 替换为执行EF查询的Lambda ARN
      "Resource": "arn:aws:lambda:us-east-1:123456789012:function:EFQueryLambda",
      "End": true
    }
  }
}

这个状态机仅包含一个Task步骤，直接调用目标Lambda并传递从第一个Lambda传来的插入数据。

4. 编写第二个Lambda函数（用EF Core查询Aurora） #

用C#实现Lambda逻辑，通过EF Core连接Aurora执行查询：

• 安装NuGet依赖：Npgsql.EntityFrameworkCore.PostgreSQL
• 定义DbContext和实体类：

  using Microsoft.EntityFrameworkCore;
  
  public class AppDbContext : DbContext
  {
      public DbSet<BusinessEntity> BusinessEntities { get; set; } // 替换为你的查询实体
  
      protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
      {
          // 从Lambda环境变量读取连接字符串，避免硬编码
          var connStr = Environment.GetEnvironmentVariable("AuroraPostgreSQLConnStr");
          optionsBuilder.UseNpgsql(connStr);
      }
  }
  
  public class BusinessEntity
  {
      public int Id { get; set; }
      // 匹配数据库表的其他字段
  }
  
  // 对应X表插入的字段结构
  public class InsertedXData
  {
      public int Id { get; set; }
      public string BusinessColumn1 { get; set; }
      public string BusinessColumn2 { get; set; }
  }
  

• Lambda处理逻辑：

  using System.Text.Json;
  
  public class EFQueryHandler
  {
      public async Task<object> FunctionHandler(JsonElement input, ILambdaContext context)
      {
          // 解析Aurora传来的插入数据
          var insertedData = JsonSerializer.Deserialize<InsertedXData>(input);
          
          using var dbContext = new AppDbContext();
          // 执行业务查询，示例：关联查询或数据校验
          var queryResult = await dbContext.BusinessEntities
              .Where(e => e.Id == insertedData.Id)
              .ToListAsync();
  
          // 返回查询结果，可根据业务需求调整结构
          return new { InsertedRecord = insertedData, QueryResult = queryResult };
      }
  }
  

• 配置Lambda环境变量AuroraPostgreSQLConnStr，值为Aurora的连接字符串（格式：Host=your-aurora-endpoint;Database=your-db;Username=your-user;Password=your-password;Port=5432）
• 若Aurora在VPC内，需将Lambda部署到同一VPC的子网，并配置安全组允许Lambda访问Aurora的5432端口；同时给Lambda的IAM角色添加访问RDS的权限。

5. ASP.NET项目辅助配置（可选） #

如果需要在ASP.NET项目中测试或管理流程：

• 可通过AWS SDK for .NET调用Lambda/Step Function的API，模拟触发流程
• 生产环境建议用CloudFormation或Terraform做基础设施即代码，统一管理所有资源

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