在汇后继续管道流动

Question

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

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

问题：

下

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

截图： 数据融合

Answer 1

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

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

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