04 - 步骤 JSON input

ops/2024/10/22 9:44:07/

简介

Kettle 的 JSON Input 步骤是用于从 JSON 格式的数据源中读取数据的步骤。它允许用户指定 JSON 格式的输入数据,然后将其转换成 Kettle 中的行流数据,以供后续的数据处理、转换和加载操作使用。

使用

场景

1、拖拽到面板

2、指定JSON input 为 Kafka consumer的下一步骤

点击Kafka consumer ,从边框点击连接到 JSON input.

3、配置

双击JSON input

4、调试

idea 发送一条消息到 Kafka consumer 监听的 test 主题

结果如下:


http://www.ppmy.cn/ops/27157.html

相关文章

Mysql优化之参数调优

前言 MySQL参数优化是针对数据库配置参数的调整和优化,以提高数据库系统的性能、稳定性和可用性。它和Mysql的应用环境例如项目的用户量在线情况、访问情况、存储资源量等以及服务硬件配置都有关系,优化也不可能一次性完成,需要不断的观察以…

python脚本实现布尔盲注

目录 代码实现 代码解释 过程中遇到的问题 1、号url编码问题 2、二分法查找 3、如何判断这一次循环内的变量值等于上一次的值 第一种思路 第二种思路 相信师傅们在平常渗透测试中,偶尔会遇到布尔盲注的情况,但是手工的话太慢,上sqlma…

微信小程序 - 登录(切屏后继续倒计时)

屏幕休眠或后台运行倒计时暂停问题 updateTime: function () {let promise new Promise((resolve, reject) > {var beginTime new Date().getTime();let setTimer setInterval(() > {var newTime new Date().getTime();var dTime (newTime - beginTime) / 1000;dTim…

50. 【Android教程】xml 数据解析

xml 是一种标记扩展语言(Extension Mark-up Language),学到这里大家对 xml 语言一定不陌生,但是它在 Android 中的运用其实只是冰山一角。抛开 Android,XML 也被广泛运用于各种数据结构中。在运用 xml 编写 Android 布…

Gateway路由

Route以微服务名-动态获取服务URI 痛点:路由url写死问题。 是什么 https://docs.spring.io/spring-cloud-gateway/reference/spring-cloud-gateway/global-filters.html#reactive-loadbalancer-client-filter 修改 9527 yml中的url 测试 如果将8001微服务ym1文件端…

python——Pandas库

Pandas 是一个非常强大的 Python 库,专门用于数据处理和分析。在处理 Excel 文件时,它提供了简单且功能丰富的 API,使得读取、写入、筛选、修改以及分析 Excel 数据变得十分便捷。以下是一些常用的 Pandas API 及其应用场景,以及如…

【Numpy】一文向您详细介绍 np.linspace()

【Numpy】一文向您详细介绍 np.linspace() 🌈 欢迎莅临我的个人主页👈 这里是我静心耕耘深度学习领域、真诚分享知识与智慧的小天地!🎇 🎓 博主简介:985高校的计算机专业人士,热衷于分享技术见…

【Docker学习】docker checkpoint简单了解

docker checkpoint是一个试验性的功能,旨在用于测试和反馈,未来不确定是否会发生变化或是被删除掉,现有的功能我们可以简单了解了解。 docker checkpoint主要用于管理检查点(CheckPoint)。检查点(CheckPoi…