Quix Streams Release 3.14.0

QuixStreams 3.14 - The Pi Release: Concat All The Things!

Just shipped QuixStreams 3.14.0 and no, the version number wasn't an accident. Who doesn't love some math humor with their stream processing library?

The star of this release is our new `concat()` method. Now, you can smash multiple streams together without that awkward manual plumbing code. Combine orders from different regions, merge multiple sensors, or just fix that  branching logic you've been wrestling with:

‍# UK orders in GBP, German orders in EUR, but we need combined USD reporting
orders_uk = app.dataframe(topic_uk)
orders_de = app.dataframe(topic_de)‍

# Convert currencies first
orders_uk["amount_usd"] = orders_uk["amount"].apply(convert_currency("GBP", "USD"))
orders_de["amount_usd"] = orders_de["amount"].apply(convert_currency("EUR", "USD"))

# Magic happens here
orders_combined = orders_uk.concat(orders_de)

New Aggregations

We've also added new aggregations - Earliest, Latest, First, and Last.

FileSource and Other Fixes

The FileSource got some dev time, and we fixed that thing where using MongoDB with None headers would make everything explode. Plus there's a shiny new InfluxDB3Source if you're in need of one.

Under the hood, we've cleaned up a bunch of internal plumbing that you probably never noticed but we were getting stressed about, plus we bumped a bunch of dependencies to take advantage of improved security and whatever.

‍

Check out the full release notes if you want all the details!