在水槽后继续管道流动

Question

我需要使用 Data Fusion 在 Cloud SQL 数据库 (postgres) 中加载位于 GCS 中的 CSV 文件。

对于每个 CSV 行，我需要在另一个表 (Table_B) 中插入一行，并使用插入的 PK 在我的目标表 (Table_A) 中引用它。

问题：

1. 下沉后是否可以继续管道流动？我无法在 Database Sink 之后添加连接器。
2. 是否可以在数据库接收器插件中返回插入的 pk？

截图： Data Fusion

Answer 1

您可以在接收器之后添加操作插件。例如，Database Action 可用于在管道将数据写入接收器后运行 SQL 命令。

动作插件可以在 Pipeline Studio 的条件和动作部分下找到。

如果现有的动作插件不能满足您的需求，您可以使用this 作为起点编写自己的动作插件。