NiFi 中获取flowFile

在 NiFi 中获取 flowFile 可以使用 ProcessSession 对象。ProcessSession 是 NiFi 中用于管理流程处理的对象，它可以创建、修改、删除 flowFile，以及对 flowFile 进行其他操作。

获取 flowFile 的方法如下：

1. 通过 ProcessContext 获取 ProcessSession 对象：

ProcessSession session = context.processSession();

2. 使用 ProcessSession 对象创建一个新的 flowFile：

FlowFile flowFile = session.create();

3. 使用 ProcessSession 对象获取当前处理的 flowFile：

FlowFile flowFile = session.get();

4. 使用 ProcessSession 对象获取来自某个特定关系的 flowFile：

FlowFile flowFile = session.get(relationship);

其中 relationship 是一个 NiFi 中的关系（relationship）对象，表示一个连接器的输入或输出。

5. 使用 ProcessSession 对象获取来自多个关系的 flowFile：

Set<FlowFile> flowFiles = session.get(relationships);

其中 relationships 是一个 NiFi 中的关系列表，表示多个连接器的输入或输出。

获取 flowFile 后，可以对其进行处理，例如读取、写入、修改、删除等操作。