Azure Stream Analytics documentation

About Azure Stream Analytics

Overview

• What is Azure Stream Analytics?
• Azure Stream Analytics solution patterns

Quickstart

• Create a job with Azure portal
• Analyze fraudulent call data and visualize results

Concept

• Choose a streaming analytics technology

Connect a job to a data source

Overview

• Learn about input types

Concept

• Stream input data
• Join reference data for lookups

How-To Guide

• Troubleshoot input connections
• Process Apache Kafka for Event Hubs events
• Process data from Azure Event Hubs

Send data to an output sink

Overview

• Learn about output types

Concept

• Output to Azure Cosmos DB
• Output to Azure SQL Database
• Custom blob output partitioning
• Output error handling policies

How-To Guide

• Troubleshoot output connections

Monitor and troubleshoot your job

How-To Guide

• Monitor and manage jobs using Azure portal
• Analyze job performance using job metrics and dimensions
• Troubleshoot using resource logs
• Troubleshoot data errors

Review temporal concepts

Concept

• Common query patterns
• Understand time handling in Stream Analytics
• Internal checkpoint and replay

Transform data with Stream Analytics queries

Concept

• Introduction to windowing functions
• Introduction to geospatial functions
• Parse JSON and Avro data

How-To Guide

• Troubleshoot query logic
• Write JavaScript user-defined aggregates

Tutorial

• Run a JavaScript user-defined function

Analyze with machine learning

How-To Guide

• Use machine learning to detect anomalies
• Perform sentiment analysis with Machine Learning Studio (classic)
• Scale jobs with Machine Learning Studio (classic) functions

Try Stream Analytics tutorials and solutions

Tutorial

• Real-time fraud detection
• Trigger an Azure Function

How-To Guide

• Build solutions with geofencing and geospatial aggregation
• Run jobs on IoT Edge
• Build an IoT solution
• High-frequency trading simulation
• Alert based on adjustable rule thresholds

Deploy Stream Analytics jobs

How-To Guide

• Use REST APIs to set up CI/CD for IoT Edge jobs

Scale Stream Analytics jobs

How-To Guide

• Scale with streaming units
• Scale with query parallelization
• Scale jobs to increase throughput
• Optimize processing by repartitioning