Not an exact match, but https://github.com/soketi/soketi might work for your needs (API-compatible with https://pusher.com )

I've wrote one, but it's not public/production-ready yet. Built on top of clickhouse as well.

Basically pipe is just a collection of WITH statements with some template processing.