如何在数据库变更时触发执行Pentaho作业或转换？

你可以通过以下几种方案实现，替代原有的定时执行模式，缩短业务处理延迟：

方案1：PostgreSQL表触发器直接调用外部脚本（Windows环境） #

PostgreSQL本身不支持直接创建Windows事件，但可以通过DML触发器调用自定义函数，在函数里执行批处理脚本启动Pentaho作业：

1. 安装必要扩展（可选，用Python实现函数）
   若用Python编写触发函数，先安装plpython扩展：

   CREATE EXTENSION IF NOT EXISTS plpython3u;
   

2. 编写触发函数
   这个函数会在PO表新增数据时，调用Windows批处理脚本：

   CREATE OR REPLACE FUNCTION trigger_pentaho_job()
   RETURNS TRIGGER AS $$
   import os
   # 替换为你的批处理脚本路径
   os.system('cmd /c "C:\\pentaho_scripts\\start_po_job.bat"')
   RETURN NEW;
   $$ LANGUAGE plpython3u;
   

3. 给PO表绑定触发器
   针对INSERT事件创建触发器，确保新增PO时触发函数：

   CREATE TRIGGER po_after_insert
   AFTER INSERT ON your_po_table
   FOR EACH ROW
   EXECUTE FUNCTION trigger_pentaho_job();
   

4. 编写Pentaho启动批处理脚本
   示例start_po_job.bat内容：

   @echo off
   cd "C:\Program Files\Pentaho\data-integration"
   kitchen.bat /file:"C:\pentaho_jobs\process_new_po.kjb" /level:Basic
   

方案2：LISTEN/NOTIFY异步触发（推荐） #

直接在触发器里执行外部命令可能阻塞数据库事务，更优的方式是用PostgreSQL的LISTEN/NOTIFY机制异步触发：

1. 创建通知触发器
   当PO表新增数据时，发送异步通知：

   CREATE OR REPLACE FUNCTION notify_po_insert()
   RETURNS TRIGGER AS $$
   BEGIN
     PERFORM pg_notify('new_po_event', NEW.po_id::text);
     RETURN NEW;
   END;
   $$ LANGUAGE plpgsql;
   
   CREATE TRIGGER po_notify_trigger
   AFTER INSERT ON your_po_table
   FOR EACH ROW
   EXECUTE FUNCTION notify_po_insert();
   

2. 编写监听脚本
   用Python写一个持续监听通知的脚本，收到通知后启动Pentaho作业：

   import psycopg2
   import os
   from psycopg2.extensions import ISOLATION_LEVEL_AUTOCOMMIT
   
   # 替换为你的数据库连接信息
   conn = psycopg2.connect(dbname="your_db", user="db_user", password="db_pass", host="localhost")
   conn.set_isolation_level(ISOLATION_LEVEL_AUTOCOMMIT)
   cur = conn.cursor()
   cur.execute("LISTEN new_po_event;")
   
   print("监听PO新增事件中...")
   while True:
       conn.poll()
       while conn.notifies:
           notify = conn.notifies.pop(0)
           print(f"收到新PO事件：ID {notify.payload}")
           # 调用Pentaho启动脚本
           os.system('cmd /c "C:\\pentaho_scripts\\start_po_job.bat"')
   

   将这个脚本做成Windows服务（比如用NSSM工具），开机自动运行即可实现实时监听。

方案3：API轮询（备选） #

如果不想修改数据库配置，可以编写一个定时轮询脚本，通过数据库API检查PO表的最新记录，发现新增数据时触发Pentaho作业。这种方式实现简单，但延迟取决于轮询间隔（比如10-30秒）。

关键注意事项 #

• 确保PostgreSQL服务账户有执行外部脚本和访问Pentaho目录的权限，否则会触发失败。
• 避免在触发器中执行耗时操作，推荐用LISTEN/NOTIFY的异步方式，防止阻塞主业务事务。
• Pentaho的kitchen.bat（作业）或pan.bat（转换）需配置正确的环境变量，或在脚本中指定完整路径。

内容的提问来源于stack exchange，提问作者Robert Hicks