Objetivo General
Se deberá de crear un proceso de tipo Job donde se consumirá o implementará una función de Spin en la cual se procesa la información que proviene de FISERV a través de los archivos .ATPTX y la información que está persistida en SPIN a través de la colección Fiserv.transactions para después, iterar la colección de resultados y aplicar un filtrado por cada tipo de proveedor y por ende, por cada registro.
Si existe inconsistencias en los saldos entre un registro que viene de FISERV y un registro que viene de SPIN, entonces, se realizará el llamado al servicio de account-aggregation-service => sync() parasincronizar la información en el Mirror, de lo contrario, se pasará al siguiente registro.
A continuación se detalla el flujo anteriormente descrito por de medio de un Diagrama de Flujo:
Para poder realizar este proceso, debemos contar con lo siguiente del lado del cliente (Spin) para poderdesarrollar la solución propuesta:
Accesos al repositorio spin-analytics
Acceso AWS (Glue)
Acceso a las BD's en MongoDB de los proyectos de Spin Mirror Strategy