AWS Aurora Postgres 和 aws_lambda.invoke 的交易发件箱模式

Question

我正在从事一个由几个微服务组成的项目。我计划在插入触发器后通过在 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

的记录

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

Answer 1

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

AWS Aurora Postgres 和 aws_lambda.invoke 的交易发件箱模式

Transaction Outbox Pattern with AWS Aurora Postgres and aws_lambda.invoke

postgresql

microservices

amazon-aurora

outbox-pattern