Obrigado Andy, primeiro por me contar sobre o operador "From File", torna a vida mais fácil em alguns casos ?
Também precisava enviar apenas uma vez, quando o lote estivesse completamente terminado. E encontrei minha solução em outra de suas respostas no fórum.
registros=[]
def on_input(msg):
global registros
registros.append(msg.attributes['file']['path'])
if msg.attributes['message.lastBatch']:
api.send("out", registros)
api.set_port_callback("in", on_input)
Então, muito obrigado