Pipeline orchestration & ingestion
Orquestração & ingestão
~35 Airflow DAGs, tagged by role — download, consolidation, report, audit — with a sensor-style DAG polling state every five minutes and triggering what's ready. Three kinds of source: an RPA pipeline built on Page Object Model patterns for the administrator's portal, REST/GraphQL clients for custodian APIs, and a standalone loader package for public macro data.
~35 DAGs do Airflow, tagueadas por papel — download, consolidação, relatório, auditoria — com uma DAG estilo sensor consultando o estado a cada cinco minutos e disparando o que estiver pronto. Três tipos de fonte: um pipeline de RPA construído sobre o padrão Page Object Model para o portal da administradora, clientes REST/GraphQL para APIs custodiais, e um pacote de loaders standalone para dados macro públicos.
- Custodian REST/GraphQL endpoints for positions and cash statements.
- Endpoints REST/GraphQL custodiais de posições e demonstrativos de caixa.
- Public macro feeds (BCB, IBGE, CVM, CAGED, Tesouro) for context.
- Feeds macro públicos (BCB, IBGE, CVM, CAGED, Tesouro) para contexto.
- Selenium RPA built on Page Object Model patterns where no API exists.
- RPA com Selenium e Page Object Model onde não existe API.