Nifi：flowFile量に基づいてtrnasfer 'transaction'を処理する方法はありますか？

Question

私はflowFileキューにある一定量のflowFileを持っていて、使用されていないFileに対して削除操作を行うときに転送操作を行いたいと思っています。 flowfileの配列リストからflowfileを消失させる操作の原因を取り除くことができますか？ここに私のコードは次のとおりです。

import org.apache.commons.io.IOUtils 
import java.nio.charset.StandardCharsets 
import groovy.lang.* 

def flowFile=session.get(); 
def name=flowFile.getAttribute("realName") 
def count=flowFile.getAttribute("count") 
def filename=flowFile.getAttribute("filename") 
def value= count as Double; 
def numb=Math.round(value) 
def List<FlowFile> flowFiles= new ArrayList<>(); 
flowFiles.add(flowFile) 

if(flowFiles.size()==numb){ 
for(FlowFile i in flowFiles){ 
if(i.getAttribute("filename").substring(0,10)==name){ 
session.transfer(i,REL_SUCCESS); 

} 
} 
} 

else{ 

session.remove(flowFile); 

} 

Answer 1

あなたが受信されるフローファイルのX数を待っている場合、あなたは（あなたが10個のフローファイルをしたいと仮定して）このようなものを使用することができます。

def flowfileList = session.get(10) 
if(flowfileList.size() < 10) { 
    session.rollback() 
    return 
} 
​// If you get here, you have 10 flowfiles in flowfileList