如何基于Snowflake查询结果触发Informatica映射任务?
问题说明
我们公司通过Informatica将S3中的数据导入Snowflake,每次数据导入任务完成后,系统会向INFORMATICA_JOBS表插入一条记录,包含目标表的模式与表名、处理行数及时间戳。该表的结构与示例数据如下:
| table | rows | timestamp |
|---|---|---|
| schema_A.table1 | 123 | 2023-06-06 13:02 |
我需要监控这个表,当任意记录的rows列值为0时,自动触发对应的Informatica映射任务——原本这个操作需要手动登录Informatica执行。
目前我已创建了一个Snowflake任务用于检测rows=0的记录,代码如下:
CREATE OR REPLACE TASK CheckTableForZeroRowsTask WAREHOUSE = warehouse_name SCHEDULE = 'DAILY' AS USE ROLE dev_role; USE WAREHOUSE warehouse_name; SELECT COUNT(*) FROM schema_A.table_name WHERE rows=0;
但不清楚如何在检测到rows=0的情况时,自动触发Informatica的映射任务。
内容的提问来源于stack exchange,提问作者Aastha Jha
相关产品推荐
相关产品推荐

