在Kettle（现称为 **Pentaho Data Integration**）中调用 Python 脚本并传递参数、接收返回值，通常可以通过 **Shell 步骤** 或 **调用 HTTP 接口** 的方式实现。以下将分别介绍这两种方法，并说明如何实现参数传递与结果接收。 ### 1. 使用 Shell 步骤调用 Python 脚本并传递参数 Kettle 提供了 Shell 步骤，可以用于调用本地的 Python 脚本。通过命令行参数的方式，可以将 Kettle 中的数据作为参数传递给 Python 脚本，并通过标准输出（stdout）将结果返回给 Kettle。 #### 示例 Python 脚本（test.py）： ```python import sys def main(param1, param2): print(f"Received parameters: {param1}, {param2}") result = int(param1) + int(param2) print(result) if __name__ == "__main__": if len(sys.argv) != 3: print("Usage: python test.py <param1> <param2>") else: main(sys.argv[1], sys.argv[2]) ``` #### 在 Kettle 中配置 Shell 步骤： - 添加一个 **Job**，选择 **Shell** 步骤。 - 在 **Script filename** 中选择你的 Python 脚本路径。 - 在 **Arguments** 中输入参数，例如： ``` ${param1} ${param2} ``` - 设置 **Working directory** 为脚本所在目录。 - 在 **Output** 选项卡中，勾选 **Capture output of script**，并将输出结果保存到字段中，例如 `script_output`。 执行完成后，`script_output` 字段将包含 Python 脚本的标准输出内容，可以通过后续步骤解析该字段获取返回值。 --- ### 2. 使用 HTTP 步骤调用 Python 提供的 REST API 如果 Python 脚本被封装为 Web 服务（如使用 Flask），则可以通过 Kettle 的 **HTTP** 步骤调用该服务，并传递参数和接收 JSON 格式的响应。 #### 示例 Python Flask 服务： ```python from flask import Flask, request, jsonify app = Flask(__name__) @app.route('/process', methods=['GET']) def process(): param1 = request.args.get('param1') param2 = request.args.get('param2') result = int(param1) + int(param2) return jsonify({"result": result}) if __name__ == "__main__": app.run(debug=True) ``` #### 在 Kettle 中配置 HTTP 步骤： - 添加一个 **Transformation**，选择 **HTTP** 步骤。 - 配置 URL 为 `http://localhost:5000/process`。 - 在 **Parameters** 中添加参数 `param1` 和 `param2`，并绑定到 Kettle 中的字段。 - 执行后，HTTP 步骤会返回 JSON 数据，可以通过 **JSON Input** 步骤解析响应内容，提取 `result` 字段。 --- ### 3. 参数传递注意事项 - 确保 Python 环境已正确配置，并在 Kettle 所在服务器的环境变量中添加 Python 的路径，例如 `E:\Anaconda3;E:\Anaconda3\Scripts`[^5]。 - 如果使用 Shell 步骤，确保 Python 脚本具有可执行权限，并且 `.py` 文件默认由 Python 解释器打开。 - 若需处理复杂数据结构，建议使用 HTTP 接口方式，返回 JSON 格式数据更便于解析。 --- ### 4. 结果接收与后续处理 - 对于 Shell 方式，可以使用 **JavaScript** 或 **Calculator** 步骤对输出字段进行解析。 - 对于 HTTP 方式，使用 **JSON Input** 步骤提取返回值后，可以直接用于后续的数据库写入、日志记录等操作。 --- ###