Background

The EU’s Central Electronic System of Payment information (CESOP) requires payment service providers to report cross-border transaction data quarterly. At Walletto, the original process was entirely manual: analysts extracted raw transaction data, reconciled it across multiple source systems, formatted it to the regulatory schema, and submitted it — a cycle that consumed roughly three working days every quarter.

What I built

I designed and delivered an automated pipeline that:

1. Extracts transaction data from the core ledger via a scheduled Airflow DAG
2. Transforms it through a KNIME workflow that applies the CESOP validation rules and XML schema
3. Validates the output against the regulatory specification and flags anomalies in a Power BI dashboard
4. Packages the final XML submission artefact ready for upload

Outcome

• Submission cycle reduced from ~3 days to under 2 hours
• Zero manual reconciliation errors in the first four submission cycles
• Compliance team gained full visibility via the Power BI dashboard, allowing self-service status checks without engineering involvement

Stack rationale

KNIME was chosen because the compliance team already used it for ad-hoc data work — lowering the handover burden and making future maintenance accessible without Python knowledge. Airflow handled orchestration since it was already in the data platform stack.