Was ist Azure Stream Analytics?What is Azure Stream Analytics?

Azure Stream Analytics ist eine Engine für Analysen in Echtzeit und die Verarbeitung komplexer Ereignisse, die entwickelt wurde, um große Mengen schneller Streamingdaten aus mehreren Quellen gleichzeitig zu analysieren und zu verarbeiten.Azure Stream Analytics is a real-time analytics and complex event-processing engine that is designed to analyze and process high volumes of fast streaming data from multiple sources simultaneously. In Informationen aus einer Reihe von Eingabequellen wie Geräten, Sensoren, Clickstreams, Feeds sozialer Medien und Anwendungen können Muster und Beziehungen identifiziert werden.Patterns and relationships can be identified in information extracted from a number of input sources including devices, sensors, clickstreams, social media feeds, and applications. Diese Muster können verwendet werden, Aktionen und Workflows wie das Erstellen von Warnungen, Senden von Informationen per Feed an ein Berichterstellungstool oder Speichern transformierter Informationen zur späteren Verwendung auszulösen.These patterns can be used to trigger actions and initiate workflows such creating alerts, feeding information to a reporting tool, or storing transformed data for later use. Außerdem ist Stream Analytics in der Azure IoT Edge-Laufzeit verfügbar und unterstützt genau die gleiche Sprache bzw. Syntax wie die Cloud.Also, Stream Analytics is available on Azure IoT Edge runtime, and supports the same exact language or syntax as cloud.

Die folgenden Szenarien sind Beispiele für Situationen, in denen Azure Stream Analytics verwenden werden kann:The following scenarios are examples of when you can use Azure Stream Analytics:

  • Analysieren von Telemetriedatenströmen von IoT-Geräten in EchtzeitAnalyze real-time telemetry streams from IoT devices
  • Analyse von Webprotokollen/ClickstreamsWeb logs/clickstream analytics
  • Geoanalysen für das Flottenmanagement und fahrerlose FahrzeugeGeospatial analytics for fleet management and driverless vehicles
  • Remoteüberwachung und Predictive Maintenance für Objekte mit hohem WertRemote monitoring and predictive maintenance of high value assets
  • Echtzeitanalysen von POS-Daten (Point of Sale) für die Bestandskontrolle und AnomalieerkennungReal-time analytics on Point of Sale data for inventory control and anomaly detection

Funktionsweise von Stream AnalyticsHow does Stream Analytics work?

Ein Azure Stream Analytics-Auftrag besteht aus einer Eingabe, Abfrage und Ausgabe.An Azure Stream Analytics job consists of an input, query, and an output. Stream Analytics erfasst Daten aus Azure Event Hubs, Azure IoT Hub oder Azure Blob Storage.Stream Analytics ingests data from Azure Event Hubs, Azure IoT Hub, or Azure Blob Storage. Mit der Abfrage, die auf SQL (Structured Query Language) basiert, können Streamingdaten über einen bestimmten Zeitraum einfach gefiltert, sortiert, aggregiert und verknüpft werden.The query, which is based on SQL query language, can be used to easily filter, sort, aggregate, and join streaming data over a period of time. Sie können diese SQL-Sprache auch mit JavaScript und benutzerdefinierten C#-Funktionen (UDFs) erweitern.You can also extend this SQL language with JavaScript and C# user defined functions (UDFs). Sie können die Optionen für die Ereignisreihenfolge und die Dauer der Zeitfenster bei der Durchführung von Aggregationsvorgängen mithilfe einfacher Sprachkonstrukte und/oder Konfigurationen einfach anpassen.You can easily adjust the event ordering options and duration of time windows when preforming aggregation operations through simple language constructs and/or configurations.

Zu jedem Auftrag gehört eine Ausgabe für die transformierten Daten. Sie können die Reaktion auf die analysierten Informationen steuern.Each job has an output for the transformed data, and you can control what happens in response to the information you've analyzed. Sie haben beispielsweise folgende Möglichkeiten:For example, you can:

  • Senden von Daten an Dienste wie Azure Functions, Service Bus Topics oder Queues, um Kommunikation oder benutzerdefinierte Workflows nachgelagert auszulösen.Send data to services such as Azure Functions, Service Bus Topics or Queues to trigger communications or custom workflows downstream.
  • Senden von Daten an ein Power BI-Dashboard für die EchtzeitvisualisierungSend data to a Power BI dashboard for real-time dashboarding.
  • Speichern von Daten in anderen Azure Storage-Diensten zum Trainieren eines Machine Learning-Modells basierend auf Verlaufsdaten oder zum Durchführen von Batchanalysen.Store data in other Azure storage services to train a machine learning model based on historical data or perform batch analytics.

In der folgenden Abbildung ist zu sehen, wie Daten an Stream Analytics gesendet, analysiert und für andere Aktionen wie Speicherung oder Darstellung weitergeleitet werden:The following image shows how data is sent to Stream Analytics, analyzed, and sent for other actions like storage or presentation:

Stream Analytics-Einführung zur Pipeline

Wichtige Funktionen und VorteileKey capabilities and benefits

Azure Stream Analytics ist benutzerfreundlich, flexibel, zuverlässig und auf jede Auftragsgröße skalierbar.Azure Stream Analytics is designed to be easy to use, flexible, reliable, and scalable to any job size. Dieses Modul steht übergreifend für mehrere Azure-Regionen zur Verfügung.It is available across multiple Azure regions. In der folgenden Abbildung sind die wichtigsten Funktionen von Azure Stream Analytics dargestellt:The following image illustrates the key capabilities of Azure Stream Analytics:

Wichtige Funktionen von Stream Analytics

Einfacher EinstiegEase of getting started

Der Einstieg in Azure Stream Analytics ist einfach.Azure Stream Analytics is easy to start. Es sind nur wenige Klicks erforderlich, um eine Verbindung mit mehreren Quellen oder Senken herzustellen und so eine End-to-End-Pipeline zu erstellen.It only takes a few clicks to connect to multiple sources and sinks, creating an end-to-end pipeline. Stream Analytics kann Verbindungen mit Azure Event Hubs und Azure IoT Hub zur Datenstromerfassung und mit Azure Blob Storage zur Erfassung von Verlaufsdaten herstellen.Stream Analytics can connect to Azure Event Hubs and Azure IoT Hub for streaming data ingestion, as well as Azure Blob storage to ingest historical data. Die Auftragseingabe kann auch statische oder langsam veränderliche Referenzdaten von Azure Blob Storage oder SQL-Datenbank enthalten, die Sie mit Streamingdaten verknüpfen können, um Suchvorgänge durchzuführen.Job input can also include static or slow-changing reference data from Azure Blob storage or SQL Database that you can join to streaming data to perform lookup operations.

Stream Analytics kann Auftragsausgaben an viele Speichersysteme leiten, z.B. Azure Blob Storage, Azure SQL-Datenbank, Azure Data Lake Storage und Azure Cosmos DB.Stream Analytics can route job output to many storage systems such as Azure Blob storage, Azure SQL Database, Azure Data Lake Store, and Azure CosmosDB. Sie können Batchanalysen für gespeicherte Ausgaben mit Azure HDInsight ausführen oder die Ausgabe an einen anderen Dienst senden, z. B. Event Hubs zur Verarbeitung oder Power BI für Echtzeitvisualisierungen.You can run batch analytics on stored output with Azure HDInsight, or you can send the output to another service, like Event Hubs for consumption or Power BI for real-time visualization.

Die gesamte Liste von Stream Analytics-Ausgaben finden Sie unter Grundlegendes zu den Ausgaben von Azure Stream Analytics.For the entire list of Stream Analytics outputs, see Understand outputs from Azure Stream Analytics.

Produktivität der ProgrammiererProgrammer productivity

Azure Stream Analytics verwendet eine einfache SQL-basierte Abfragesprache, die mit leistungsstarken zeitlichen Einschränkungen versehen wurde, um Daten während der Übertragung zu analysieren.Azure Stream Analytics uses a simple SQL-based query language that has been augmented with powerful temporal constraints to analyze data in motion. Zum Definieren von Auftragstransformationen verwenden Sie eine einfache, deklarative Stream Analytics-Abfragesprache, mit der Sie komplexe temporale Abfragen und Analysen mithilfe von einfachen SQL-Konstrukten erstellen können.To define job transformations, you use a simple, declarative Stream Analytics query language that lets you author complex temporal queries and analytics using simple SQL constructs. Da die Stream Analytics-Abfragesprache mit der SQL-Sprache konsistent ist, genügt die Vertrautheit mit SQL zum Erstellen von Aufträgen.Because Stream Analytics query language is consistent to the SQL language, familiarity with SQL is sufficient to start creating jobs. Sie können Aufträge auch mit Entwicklertools wie Azure PowerShell, Stream Analytics Visual Studio-Tools, der Visual Studio Code-Erweiterung für Stream Analytics oder Azure Resource Manager-Vorlagen erstellen.You can also create jobs by using developer tools like Azure PowerShell, Stream Analytics Visual Studio tools, the Stream Analytics Visual Studio Code extension, or Azure Resource Manager templates. Die Nutzung von Entwicklertools ermöglicht Ihnen die Offlineentwicklung von Transformationsabfragen und die Verwendung der CI/CD-Pipeline zum Übermitteln von Aufträgen an Azure.Using developer tools allow you to develop transformation queries offline and use the CI/CD pipeline to submit jobs to Azure.

Die Stream Analytics-Abfragesprache verfügt über viele verschiedene Funktionen zum Analysieren und Verarbeiten von Streamingdaten.The Stream Analytics query language offers a wide array of functions for analyzing and processing streaming data. Diese Abfragesprache unterstützt die einfache Datenbearbeitung, Aggregationsfunktionen und komplexe geografische Funktionen.This query language supports simple data manipulation, aggregation functions, and complex geospatial functions. Sie können Abfragen im Portal bearbeiten und anhand von Stichprobendaten testen, die aus einem Livestream extrahiert werden.You can edit queries in the portal and test them using sample data that is extracted from a live stream.

Sie können die Funktionen der Abfragesprache erweitern, indem Sie zusätzliche Funktionen definieren und aufrufen.You can extend the capabilities of the query language by defining and invoking additional functions. Sie können Funktionsaufrufe in Azure Machine Learning definieren, um Azure Machine Learning-Lösungen zu nutzen, und benutzerdefinierte JavaScript- oder C#-Funktionen oder benutzerdefinierte Aggregate integrieren, um im Rahmen einer Stream Analytics-Abfrage komplexe Berechnungen durchzuführen.You can define function calls in the Azure Machine Learning to take advantage of Azure Machine Learning solutions, and integrate JavaScript or C# user-defined functions (UDFs) or user-defined aggregates to perform complex calculations as part a Stream Analytics query.

Vollständige VerwaltungFully managed

Azure Stream Analytics ist ein vollständig verwaltetes serverloses Angebot (PaaS) in Azure.Azure Stream Analytics is a fully managed serverless (PaaS) offering on Azure. Sie müssen zum Ausführen Ihrer Aufträge keine Hardware bereitstellen und keine Cluster verwalten.You don’t have to provision any hardware or manage clusters to run your jobs. Azure Stream Analytics übernimmt die gesamte Verwaltung Ihres Auftrags, indem komplexe Computecluster in der Cloud eingerichtet werden und die erforderliche Leistungsoptimierung für die Ausführung des Auftrags durchgeführt wird.Azure Stream Analytics fully manages your job by setting up complex compute clusters in the cloud and taking care of the performance tuning necessary to run the job. Die Integration von Azure Event Hubs und Azure IoT Hub macht es möglich, dass Aufträge Millionen von Ereignissen pro Sekunde erfassen, die von verbundenen Geräten, aus Clickstreams oder aus Protokolldateien stammen.Integration with Azure Event Hubs and Azure IoT Hub allows your job to ingest millions of events per second coming from a number of sources, to include connected devices, clickstreams, and log files. Indem Sie die Partitionierungsfunktion von Event Hubs verwenden, können Sie Berechnungen in logische Schritte partitionieren, die bei Bedarf jeweils weiter partitioniert werden können, um die Skalierbarkeit zu erhöhen.Using the partitioning feature of Event Hubs, you can partition computations into logical steps, each with the ability to be further partitioned to increase scalability.

Ausführung in der Cloud oder im Intelligent Edge-BereichRun in the cloud or on the intelligent edge

Für umfangreiche Analysen kann Azure Stream Analytics in der Cloud ausgeführt werden, und für Analysen mit sehr niedriger Latenz ist die Ausführung auf IoT Edge möglich.Azure Stream Analytics can run in the cloud, for large-scale analytics, or run on IoT Edge for ultra-low latency analytics. Für Azure Stream Analytics wird für die Cloud und den Edge die gleiche Abfragesprache genutzt, sodass Entwickler echte Hybridarchitekturen für die Datenstromverarbeitung erstellen können.Azure Stream Analytics uses the same query language on both cloud and the edge, enabling developers to build truly hybrid architectures for stream processing.

Niedrige GesamtkostenLow total cost of ownership

Stream Analytics ist ein kostenoptimierter Clouddienst.As a cloud service, Stream Analytics is optimized for cost. Es fallen keine Anfangskosten an. Sie bezahlen nur für die verbrauchten Streamingeinheiten und die verarbeitete Datenmenge.There are no upfront costs involved - you only pay for the streaming units you consume, and the amount of data processed. Es sind keine Mindestabnahme und keine Clusterbereitstellungen erforderlich, und Sie können den Auftrag basierend auf Ihren Geschäftsanforderungen hoch- oder herunterskalieren.There is no commitment or cluster provisioning required, and you can scale the job up or down based on your business needs.

Geeignet für unternehmenskritische WorkloadsMission-critical ready

Azure Stream Analytics ist in mehreren Regionen auf der ganzen Welt verfügbar und dank seiner Zuverlässigkeit, Sicherheit und Compliance für die Ausführung unternehmenskritischer Workloads geeignet.Azure Stream Analytics is available across multiple regions worldwide and is designed to run mission-critical workloads by supporting reliability, security and compliance requirements.

ZuverlässigkeitReliability

Für Azure Stream Analytics wird die Exactly-Once-Ereignisverarbeitung (genau einmal) und die At-Least-Once-Zustellung (mindestens einmal) von Ereignissen garantiert, sodass Ereignisse niemals verloren gehen.Azure Stream Analytics guarantees exactly-once event processing and at-least-once delivery of events, so events are never lost. Die Exactly-Once-Verarbeitung wird mit ausgewählter Ausgabe garantiert, wie unter Event Delivery Guarantees (Azure Stream Analytics) (Garantien zur Ereignisbereitstellung (Azure Stream Analytics)) beschrieben.Exactly-once processing is guaranteed with selected output as described in Event Delivery Guarantees.

Azure Stream Analytics verfügt über integrierte Wiederherstellungsfunktionen für den Fall, dass für ein Ereignis ein Fehler auftritt.Azure Stream Analytics has built-in recovery capabilities in case the delivery of an event fails. Stream Analytics verfügt außerdem über integrierte Prüfpunkte, um den Zustand Ihres Auftrags aufrecht zu erhalten und wiederholbare Ergebnisse zu liefern.Stream Analytics also provides built-in checkpoints to maintain the state of your job and provides repeatable results.

Als verwalteter Dienst wird für Stream Analytics eine Ereignisverarbeitung mit einer Verfügbarkeit von 99,9 % (minutengenau) garantiert.As a managed service, Stream Analytics guarantees event processing with a 99.9% availability at a minute level of granularity. Weitere Informationen finden Sie auf der Seite SLA für Stream Analytics.For more information, see the Stream Analytics SLA page.

SicherheitSecurity

Azure Stream Analytics verschlüsselt jegliche ein- und ausgehende Kommunikation und unterstützt TLS 1.2.In terms of security, Azure Stream Analytics encrypts all incoming and outgoing communications and supports TLS 1.2. Integrierte Prüfpunkte werden ebenfalls verschlüsselt.Built-in checkpoints are also encrypted. Die eingehenden Daten werden von Stream Analytics nicht gespeichert, da die gesamte Verarbeitung im Arbeitsspeicher stattfindet.Stream Analytics doesn't store the incoming data since all processing is done in-memory.

ComplianceCompliance

Azure Stream Analytics erfüllt die Anforderungen mehrerer Compliancezertifizierungen, wie in der Übersicht über die Azure-Compliance beschrieben.Azure Stream Analytics follows multiple compliance certifications as described in the overview of Azure compliance.

LeistungPerformance

Stream Analytics kann pro Sekunde Millionen von Ereignissen verarbeiten und Ergebnisse mit äußerst kurzer Wartezeit liefern.Stream Analytics can process millions of events every second and it can deliver results with ultra low latencies. Sie können vertikal und horizontal hochskalieren, um große Echtzeitanwendungen und komplexe Anwendungen für die Ereignisverarbeitung zu nutzen.It allows you to scale-up and scale-out to handle large real-time and complex event processing applications. Stream Analytics unterstützt eine höhere Leistung mittels Partitionierung, damit komplexe Abfragen parallelisiert und auf mehreren Streamingknoten ausgeführt werden können.Stream Analytics supports higher performance by partitioning, allowing complex queries to be parallelized and executed on multiple streaming nodes. Azure Stream Analytics basiert auf Trill, einem Hochleistungsanalysemodul für In-Memory-Streaming, das in Zusammenarbeit mit der Forschungsabteilung von Microsoft entwickelt wurde.Azure Stream Analytics is built on Trill, a high-performance in-memory streaming analytics engine developed in collaboration with Microsoft Research.

Nächste SchritteNext steps

Sie haben einen Überblick über Azure Stream Analytics erhalten.You now have an overview of Azure Stream Analytics. Nun können Sie tiefer einsteigen und Ihren ersten Stream Analytics-Auftrag erstellen:Next, you can dive deep and create your first Stream Analytics job: