NiFi 中的文件名是如何生成的?

How are filenames generated in NiFi?

我想知道 NiFi 是如何生成文件名的。

这背后的问题是两个流文件是否有可能同名?

例如,如果我们有一个 NiFi 集群,其中处理器获取数据 运行 执行设置为 "all nodes" 会怎样;我们观察到相同的数据可以进入每个节点——在这种情况下,是否有可能生成相同的文件名?

每个流文件都有一个"filename"属性,该属性是在创建流文件时创建的,因此它依赖于创建流文件的处理器。默认情况下,文件名属性将设置为流文件创建时的系统时间(以纳秒为单位),但一些与文件系统交互的处理器(如 GetFile、FetchFile、GetHDFS 等)会将文件名设置为它们检索到的文件。

如果集群中的所有节点都使用文件系统处理器之一获取相同的文件,那么每个节点都会有一个具有相同文件名的流文件,但如果它来自其他地方,则每个节点的系统时间都会不同节点.