基本实现和处理

PostgreSQL漂移同步解决方案的基本实现包括您选择的源端,PostgreSQL Metadata处理器和JDBC Producer目标端:

PostgreSQL漂移同步解决方案以如下方式使用PostgreSQL Metadata处理器和JDBC Producer目标端:

PostgreSQL Metadata处理器,用于漂移检测和表更改
处理记录时,PostgreSQL Metadata处理器会检测到对新表和新列的需求。在检测到更改需求后,它将执行数据定义语言(DDL)以根据需要创建新的数据库表或更改现有表。这允许数据库在记录到达JDBC Producer目标端之前创建或更改表。
处理器创建表并将列添加到表中。它不会从表中删除现有列。
注意: 在部署PostgreSQL漂移同步解决方案之前,请考虑数据库的创建和更改表速度,以及传入数据的创建和更改表要求。如果数据库无法快速执行所需的更改,则PostgreSQL漂移同步解决方案可能不是合适的解决方案。
写入新表和变更表的JDBC Producer目标端
该JDBC Producer目标端将数据写到基于在阶段配置属性数据库。
由PostgreSQL Metadata处理器创建或更改的表中的所有列均允许为空。在写入缺少字段的记录时,数据库将在相应的列中插入空值。

整理记录

目前,PostgreSQL漂移同步解决方案不处理带有嵌套字段的记录。如有必要,您可以使用Field Flattener处理器对带有嵌套字段的记录进行扁平化,然后再将它们传递给PostgreSQL Metadata处理器

带有Field Flattener的PostgreSQL漂移同步解决方案的基本实现如下所示: