...
| Table of Contents |
|---|
INTRODUCCIÓN
...
Introducción
En este trimestre se ha desarrollado una prueba de concepto de cómo se puede trabajar con los componentes dataflow, flow engine, entidades virtuales, apis,… de la plataforma Onesaitplatform para de forma muy sencilla parar generar expedientes bancarios para distintas entidades a partir de los datos obtenidos
invocando un servicio rest.
Esto lo realizaremos con un enfoque low code, ya que todo se creará a partir de diagramas, flujos , editores y formularios desde el Controlpanel de la Onesait platform, esta construida sobre el laboratorio
https://lab.onesaitplatform.com/controlpanel
Continuando con el demostrador, el flujo Servicio REST.
En el demostrador se han usado el Dataflow, Flow Engine, entidades virtuales, APIs y Dashboards de la plataforma.
La demo se ha disponibilizado en el CloudLab de Plataforma.
Flujo del demostrador
En el diagrama se muestra el flujo del sistema:
...
El DataFlow de ingesta invocar a las APIS REST del Banco para hacer la ingesta y luego validará los datos entrantes de distintas formas, por ejemplo
...
comprobando si algún parámetro necesario no está relleno o validando valores de la entrada contra Entidades de Control.
Tras realizar las validaciones,
...
los registros validos serán redireccionados a los distintos subflujos de inserción en función
...
del tipo de dato recuperado.
Estos datos se completan y finalmente se almacenan en la Entidad de plataforma que aplique.
Los expedientes descartados se almacenan en una entidad, con un campo error que indica porque no se han podido insertar.
Finalmente, los resultados del registro de expedientes pueden verse en
...
una aplicación web que
...
Aquí os ponemos un diagrama, mostrando el sistema.
...
¿Qué se está haciendo?
incluye un dashboard.
En detalle
En primer lugar tenemos una api rest de un banco, un API REST la cual nos proporciona la información necesaria para generar los distintos expedientes.
Arranque del proceso
Para la demo tenemos un Flow del FlowEngine ("startexpedientsingest") que inicia el proceso de forma manual , aun que lo podíamos hacer con un nodo cron y hacerlo temporizado cada cierto tiempoinvocando al DataFlow de ingesta.
...
En este punto hemos lanzado la ejecución, Al ejecutar se comprueba el estado del dataflow principal si es viable DataFlow y se lanza.
...
...
Ingesta y proceso de los datos
En el flujo principal DataFlow de ingesta se invoca al api rest de un banco y API REST que nos trae la información para la demo. Son registros con cientos de campos donde unos cumplen los requisitos para convertirse en expedientes y otros no y terminan almacenándose junto al error en la entidad expedientexpediente_error
En el diagrama vemos un componente :
...
Este módulo actúa como el Bus o Broker de la plataforma. Ofrece conectores en diferentes tecnologías como Kafka, MQTT, REST, WebSockets, AMQP,… permitiendo que los diferentes clientes (sistemas y dispositivos) puedan comunicar con la plataforma de forma eficiente, en el siguiente enlace tenemos más informción sobre él.
https://onesaitplatform-es.refined.site/space/DOC/2215907410/Un+Vistazo+al+Digital+Broker
En este componente del flujo principal se está haciendo una validación de cada registro contra una entidad virtual, comprobando si existe el tipo de interviniente usado en el expediente en esta entidad virtual que es un catálogo de tipos de intervinientes, esto lo hacemos simplemente añadiendo una caja al flujo y mapeando el campo del registro y el de la tabla
...
Con esto se da más flexibilidad ya que si se añadiese una nueva entidad, tan sólo habría que añadir un nuevo subflujo y añadiéndolo a la salida del flujo principal.No tendremos un flujo gigantesco con toda la funcionalidad sino que lo tendremos segmentado siendo más sostenible.
Dashboard
Finalmente se ha creado un dashboard que muestra la información sobre este proceso, es decir registros creados, errores, se puede filtrar por días,...
...