使用 AWS Aurora Postgres 和 aws_lambda.invoke 的事务发件箱模式

问题描述

我正在开发一个由几个微服务组成的项目。我打算通过在插入触发器后调用 Postgres 中的 lambda 函数来使用事务发件箱模式。

我在想这样的事情

CREATE OR REPLACE FUNCTION tx_msg_func()    RETURNS trigger AS
$$
DECLARE newRecord JSON;
BEGIN
    newRecord :=  row_to_json(NEW.*);

    PERFORM * FROM aws_lambda.invoke(
        aws_commons.create_lambda_function_arn('my_lambda_function'),newRecord,'Event'
    );

    RETURN NEW;
END;

$$
LANGUAGE 'plpgsql';

CREATE TRIGGER tx_msg_insert AFTER INSERT ON tx_outBox_table
FOR EACH ROW EXECUTE PROCEDURE tx_msg_func();

这里，lambda 函数将接收新记录作为 JSON 并发送 SQS 消息。发送消息成功后，会从tx_outBox_table

中删除记录

我想知道这里是否有我遗漏的缺点。您认为这是一个生产就绪的解决方案吗？有什么我应该注意的吗？

解决方法

那么，交易呢？它应该尽可能短。在事务内部执行插入后，因此... TCP 调用进入事务内部。可以用它做什么？ Here 是一个想法。在当前事务之外处理异常。当什么都不写时，新事务更轻，所以也许这就是要走的路？