0

如何一次从 ExecuteScript 处理器接收 2 个 csv 流文件，以及如何使用 python 在 NIFI 中使用主键合并到一个 csv 中。

我使用的是正确的处理器还是需要更改以将多个流文件发送到 python 代码并使用主键合并。我使用下面的代码来获取流文件。我一次无法接收 2 个文件。但 NIFI ExecuteScript 处理器发送 2 个文件

flowFiles = session.get(2)
if (flowFiles != None):
  if (flowFiles[0] != None and flowFiles[1] != None):
      myAttr1 = flowFiles[0].getAttribute('k')
      log.info(' myAttr1 :: ',myAttr1)
      myAttr = flowFiles[1].getAttribute('l')
      log.info(' myAttr :: ',myAttr)
4

0 回答 0