This blog post is for those folks comfortable with creating a data stream from an IEnumerable, IObservable or StreamInsight adapter data source.  If you’d like more details on creating those, have a look at this blog post , which covers creating an IEnumerable ‘canned’ data source then wrapping...

Following on the heels of my last query pattern blog post, I started to dig into creating a custom data context for use with StreamInsight and LINQPad.  The default contexts supplied out of box with the StreamInsight driver (including the Hitchhiker’s Guide context) are great, but don’t contain...

Process data, commonly accessed from OPC or a process historian such as OSIsoft PI, is well suited for analysis using StreamInsight – being time-series data with data values from a range of sensors. In this post, I’ll walk through a couple of simple patterns for working with process data...

The LINQPad driver for StreamInsight provides an awesomely easy way to run StreamInsight queries using easily accessible data contexts of temporal streams. However, as LINQPad only supports a single active data context connection in a query it can be difficult to use one of the hard to read “without...

Occasionally, when working with StreamInsight queries an unusual result will crop up, leading to asking the rather blunt question “where did that come from?”. Luckily the StreamInsight Event Flow Debugger has a great feature ( Root Cause Analysis ) that will let us examine how certain results...

Been tied up with PASS for the past (pun intended) couple of weeks, so it’s time to get a bit caught up on writing.  One of the key technical features of StreamInsight is the ability for one query to consume the output of another, enabling the system to avoid having to process events twice, and...

This is a question that has come up in a few customer engagements, and on several forum posts – how do I find the top category in a stream for a given group?  Several examples of this pattern of question are: Given a stream of Product View events from a website, each containing a user id and product...

Another little LINQ error you might encounter from time to time. Ran into this yesterday while building out some queries, and figured it was worth a quick post. Starting with a basic stream, I needed to group by a set of fields in the stream and calculate some basic aggregates. Code Snippet...

The StreamInsight dev team has just released the next version of StreamInsight (version 1.1)!!  New features in this release include: .NET Sequences - no more custom adapters for common .NET data sources.  Using .NET sequences instead of adapters as event sources and sinks, which makes the...

This is a pretty obscure one, and a nice short snippet of a blog post.  I ran into this error yesterday while building out some StreamInsight applications for real time web analytics, and was very briefly stumped.  Let’s have a quick peek at how I ran into it. Starting with a working query...

StreamInsight has a very powerful management service that is fully available to developers and administrators alike. Any technique that you see in the Event Flow Debugger or in the API can be remotely invoked via the Management Service . This enables all sorts of tasks and scenarios, such as remotely...

Using reference data in StreamInsight is a very common scenarios; some examples would be: Monitoring process control event streams for values that exceed a given threshold (for example, a valve’s pressure exceeding a certain safety threshold). Enriching utility usage information in a smart metering scenario...

One of the common tasks in StreamInsight is to use a reference stream to integrate metadata or reference data from a relatively static source (such as a SQL Server table – a walkthrough of this technique will be described in an upcoming blog post).  One of the challenges in integrating the reference...

Following in the great tradition of other learn through example LINQ example pages, such as 101 LINQ Samples , here’s the first in a series of posts on StreamInsight query examples. This will first show up on this blog, then get migrated over to a centralized site on the StreamInsight developer...