我正在开发一个由几个微服务组成的项目。我计划在插入触发器后通过在 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
我想知道这里是否有我遗漏的缺点。你认为这是一个生产就绪的解决方案吗?有什么我应该注意的吗?