...

Introducción

En esta release se ha creado la base de un Planificador en Plataforma que permite:

• Definir un flujo de negocio:

  • este flujo puede estar compuesto por DataFlows, Notebooks y/o Entidades KPI

  • Indicar el orden del flujo

  • Indicar qué hacer ante error

• Planificar la ejecución de un flujo de negocio (desde el FlowEngine)

• Capturar el resultado de cada ejecución del flujo

• Visualizar el estado de la ejecución del flujo en un Dashboard de Plataforma

• Relanzar procesos en el flujo de negocio desde el punto en el que se encuentran

¿Cómo funciona?

Este activo está compuesto por un conjunto de flujos desarrollados en el módulo FlowEngine, y para su funcionamiento se necesitan varias entidades creadas en plataforma que permiten trazar el estado de la ejecución en curso, así como un log de las ejecuciones realizadas.

...

En este caso continuará en el primer proceso y/o operación que se encuentre en las entidades de estado (process_status y operation_status) con estado de ERROR. Si el usuario quiere dar como OK la operación que ha fallado para que la ejecución continúe en el siguiente paso, únicamente deberá actualizar el estado de esa operación en la entidad operation_status a OK, y relanzar la ejecución manualmente desde el Flow Engine.

Visualización del estado

Para realizar un seguimiento de las ejecuciones se dispone de un dashboard creado en plataforma en el que dada una fecha se podrá visualizar tanto el log como el estado de la ejecución:

...

Configuración

El planificador tiene una serie de variables globales que permiten la configuración de las ontologías base, así como el tipo de query que utiliza internamente y el tipo de query de borrado.

...

• queryType: tipo de query que utiliza el orquestador (SQL | NATIVE)

• processes_ontology: nombre de la ontología processes

• process_dependencies_ontology: nombre de la ontología process_dependencies

• process_status_ontology: nombre de la ontología process_status

• operation_status_ontology: nombre de la ontología operation_status

• process_log_ontology: nombre de ontología process_log

• deleteQueryType: tipo de query de borrado (SQL | NATIVE)

• dataflowTimeout: timeout para la ejecución de dataflows

• notebookTimeout: timeout para la ejecución de noteboks

• apiKey: api key necesario para la ejecución de las operaciones, esta debe pertenecer a un usuario que tenga permisos sobre las ontologías del orquestador, así como a las operaciones que se vayan a ejecutar.

Consideraciones

Al tratarse de un activo desarrollado sobre plataforma es fácilmente extensible, por lo que se podrían añadir por ejemplo más tipos de operaciones de manera sencilla realizando un pequeño desarrollo en el FlowEngine, o simplemente enriquecer la lógica del planificador según necesidad.

...