如何将 Aurora Postgresql 与 AWS SQS 集成

Question

我需要在 Aurora PostgresSQL 中创建一个触发器，它应该将新插入的行数据推送到 AWS SQS 上。

如何实现？

Answer 1

您可以 使用 aws_lambda

 扩展从 Aurora PostgreSQL 数据库集群 - Amazon Aurora

调用 AWS Lambda 函数。

这可以由

INSERT

上的标准 Postgres 触发器触发。

您需要编写一个 AWS Lambda 函数，然后将消息发送到 Amazon SQS。

所以，总流量为：

SQL INSERT -> Postgres Trigger -> aws_lambda extension -> AWS Lambda function -> Send message to SQS queue