如何在NiFi ExecuteScript处理器中获取FlowFile对应的XLSX文件？

当然可行，以下是具体的实现思路、示例代码和关键注意事项：

核心原理 #

ExecuteScript处理器允许你直接操作FlowFile的内容流，你可以读取XLSX文件的字节数据，再通过HTTP、FTP等协议将其发送到目标服务。

Groovy脚本示例（NiFi兼容度高） #

Groovy是NiFi ExecuteScript的常用脚本语言，示例代码如下：

import org.apache.nifi.processor.io.StreamCallback
import org.apache.http.client.methods.HttpPost
import org.apache.http.entity.ByteArrayEntity
import org.apache.http.impl.client.CloseableHttpClient
import org.apache.http.impl.client.HttpClients

def flowFile = session.get()
if (!flowFile) return

// 读取FlowFile内容并发起传输
flowFile = session.write(flowFile, { inputStream, outputStream ->
    // 读取XLSX文件的全部字节（大文件建议改用流式传输）
    byte[] xlsxBytes = inputStream.bytes
    
    // 初始化HTTP客户端
    CloseableHttpClient client = HttpClients.createDefault()
    HttpPost post = new HttpPost("https://你的目标服务地址")
    
    // 设置请求头和实体
    post.setHeader("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
    post.setEntity(new ByteArrayEntity(xlsxBytes))
    
    // 执行请求并处理结果
    def response = client.execute(post)
    def statusCode = response.getStatusLine().getStatusCode()
    
    if (statusCode >= 200 && statusCode < 300) {
        session.transfer(flowFile, REL_SUCCESS)
    } else {
        session.transfer(flowFile, REL_FAILURE)
    }
    
    client.close()
} as StreamCallback)

session.commit()

关键注意事项 #

• 依赖包准备：如果使用Apache HttpClient这类第三方库，需要将对应的jar包放到NiFi安装目录的lib文件夹下，重启NiFi生效
• 大文件处理：如果XLSX文件体积较大，不要一次性读取全部字节到内存，改用流式传输（比如直接将inputStream写入HTTP请求的输出流）
• 异常捕获：建议在脚本中添加try-catch块，处理网络连接失败、目标服务无响应等异常，避免处理器挂起
• 协议扩展：除HTTP外，也可以用类似逻辑实现FTP/SFTP传输，只需替换对应的客户端工具类即可

内容的提问来源于stack exchange，提问作者Mandroid