PDI/Kettle：避免文件创建或映射（子转换）执行

Question

现在很清楚，转换的所有步骤都是并行执行的，在 Pentaho 中无法更改此行为。

鉴于此，我们有一个带有切换任务的场景，它检查特定字段（从文件名读取）并决定哪个任务（映射 - 子转换）将处理该文件。这是通用逻辑的一部分，在每个映射任务之前和之后，都会执行一些样板任务，例如更新数据库记录、发送电子邮件等。

问题是：如果我们没有“ACCC014”文件，则无法执行此转换。我知道这是不可能的，因为所有任务都是并行执行的，所以出现了第二个问题：在一些映射中，创建了 XML 文件。而且即使 Pentaho 使用空数据执行这个任务，我们也找不到避免创建 XML 输出文件的方法。

我们考虑过将这个开关逻辑移到作业中，因为理论上它是串行的，但没有发现可以进行这种区分的条件步骤。

我们还研究了元数据注入任务，但我们不认为这是要走的路。每个子转换都做了不同的工作。其中一些更新一些表，另一些写入文件，另一些在不同数据库之间移动数据。它们都接收一些文件作为输入并返回一个 send_email 标志和一个消息字符串。没有别的了。

有没有办法做我们愿意做的事？还是没有办法重用基于默认输入/输出的部分逻辑？

编辑：添加 ACCC014 转换。是的，“开始时不创建文件”选项被选中。

Answer 1

您可以使用Transformation Executor 步骤 (http://wiki.pentaho.com/display/EAI/Transformation+Executor) 来有条件地执行转换。虽然我没有真正使用过这一步，所以我不能说它的稳定性或性能。

主要改造：

像这样设置你的父转换：
关于 Injector 步骤：在 5.2 版本中，即使它们是在“结果行”选项卡上定义的，我也无法获得在子转换中创建的字段，因此我必须在 Injector 步骤中定义所有这些字段。 不确定，在当前版本中是否仍然需要。

Transformation Executor 的可能调整：

1. 您可能想要更改 Row grouping 选项卡上的 The number of rows to send to the transformation 值：将其设置为 0 以便 一次发送所有行，而不是重新执行转换 每 N 行。

2. 如果要读取子转换的输出，请选择“此 输出将包含执行后的结果行”选项而 创建到后续步骤的跃点：

子变换：

您可能需要的唯一更改是将映射输入和输出替换为 Get rows from result 和 Copy rows to result：

5.2 中的已知问题： 似乎作业执行器不是从“将行复制到结果”步骤中读取子转换的输出，而是从最近创建的步骤中读取的。因此，如果您在子转换中添加了一些步骤，请记住重新创建您希望从中读取输出的步骤：只需选择“将行复制到结果”，剪切它，将其粘贴回去并重新创建跃点。