Official blog of the development team of StreamInsight.
The wait is over—we are pleased to announce the release of StreamInsight 2.1. Since the release of version 1.2, we have heard your feedbacks and suggestions and based on that we have come up with a whole new set of features. Here are some of the highlights:
Here is how simple coding can be with the 2.1 Programming Model:
static void Main(string args)
using (Server server = Server.Create("Default"))
// Create an app
Application app = server.CreateApplication("app");
// Define a simple observable which generates an integer every second
var source = app.DefineObservable(() =>
// Define a sink.
var sink = app.DefineObserver(() =>
Observer.Create<long>(x => Console.WriteLine(x)));
// Define a query to filter the events
var query = from e in source
where e % 2 == 0
// Bind the query to the sink and create a runnable process
using (IDisposable proc = query.Bind(sink).Run("MyProcess"))
Console.WriteLine("Press a key to dispose the process...");
That’s how easily you can define a source, sink and compose a query and run it. Note that we did not replace the existing APIs, they co-exist with the new surface.
Stay tuned, you will see a series of articles coming out over the next few weeks about the new features and how to use them.
Come and grab it from our download center page and let us know what you think! You can find the updated MSDN documentation here, and we would appreciate if you could provide feedback to the docs as well—best via email to firstname.lastname@example.org.
Moreover, we updated our samples to demonstrate the new programming surface.
Regards, The StreamInsight Team
Does this version have better support for Windows Azure?
Rick, what kind of improved support are you looking for? How do you want to use StreamInsight in Azure?