I'm trying to implement real-time analytics on aggregated blockchain data. My database stores swap