### Windows Python 调用 Linux 版本 Kettle 并执行命令的方法 要在 Windows 系统中通过 Python 脚本来调用运行在 Linux 上的 Kettle（Pentaho Data Integration），可以通过 SSH 协议远程连接到 Linux 服务器并执行相关命令。以下是详细的解决方案： --- #### 1. 安装 Paramiko 库 Paramiko 是一个用于 Python 的 SSHv2 协议库，允许开发者编写客户端程序来与远程服务器通信。可以在本地 Windows 环境中安装该库以便后续使用。 ```bash pip install paramiko ``` --- #### 2. 构建 SSH 连接 以下是一个完整的 Python 脚本示例，展示如何通过 Paramiko 在 Windows 中调用 Linux 上的 Kettle 命令。 ```python import paramiko def run_kettle_job_on_linux(host, port, username, password, command): """ 使用 Paramiko 在 Linux 上通过 SSH 执行 Kettle Job 或 Transformation。 参数说明： host (str): Linux 服务器的 IP 地址或域名。 port (int): SSH 端口号，默认为 22。 username (str): 登录 Linux 服务器的用户名。 password (str): 用户密码。 command (str): 需要在 Linux 上执行的具体 Kettle 命令。 """ try: # 初始化 SSH 客户端 ssh_client = paramiko.SSHClient() # 自动接受未知主机密钥 ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy()) # 连接到 Linux 服务器 ssh_client.connect(hostname=host, port=port, username=username, password=password) # 执行 Kettle 命令 stdin, stdout, stderr = ssh_client.exec_command(command) # 输出标准输出和错误流 output = stdout.read().decode('utf-8') error = stderr.read().decode('utf-8') if error: print(f"Error occurred while running the command:\n{error}") else: print(f"Command executed successfully.\nOutput:\n{output}") except Exception as e: print(f"An exception occurred: {e}") finally: # 关闭 SSH 连接 ssh_client.close() # 示例：调用 Kettle Job if __name__ == "__main__": linux_host = "your_linux_server_ip" linux_port = 22 linux_username = "your_username" linux_password = "your_password" # 构造 Kettle 命令 kettle_home = "/opt/kettle/pdi-ce-7.1.0.0-12/data-integration/" repository_name = "PRD" job_directory = "/DATA_CHECK" job_name = "check_done_send_mail" log_file_path = f"/home/kettlelog/{job_name}_$(date +%Y%m%d).log" kettle_command = ( f"{kettle_home}kitchen.sh " f"-rep {repository_name} " f"-user admin -pass admin " f"-dir {job_directory} -job {job_name} " f"-level=Basic >> {log_file_path}" ) # 调用函数 run_kettle_job_on_linux(linux_host, linux_port, linux_username, linux_password, kettle_command) ``` 此脚本实现了以下几个功能： - 使用 Paramiko 创建 SSH 连接[^3]。 - 在 Linux 服务器上执行指定的 Kettle 命令。 - 捕获并打印命令的标准输出和错误信息。 --- #### 3. 注意事项 - **SSH 密钥认证** 如果希望避免每次输入密码，可以配置基于公私钥的 SSH 认证方式。这需要提前将 Windows 系统中的公钥上传至 Linux 服务器，并修改上述代码以加载私钥文件。 - **日志记录** 可以扩展脚本的功能，将执行结果保存到本地文件中，便于后期分析和调试。 - **异常处理** 添加更多的异常捕获机制，确保即使发生意外情况也能优雅退出而不影响其他业务逻辑。 --- #### 4. 替代方案 除了直接通过 SSH 执行命令外，还可以考虑以下替代方法： - **REST API 接口** 若目标环境支持 RESTful Web Service，则可通过 HTTP 请求触发 Kettle 作业或转换任务[^4]。 - **FTP/SFTP 文件传输** 当仅需传递少量参数而非整个脚本时，可先借助 FTP 或 SFTP 将必要资源同步过去再单独启动对应进程。 ---