Explore three end-to-end pipes — from on-chain data to ClickHouse-ready insights
ds
abstracting away the details of data retrieval and transformation. Its definition is somewhat long but straightforward.
Eventually we will have a library of reusable components such as the TransferPreBalancesStream
class that implements common raw data processing subtasks (such as fetching and decoding all DEx swaps from major Solana exchanges).
And that’s it for the pipes’ architecture explanation! You can now explore these three end-to-end pipelines with more real world utility than this little demo.