• 3 min read

New in Stream Analytics: Output to Azure Functions, built-in anomaly detection, etc.

Today at Microsoft Ignite, we are pleased to announce the preview of several new and compelling capabilities in Azure Stream Analytics. These include built-in inline machine learning based anomaly…

Today at Microsoft Ignite, we are pleased to announce the preview of several new and compelling capabilities in Azure Stream Analytics. These include built-in inline machine learning based anomaly detection, egress to Azure functions, support for compressed data formats, JavaScript User defined aggregates, and support for CI/CD in Visual Studio tooling. These new features will start rolling out over the course of the next several weeks. If you are attending Microsoft Ignite conference this week, please attend sessions BRK3302 and BRK3303 to learn more.

Built-in Machine Learning-based anomaly detection

Built-in machine learning-based operator ‘ANOMALYDETECTION’ is designed to help customers of Azure Stream Analytics who monitor data from applications or devices in real time, and need help to easily detect events or observations that do not conform to an expected pattern.

Until now, Industrial IoT customers, and others who monitored streaming data relied on custom machine learning models. Implementers needed to have intimate familiarity with the scenarios and the problem domain. Also, integrating these models with the stream processing mechanisms required complex data pipeline engineering.

With the new capability announced today, the complexity of machine learning has been simplified to a single SQL function call to a machine learning model. The underlying general-purpose machine learning model is abstracted and continuously learns over time to match your input streams. This new functionality is targeted towards numerical time series data, and will help customers detect anomalies, positive and negative trends. You can find more information in the Anomaly Detection documentation here.

Stream Analytics

Multiple ways to use the function in Stream Analytics queries

Egress to Azure functions

Azure Functions is a ‘serverless’ compute service in Azure that helps users run code on demand without having to explicitly provision or manage infrastructure, and lets them implement code that is triggered by events occurring in Azure or third-party services. This ability of Azure Functions to respond to triggers makes it a natural output target for Azure Stream Analytics.

Many Stream Analytics customers today leverage the rich capabilities offered by Azure functions by first writing the output to service bus queues, and then accessing Azure functions from there. To provide a lot more direct integration with Azure functions, today we are announcing an output adapter to Azure Functions from Azure Stream Analytics. This output adapter is designed to allow users to connect Stream Analytics to Azure Functions, and run a script or piece of code to trigger downstream workflows and accelerate response to key events.

For example, it will now be a lot easier for developers to send out email alerts or notifications when certain pre-defined conditions such as overheating is observed on the factory floor. Developers can also author custom post processing logic that will allow Azure Stream Analytics to connect to a variety of other Azure services or apps outside the Azure ecosystem.

Output details

Support for input compression formats

Bandwidth issues and message size limitations are the key reasons why customers need support for compression input formats. Based on the growing number of requests from many of our existing and prospective customers, we are glad to announce that Azure Stream Analytics will now offer support for GZIP and Deflate streams.

Our announcement today means Azure Stream Analytics is a viable option for many customers who currently face these limitations.

Visual Studio Tooling for continuous integration and delivery

The need to manage stability of production code while promoting improvements and code updates as quickly as possible means that development teams spend a lot of time building code integration and deployment (CI/CD) processes. To better help such teams, we are rolling out native support for CI/CD from within Stream Analytics Visual Studio Tools. Customers can perform automated builds, test scripts and deploy them with the Stream Analytics Visual Studio projects using the newly released NuGet package. With this new capability, it becomes very easy to setup a continuous CI/CD pipelines for Stream Analytics jobs in the developer’s environment as well as within other automated processes.

JavaScript User Defined Aggregates

Following the release of JavaScript User defined functions mid-spring, we are now ready to offer JavaScript User Defined Aggregates (UDA). With user defined aggregates, you can run your own stateful computations like time weighted averages, cumulative density, array cumulation, and much more.

Microsoft Ignite (Sep 25th  – 29th)

Want to see these features in action? If you are at Microsoft Ignite this week, please do attend the following sessions on Tuesday. Also, please meet our team at the expo hall.

  • BRK3303 – Real-time big data analytics: Harnessing the power of now
  • BRK3302 – The future of IoT analytics: The Edge complementing the cloud

Keep the feedback and ideas coming!

Azure Stream Analytics team is highly committed to listening to your feedback and letting the user voice influence our future investments. We welcome you to join the conversation and make your voice heard via UserVoice.