一、前言

elasticsearch-bulk-insert-plugin插件，如下图，参数配置不能使用kettle.properties文件设计的变量，不利于作业迁移。考虑到ES支持rest api，尝试使用REST Client组件往ES迁移数据

二、方法

1、转换总览

在这里插入图片描述

2、表输入

在这里插入图片描述

3、JSON Output

拿到源表数据后转成JSON类型：
在这里插入图片描述
在这里插入图片描述
此步骤将从mysql表拿到的数据转成了如下格式：
在这里插入图片描述

4、JSON Input

还需进一步解析才能获得适合推入ES的json数据：
在这里插入图片描述
在这里插入图片描述
JSONPath可参考下：https://blog.csdn.net/lwg_1540652358/article/details/84111339

5、REST Client

向ES发送请求：
在这里插入图片描述

6、备注

若mysql源表中存在NULL值，依然能插入ES。从mysql数据转成的json为：
在这里插入图片描述
查询ES：
在这里插入图片描述
使用exists查询字段为null的文档：
在这里插入图片描述

# etl
Logo
乐奇 Rokid 开放社区

更多推荐

2026年9月16日 星期三 AI 日报

31.Meta推出个人Agent产品Muse：由闭源模型Muse Spark驱动，可通过独立应用、网页及WhatsApp交互，连接第三方服务、操作浏览器并后台持续执行任务，采用免费+20/100美元两档订阅，后续将接入Meta智能眼镜。22.国产AI编程工具全景成型：形成CLI终端、IDE插件、AI原生IDE、Web端、云端智能体、本地部署六种形态：Kimi Code、Trae、文心快码Comat

avatar 乐奇 Rokid 开放社区
cover

AR巡检哪家好

avatar 乐奇 Rokid 开放社区

Hydra 1.1 到 1.2 升级指南：@hydra.main() 与 hydra.initialize() 的 config_path 默认行为变更

Hydra 从 1.2 开始，当 `version_base >= "1.2"` 时，`@hydra.main()` 和 `hydra.initialize()` 的 `config_path` 参数默认值由"应用所在的目录"变更为 `None`，即不再向配置搜索路径（Config Search Path）中自动添加任何目录。这篇指南梳理 Hydra 1.0 → 1.1 → 1.2 三个阶段 `c

avatar 乐奇 Rokid 开放社区