chuckblake

We've added a filtering capability to our decoders and fixed an issue which now ensures that parallel stateless computations always run independently.

We’ve been hard at work in Wallaroo Labs-ville with a whole slew of features & bug fixes just to help you succeed with Wallaroo! We’ve added support for dynamic keys -- now you aren’t required to pre-define your partition keys when you’re writing your app! Let us do the heavy lifting for you!

Wallaroo is a modern stream processing framework that makes it easy to get stateful, event-driven applications to production regardless of scale. This post talks about the Wallaroo Python API and how you can use it to define all of the sources, sinks, and computations necessary for you to implement your event-driven application.

In this example, we build an Adtech use case where Wallaroo is used to join several event streams to determine if the user taking action is a “loyal customer,” and should receive a promotional discount. Includes walkthrough and working example code.

Distributed Stream Processing