kettle 调用 webservice 服务抽取结果到目标库,同时更新源数据库标志位
一、基本配置
- 文件 — 新建 — 转换 建立项目
- 主对象树 DB 连接,一个源数据库 centeradapter 参数库、一个目标数据库 ehrview 参数库



假如输入库中某张表为:
create table TEST20190917(
ID NUMBER,
SHENG VARCHAR2(20),
FLAGTYPE VARCHAR2(4)
);,
输出库中某张表为:
create table TEST20190917(
SHENG VARCHAR2(20),
XMLDATA VARCHAR2(2000)
);
二、创建步骤
建立整体步骤如下所示

1、核心对象 — 输入 — 表输入,连接输入库,读取基础参数表

2、核心对象 — 转换 — 字段选择
点击基础参数表输入框,按住 shift 键,鼠标自前者到字段选择框移动,会进行两个按钮连接,同样方法进行其他步骤直接的连接

3、核心对象 — 查询 –WEB 服务查询,以天气预报服务接口
http://www.webxml.com.cn/WebServices/WeatherWebService.asmx?wsdl 为例,进行配置



4、核心对象 — 输入 –XML 文件输入,XML 源定义在一个字段里打对号,选择源字段名,

根据 webservice 服务接口返回 xml 数据配置循环读取路径

ody></soap:Envelope>,则循环读取路径为 /soap:Envelope/soap:Body/getSupportCityResponse

5、核心对象 — 转换 — 字段选择

6、核心对象 — 输出 — 表输出

7、核心对象 — 转换 — 增加常量

8、核心对象 — 输出 — 更新

三、运行
点击运行按钮
,运行成功会在各个步骤中显示绿色的对号按钮,否则出错会显示红色叉号按钮

四、查看数据
目标库中查找相关表查询出已经插入数据

五、核心对象 — 通用,编写 job 脚本,实现定时器任务




原创文章,作者:端木书台,如若转载,请注明出处:https://blog.ytso.com/tech/database/267354.html