第 53 章 PostgreSQL Sink

将数据发送到 PostgreSQL 数据库。

此 Kamelet 需要一个 JSON 作为正文。JSON 字段和参数之间的映射通过键实现，因此如果您有以下查询：

'INSERT INTO accounts (username,city) VALUES (:#username,:#city)'

Kamelet 需要以类似的输入的形式接收：

'{ "username":"oscerd", "city":"Rome"}'

53.1. 配置选项

下表总结了 postgresql-sink Kamelet 的配置选项：

属性	名称	描述	类型	默认	Example
databaseName *	数据库名	我们指向的数据库名称	字符串
密码 *	密码	用于访问安全 PostgreSQL 数据库的密码	字符串
查询 *	查询	要针对 PostgreSQL 数据库执行的查询	字符串		`"INSERT INTO accounts (username,city) VALUES (:#username,:#city)"`
serverName *	服务器名称	数据源的服务器名称	字符串		`"localhost"`
用户名 *	用户名	用于访问安全 PostgreSQL 数据库的用户名	字符串
serverPort	服务器端口	数据源的服务器端口	字符串	`5432`

注意

带星号(*)标记的字段是必需的。