我正在尝试在Nifi上创建一个基本流程
这很简单。
但是，当我尝试在python上读取数据时，我遇到了问题
据我所知，我需要使用sys. stdin/out。它只读取和写入如下。
import sys
import pandas as pd
file = pd.read_csv(sys.stdin)
file.to_csv(sys.stdout,index=False)
您可以在下面找到处理器属性，但我认为这不是问题所在。
查询数据库表记录：
错误信息：
如果您运行的是1.12.0或更高版本，有一种更简单的方法可以做到这一点：脚本转换记录。它就像ExecuteScript，只是它基于每条记录工作。这就是它的简单Groovy脚本的样子：
def fullName = record.getValue("FullName")
def nameParts = fullName.split(/[\s]{1,}/)
record.setValue("FirstName", nameParts[0])
record.setValue("LastName:", nameParts[1])
record
这是一个新的处理器，所以除了捆绑的（非常好的）留档之外，它还没有那么多留档。所以目前示例可能很少。如果你想使用并遇到问题，请随时加入nifi-user邮件列表并寻求更详细的帮助。
