Apache NiFi - プロセッサへの入力として複数のFlowFilesを使用する

Question

私は、2つ以上の入力が1つの出力を生成するためにそれらに対して実行された操作（集合、補数など）を持つワークフローを持っています。私は自分自身で設定されたロジックを実行するプロセッサを作成する必要があると予想しますが、異なる起源の複数のフローファイルで同時に作業することも可能ですか？

Answer 1

NiFiプロセッサは、入力キュー内のすべてのフローファイルに対して操作できます。たとえば：

@Override 
public void onTrigger(final ProcessContext context, final ProcessSession session) { 
    List<FlowFile> flowFiles = session.get(context.getProperty(BATCH_SIZE).asInteger()); 
    if (flowFiles == null || flowFiles.size() == 0) { 
     return; 
    } 
    // process flowFiles 
    ... 

その後、同じ背圧と優先順位付けの設定を共有することができ、単一の入力キューの中に複数の入力を一緒に持って来るためにファンネルコンポーネントを使用することができます。