如何使用文件名組合隊列中的文件？

我已經處理兩個文件（file1和file2），處理2個文件的結果是1000個正在排隊的流文件。如何使用文件名組合隊列中的文件？

現在我需要結合流文件使用「文件名」屬性。

例如： 1000個隊列中的流文件（無序）。如果文件名是file1/file2，我們需要合併流文件。然後根據FIFO策略進行處理。

基於它的文件名合併所有流文件。

NiFi有可能嗎？

我不知道如果我完全理解你的使用情況，但檢查出MergeContent處理器，你可以設置「文件名」的相關屬性Name屬性，應該結合在一起具有相同的所有流文件文件名。

2017-03-06 14:30:23 mattyb

您是否試過使用RouteOnAttribute處理器？從你所描述的感覺來看，這可能會完成這項工作。

2017-03-06 12:04:28 mrjoseph

mrjosph，我不應該給文件名來拆分它。任何通用的方法來檢查文件名？ –

$ {filename}返回實際的文件名，您在上面Value列中提供的確切規則取決於您的需求（甚至可能是正則表達式）。如果你只有兩個文件，你可以爲一個匹配規則（這將匹配到「匹配」），另一個會轉到「不匹配」的流程。 – mrjoseph

回答