Read and aggregate messages from the Bluesky firehose. Use Kaskada to connect in real-time and parse messages as part of the query.