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

Question

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

Answer 1

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

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