Creación de un Task
create or replace task DATABASE.SCHEMA.mi_task
warehouse = mi_warehouse
schedule = '1 MINUTE'
when SYSTEM$STREAM_HAS_DATA('DATABASE.SCHEMA.mi_tabla_stream')
as
call PROJECTDRIVE.WORK."pr_mi_procedure"();
Este task que estamos creando es para que salte cada minuto cuando salte el stream "mi_tabla_stream", si esto ocurre en este caso vamos a llamar a un procedimeinto "mi_procedure()".
Una vez creado lo activamos:
ALTER TASK DATABASE.SCHEMA.mi_task RESUME;
Si queremos desactivarlo para modificarlo o porque no queremos usarlo:
ALTER TASK DATABASE.SCHEMA.mi_task SUSPEND ;
No hay comentarios :
Publicar un comentario