如何解决使用 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 是一个想法。在当前事务之外处理异常。当什么都不写时,新事务更轻,所以也许这就是要走的路?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。