【kettle009】kettle访问Kafka中间件并处理数据至execl文件

作者：System 时间：2024年08月07日分类：所有,中间件字数：707

这篇文章距离上次修改已过273天，其中的内容可能已经有所变动。

-- 假设Kettle中的Kafka输入步骤已正确配置并命名为"Kafka_Input"
-- 假设Kettle中的Excel输出步骤已正确配置并命名为"Excel_Output"
BEGIN
    -- 启动Kettle转换
    CALL pdi.kettle_start_transformation(
        transformation_name   := 'Kafka_To_Excel_Transformation',  -- 转换名称
        directory_path        := '/home/user/pdi-transformation-repo',  -- 转换目录路径
        parameter_name        := 'param_topic',  -- 转换参数名称
        parameter_value       := 'your_kafka_topic',  -- 转换参数值
        parameter_filename    := 'path_to_parameters_file'  -- 参数文件路径（可选）
    );
END;

注意：

需要确保Kettle转换已经被正确定义，包括步骤、参数和连接。
需要在数据库中创建相应的存储过程，以支持调用Kettle转换。
需要确保数据库用户有权限执行外部程序（例如，启动Kettle转换）。
需要确保Kettle环境已经被配置好，并且可以通过命令行调用或API调用。

【kettle009】kettle访问Kafka中间件并处理数据至execl文件

评论已关闭

推荐阅读