第 43 章 PostgreSQL Sink

将数据发送到 PostgreSQL 数据库。

这个 Kamelet 预期 JSON 作为正文。JSON 字段和参数之间的映射由键进行,因此如果您有以下查询:

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

Kamelet 需要作为输入内容接收,如下所示:

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

43.1. 配置选项

下表总结了 postgresql-sink Kamelet 可用的配置选项:

属性名称描述类型默认示例

databaseName *

数据库名称

我们指向的数据库名称

字符串

  

密码 *

密码

用于访问受保护的 PostgreSQL 数据库的密码

字符串

  

查询 *

查询

要对 PostgreSQL 数据库执行的查询

字符串

 

"INSERT INTO 帐户(username,city)VALUES(:#username,:#city)"

serverName *

服务器名称

数据源的服务器名称

字符串

 

"localhost"

用户名 *

用户名

用于访问受保护的 PostgreSQL 数据库的用户名

字符串

  

serverPort

服务器端口

数据源的服务器端口

字符串

5432

 
注意

带有星号(*)标记的字段为必填。