如何用PDI将RESTClient获取的Blob流写入本地文件系统？

最简单方案：使用Binary File Output步骤（无需代码） #

这是Kettle专门为二进制流写入文件设计的原生步骤，完全无需编写代码，配置即可完成：

• 添加Binary File Output步骤到你的转换流程中，连接在RESTClient步骤之后。
• 在步骤配置界面：
  1. 选择你的流字段（比如stream_field）作为「Binary field」。
  2. 设置「Filename」：可以填写固定路径（如/home/user/images/output.jpg），也可以用Kettle变量或其他字段动态生成路径（比如${output_dir}/${image_filename}.jpg，其中image_filename是你转换中的其他字段）。
  3. 按需配置其他选项（如覆盖已有文件、自动创建父目录等），运行转换即可完成写入。

备选方案：User Defined Java Class步骤（自定义逻辑） #

如果你需要更灵活的自定义逻辑（比如额外的流处理、异常判断），可以用UJDC步骤，核心是正确调用流字段的读取方法：

配置步骤 #

1. 将UJDC步骤连接到RESTClient步骤，在UJDC的「Fields」面板中，确保你的流字段已被选中（这样代码才能访问该字段）。
2. 在「Script」面板中写入以下代码（替换占位符为你的实际信息）：

import java.io.FileOutputStream;
import java.io.InputStream;

// 读取流字段的输入流，替换为你的流字段名
InputStream inputStream = getInputStream("stream_field");
// 定义输出路径，可动态拼接字段值或变量
String outputPath = "/home/user/images/result.jpg";

try (FileOutputStream outputStream = new FileOutputStream(outputPath)) {
    byte[] buffer = new byte[4096];
    int bytesRead;
    // 逐块读写流内容
    while ((bytesRead = inputStream.read(buffer)) != -1) {
        outputStream.write(buffer, 0, bytesRead);
    }
    // 可选：添加状态标记字段
    setValue("write_status", "SUCCESS");
} catch (Exception e) {
    // 异常处理
    setValue("write_status", "FAILED: " + e.getMessage());
    throw new RuntimeException("写入文件失败", e);
} finally {
    // 确保输入流关闭
    if (inputStream != null) {
        inputStream.close();
    }
}

关键语法说明 #

Kettle的流字段不能用普通字段的getString()或get()方法读取，必须调用getInputStream("流字段名")来获取对应的输入流，这是你之前可能出错的地方。

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