如何将字段添加到 Apache NiFi 中的 Avro 模式？

Question

我可以让 Apache NiFi 通过 CSVReader 生成架构，然后可以使用 ConvertRecord 将架构写入属性。但是，我随后需要使用 UpdateRecord 添加字段，但这些字段不会添加到流文件或架构属性中。我相信这是因为这些字段不是最初推断的模式的一部分。我无法在注册表中创建架构，因为它是从文件中推断出来的。那么，当架构不包含字段时，如何向记录添加字段呢？

Answer 1

您使用 InferAvroSchema 是为了不必担心生成架构，还是因为您真的不知道 CSV 文件的架构？如果是前者，则发送一个 CSV，然后将推断的架构复制到 CSVReader 中，并将 UpdateRecord 中的字段添加到写入架构中。

我编写了NIFI-5524来介绍基于 UpdateRecord 属性在传出模式中添加/更新字段的自动化。