有什么方法可以将AWS Lambda Function(Python)连接到现有的外部PostgresSQL数据库



我是 AWS 新手,希望将托管在 Amazon EC2 上的外部 postgres 数据库连接到 lambda 函数 (python(,当特定数据插入数据库时会触发该函数。我搜索了很多文章,但他们在 AWS RDS 中使用了 Postgres 实例,而不是外部数据库。
提前谢谢你。

我认为以下 AWS 博客中描述的解决方案应该适用于任何 PostgreSQL,并且不限于 RDS:

  • 使用 Amazon Kinesis Data Streams 和 AWS Lambda 从 Amazon RDS for PostgreSQL 进行流更改

他们甚至明确写道:

数据库可以是 Amazon RDS 或任何PostgreSQL 安装

该解决方案的关键组件是使用 wal2json 插件进行 postgresql:

wal2json 是一个用于逻辑解码的输出插件。这意味着插件可以访问由 INSERT 和 UPDATE 生成的元组。此外,可以根据配置的副本标识访问更新/删除旧行版本。可以使用流式处理协议(逻辑复制槽(或特殊的 SQL API 使用更改。

使用wal2json,对postgresql的更改将被感染到Kinesis数据流,然后被lambda函数使用。

最新更新