kettle从入门到精通 第六十三课 ETL之kettle kettle调用python脚本的两种方法

server/2024/9/24 2:00:44/

想真正学习或者提升自己的ETL领域知识的朋友欢迎进群,一起学习,共同进步。若二维码失效,公众号后台加我微信入群,备注kettle

图片

kettle中不能直接调用python脚本,可以通过shell脚本和http进行调用pyton服务。

一、shell脚本调用python脚本

1、下面是一段简单的无参python脚本

import osdef main():# 在这里编写Python脚本的主要逻辑print("Hello, this is a Python script called by shell!")if __name__ == "__main__":main()

2、通过shell脚本调用。

 shell脚本

cd D:\king\kettle-demo
py test.py

 3、将步骤【Shell】拉入画布,步骤内直接编写shell脚本或者调用shell文件进行调用python脚本,如下图所示:

 4、采用直接插入shell脚本的方式调用python脚本,如下图所示:

 5、选项卡脚本文本框内直接填写shell脚本,如下图所示:

6、下面是一段简单的带参python脚本

# 文件名:script_with_args.pyimport sysdef main():if len(sys.argv) < 2:print("Usage: python script_with_args.py <arg1>")returnarg1 = sys.argv[1]print(f"Argument passed from shell: {arg1}")if __name__ == "__main__":main()

7、采用py test1.py java命令将参数java传递给python脚本,如下图所示:

 8、采用调用shell文件(rundemo.bat或者rundemo.sh)方式进而调用python脚本,如下图所示:

最下面的参数可以设置传递给python脚本参数,如设置V1参数。

9、采用调用shell文件(rundemo.bat或者rundemo.sh)方式进而调用python脚本,如下图所示:

也可以上一步骤的结果作为参数传递给python脚本。

 10、转换中设置一个参数V1为java,然后将java字符串传递给python脚本,如下图所示:

 二、http方式调用pyton服务

此处是将python脚本暴露http服务接口,然后在kettle中使用http步骤进行调用。这里不在详细介绍,可以参考之前的http调用文章。至于python脚本如何暴露http服务(使用Flask轻松解决),如下图所示:


http://www.ppmy.cn/server/42876.html

相关文章

CMake 在工程管理中的使用 Window/MacOS

CMake 在工程管理中的使用 Window/MacOS 是什么 CMake 是一个跨平台的编译工具&#xff0c;可以用简单的语句来描述所有平台的编译过程。 编译工具 Visual Studio 自动解析编译 cmakelists.txt 编译与链接 编译&#xff1a;将当前的C/C 代码通过编译器&#xff0c;编译位…

Pytest框架实战二

在Pytest框架实战一中详细地介绍了Pytest测试框架在参数化以及Fixture函数在API测试领域的实战案例以及具体的应用。本文章接着上个文章的内容继续阐述Pytest测试框架优秀的特性以及在自动化测试领域的实战。 conftest.py 在上一篇文章中阐述到Fixture函数的特性&#xff0c;第…

集中抄表电表是什么?

1.集中抄表电表&#xff1a;简述 集中抄表电表&#xff0c;又称为远程抄表系统&#xff0c;是一种现代化电力计量技术&#xff0c;为提升电力行业的经营效率和客户服务质量。它通过自动化的形式&#xff0c;取代了传统人工抄水表&#xff0c;完成了数据信息实时、精确、高效率…

Python ❀ 使用代码解决今天中午吃什么的重大生存问题

1. 环境安装 安装Python代码环境参考文档 2. 代码块 import random# 准备一下你想吃的东西 hot ["兰州拉面", "爆肚面", "黄焖鸡", "麻辣香锅", "米线", "麻食", "羊肉泡馍", "肚丝/羊血汤&qu…

【编译原理】词法分析器的设计与实现

一、实验目的 通过设计编制调试一个具体的词法分析程序&#xff0c;加深对词法分析原理的理解。并掌握在对程序设计语言源程序进行扫描过程中将其分解为各类单词的词法分析方法。 编制一个读单词过程&#xff0c;从输入的源程序中&#xff0c;识别出各个具有独立意义的单词&…

kafka调优参考建议 —— 筑梦之路

这里主要是从不同使用场景来调优&#xff0c;仅供参考。 吞吐量优先 吞吐量优先使用场景如采集日志。 1. broker配置调优 num.partitions&#xff1a;分区个数&#xff0c;设置为与消费者的线程数基本相等 2. producer配置调优 batch.size 批量提交消息的字节数&#xff0c;…

GitHub的原理及应用详解(一)

本系列文章简介&#xff1a; GitHub是一个基于Git版本控制系统的代码托管平台&#xff0c;为开发者提供了一个方便的协作和版本管理的工具。它广泛应用于软件开发项目中&#xff0c;包括但不限于代码托管、协作开发、版本控制、错误追踪、持续集成等方面。 GitHub的原理可以简单…

【无标题】亚马逊5月24日宣布推出2024出口跨境物流加速器计划

亚马逊中国5月24日郑重宣布启动“2024亚马逊出口跨境物流加速器计划”&#xff0c;旨在依托其世界领先的物流网络和前沿技术&#xff0c;结合本土资源&#xff0c;不断优化跨境物流服务&#xff0c;以强化中国卖家在跨境物流供应链管理方面的能力&#xff0c;进而提升整体效率&…