Co to jest usługa Azure Stream Analytics?What is Azure Stream Analytics?

Azure Stream Analytics to analiza i skomplikowany aparat przetwarzania zdarzeń w czasie rzeczywistym, który służy do analizowania i przetwarzania dużych ilości danych szybkiego przesyłania strumieniowego z wielu źródeł jednocześnie.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. Wzorce i relacje można zidentyfikować w informacjach wyodrębnionych z różnych źródeł danych wejściowych, w tym na urządzeniach, czujników, strumieni kliknięć, źródłach mediów społecznościowych i aplikacjach.Patterns and relationships can be identified in information extracted from a number of input sources including devices, sensors, clickstreams, social media feeds, and applications. Wzorce te mogą służyć do wyzwalania akcji i inicjowania przepływów pracy, takich jak tworzenie alertów, podawanie informacji do narzędzia do raportowania lub przechowywanie przekształconych danych do późniejszego użycia.These patterns can be used to trigger actions and initiate workflows such as creating alerts, feeding information to a reporting tool, or storing transformed data for later use. Ponadto Stream Analytics jest dostępna w środowisku uruchomieniowym Azure IoT Edge, co umożliwia przetwarzanie danych na urządzeniach IoT.Also, Stream Analytics is available on Azure IoT Edge runtime, enabling to process data on IoT devices.

Poniżej przedstawiono przykładowe scenariusze, w których można użyć Azure Stream Analytics:The following scenarios are examples of when you can use Azure Stream Analytics:

  • Analizowanie strumieni telemetrycznych w czasie rzeczywistym z urządzeń IoTAnalyze real-time telemetry streams from IoT devices
  • Analiza strumienia kliknięć w internecie oraz analiza dzienników internetowychWeb logs/clickstream analytics
  • Geoprzestrzenna analiza na potrzeby zarządzania flotą i korzystania z pojazdów nie wymagających kierowcyGeospatial analytics for fleet management and driverless vehicles
  • Zdalne monitorowanie i konserwacja predykcyjna zasobów o wysokiej wartościRemote monitoring and predictive maintenance of high value assets
  • Analiza danych punktu sprzedaży w czasie rzeczywistym na potrzeby kontroli zapasów i wykrywania anomaliiReal-time analytics on Point of Sale data for inventory control and anomaly detection

Jak działa usługa Stream Analytics?How does Stream Analytics work?

Zadanie Azure Stream Analytics składa się z danych wejściowych, zapytań i danych wyjściowych.An Azure Stream Analytics job consists of an input, query, and an output. Stream Analytics pobiera dane z usługi Azure Event Hubs (w tym Azure Event Hubs z Apache Kafka), Azure IoT Hub lub Azure Blob Storage.Stream Analytics ingests data from Azure Event Hubs (including Azure Event Hubs from Apache Kafka), Azure IoT Hub, or Azure Blob Storage. Zapytanie, które jest oparte na języku zapytań SQL, może służyć do łatwego filtrowania, sortowania, agregowania i przyłączania danych przesyłanych strumieniowo w określonym czasie.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. Możesz również zwiększyć ten język SQL za pomocą języka JavaScript i funkcji zdefiniowanych przez użytkownika w języku C# (UDF).You can also extend this SQL language with JavaScript and C# user defined functions (UDFs). Można łatwo dostosować opcje porządkowania zdarzeń i czas trwania okien czasu podczas preprezentowania operacji agregacji za pomocą prostych konstrukcji językowych i/lub konfiguracji.You can easily adjust the event ordering options and duration of time windows when preforming aggregation operations through simple language constructs and/or configurations.

Każde zadanie ma jedno lub kilka danych wyjściowych dla przekształconych danych i pozwala kontrolować, co dzieje się w odpowiedzi na informacje, które zostały przeanalizowane.Each job has one or several outputs for the transformed data, and you can control what happens in response to the information you've analyzed. Możesz na przykład:For example, you can:

  • Wyślij dane do usług, takich jak Azure Functions, Service Bus tematy lub kolejki, aby wyzwolić komunikację lub niestandardowe przepływy pracy.Send data to services such as Azure Functions, Service Bus Topics or Queues to trigger communications or custom workflows downstream.
  • Wyślij dane do pulpitu nawigacyjnego Power BI, aby uzyskać pulpit nawigacyjny w czasie rzeczywistym.Send data to a Power BI dashboard for real-time dashboarding.
  • Przechowuj dane w innych usługach Azure Storage (np. Azure Data Lake, Azure Synapse Analytics itp.) w celu uczenia modelu uczenia maszynowego na podstawie danych historycznych lub wykonywania analizy wsadowej.Store data in other Azure storage services (e.g. Azure Data Lake, Azure Synapse Analytics, etc.) to train a machine learning model based on historical data or perform batch analytics.

Na poniższej ilustracji pokazano, jak dane są wysyłane do Stream Analytics, analizowane i wysyłane do innych akcji, takich jak magazyn czy Prezentacja:The following image shows how data is sent to Stream Analytics, analyzed, and sent for other actions like storage or presentation:

Wprowadzenie do potoku usługi Stream Analytics

Najważniejsze funkcje i korzyściKey capabilities and benefits

Usługa Stream Analytics została zaprojektowana tak, aby była łatwa w użyciu, elastyczna, niezawodna i skalowalna do dowolnej wielkości zadania.Azure Stream Analytics is designed to be easy to use, flexible, reliable, and scalable to any job size. Jest ona dostępna w wielu regionach platformy Azure.It is available across multiple Azure regions. Na poniższej ilustracji przedstawiono kluczowe możliwości Azure Stream Analytics:The following image illustrates the key capabilities of Azure Stream Analytics:

Kluczowe możliwości usługi Stream Analytics

Łatwość rozpoczynania pracyEase of getting started

Azure Stream Analytics jest łatwy do uruchomienia.Azure Stream Analytics is easy to start. Wystarczy kilka kliknięć, aby nawiązać połączenie z wieloma źródłami i ujściami, tworząc kompleksowe potoki.It only takes a few clicks to connect to multiple sources and sinks, creating an end-to-end pipeline. Stream Analytics może nawiązać połączenie z usługą azure Event Hubs i IoT Hub platformy Azure na potrzeby pozyskiwania danych przesyłanych strumieniowo oraz z usługi Azure Blob Storage w celu pozyskiwania danych historycznych.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. Dane wejściowe zadania mogą również zawierać statyczne lub wolne zmiany danych referencyjnych z usługi Azure Blob Storage lub SQL Database , które można dołączyć do danych przesyłanych strumieniowo w celu wykonania operacji wyszukiwania.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 może kierować dane wyjściowe zadań do wielu systemów magazynowych, takich jak Azure Blob Storage, Azure SQL Database, Azure Data Lake Storei Azure CosmosDB.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. Usługę Batch Analytics można uruchomić na przechowywanych danych wyjściowych za pomocą usługi Azure HDInsight lub można wysłać dane wyjściowe do innej usługi, takiej jak Event Hubs do użycia lub Power BI do wizualizacji w czasie rzeczywistym.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.

Aby uzyskać pełną listę Stream Analytics danych wyjściowych, zobacz Opis danych wyjściowych z Azure Stream Analytics.For the entire list of Stream Analytics outputs, see Understand outputs from Azure Stream Analytics.

Produktywność programistyProgrammer productivity

Azure Stream Analytics używa prostego języka zapytań opartego na języku SQL, który został rozszerzony o zaawansowane ograniczenia czasowe do analizowania danych w ruchu.Azure Stream Analytics uses a simple SQL-based query language that has been augmented with powerful temporal constraints to analyze data in motion. Aby zdefiniować przekształcenia zadań, należy użyć prostego, deklaratywnego języka zapytań usługi Stream Analytics, który umożliwia tworzenie złożonych zapytań czasowych i analizy przy użyciu prostych konstrukcji języka SQL.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. Ponieważ język zapytań Stream Analytics jest spójny z językiem SQL, znajomość programu SQL jest wystarczająca do rozpoczęcia tworzenia zadań.Because Stream Analytics query language is consistent to the SQL language, familiarity with SQL is sufficient to start creating jobs. Możesz również tworzyć zadania przy użyciu narzędzi programistycznych, takich jak Azure PowerShell, Stream Analytics narzędzia Visual Studio, rozszerzenia Stream Analytics Visual Studio Codelub szablony Azure Resource Manager.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. Narzędzia dla deweloperów pozwalają tworzyć zapytania przekształceń w trybie offline i używać potoków ciągłej integracji/ciągłego wdrażania w celu przesłania zadań na platformę Azure.Using developer tools allow you to develop transformation queries offline and use the CI/CD pipeline to submit jobs to Azure.

Język zapytań Stream Analytics oferuje szeroką gamę funkcji służących do analizowania i przetwarzania danych przesyłanych strumieniowo.The Stream Analytics query language offers a wide array of functions for analyzing and processing streaming data. Ten język zapytań obsługuje proste operacje manipulowania danymi, agregacja i analiza, funkcje geograficzne, Dopasowanie wzorców i wykrywanie anomalii.This query language supports simple data manipulation, aggregation and analytics functions, geospatial functions, pattern matching and anomaly detection. Można edytować zapytania w portalu i testować je przy użyciu przykładowych danych wyodrębnionych z strumienia na żywo.You can edit queries in the portal and test them using sample data that is extracted from a live stream.

Możliwości języka zapytań można rozszerzyć, definiując i wywołując dodatkowe funkcje.You can extend the capabilities of the query language by defining and invoking additional functions. Możesz definiować wywołania funkcji w Azure Machine Learning, aby skorzystać z rozwiązań Azure Machine Learning i zintegrować funkcje języka JavaScript lub języka C# zdefiniowane przez użytkownika (UDF) lub agregacje zdefiniowane przez użytkownika, aby wykonywać złożone obliczenia jako część zapytania Stream Analytics.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.

W pełni zarządzaneFully managed

Usługa Azure Stream Analytics to bezserwerowe w pełni zarządzane rozwiązanie typu „platforma jako usługa” (PaaS) platformy Azure.Azure Stream Analytics is a fully managed serverless (PaaS) offering on Azure. Nie trzeba udostępniać żadnego sprzętu, zarządzać klastrami do uruchamiania zadań lub aktualizować systemu operacyjnego lub oprogramowania.You don't have to provision any hardware, manage clusters to run your jobs, or update OS or software. Azure Stream Analytics w pełni zarządzać zadaniem, dzięki czemu możesz skupić się na logice biznesowej, a nie na infrastrukturze.Azure Stream Analytics fully manages your job, so you can focus on your business logic and not on the infrastructure.

Uruchamiaj w chmurze lub na inteligentnej granicyRun in the cloud or on the intelligent edge

Azure Stream Analytics można uruchamiać w chmurze, w przypadku analiz na dużą skalę lub działać na IoT Edge na potrzeby analizy niezwykle niskich opóźnień.Azure Stream Analytics can run in the cloud, for large-scale analytics, or run on IoT Edge for ultra-low latency analytics. Azure Stream Analytics używa tych samych narzędzi i języka zapytań zarówno w chmurze, jak i krawędzi, co umożliwia deweloperom tworzenie prawdziwie architektur hybrydowych na potrzeby przetwarzania strumieniowego.Azure Stream Analytics uses the same tools and query language on both cloud and the edge, enabling developers to build truly hybrid architectures for stream processing.

Niski całkowity koszt posiadaniaLow total cost of ownership

Jako usługa w chmurze usługa Stream Analytics jest zoptymalizowana pod kątem niskiego kosztu.As a cloud service, Stream Analytics is optimized for cost. Nie ma żadnych kosztów ponoszonych z góry — płacisz tylko za użyte jednostki przesyłania strumieniowego.There are no upfront costs involved - you only pay for the streaming units you consume. Nie jest wymagane zobowiązanie ani Inicjowanie obsługi klastrów, a zadanie można skalować w górę lub w dół zgodnie z potrzebami biznesowymi.There is no commitment or cluster provisioning required, and you can scale the job up or down based on your business needs.

Gotowość na sytuacje krytyczne dla działalności firmyMission-critical ready

Usługa Azure Stream Analytics jest dostępna w wielu regionach na całym świecie i jest przeznaczona do uruchamiania obciążeń o kluczowym znaczeniu dzięki obsłudze wymagań dotyczących niezawodności, bezpieczeństwa i zgodności.Azure Stream Analytics is available across multiple regions worldwide and is designed to run mission-critical workloads by supporting reliability, security and compliance requirements.

NiezawodnośćReliability

Poza tym usługa Azure Stream Analytics gwarantuje przeprowadzenie dokładnie jednej aprowizacji zdarzenia oraz co najmniej jednokrotnego dostarczenia zdarzeń, więc nigdy nie dochodzi do utraty zdarzeń.Azure Stream Analytics guarantees exactly-once event processing and at-least-once delivery of events, so events are never lost. Przetwarzanie dokładnie jednokrotne jest gwarantowane dla wybranych danych wyjściowych zgodnie z opisem w obszarze gwarancji dostarczania zdarzeń.Exactly-once processing is guaranteed with selected output as described in Event Delivery Guarantees.

Usługa Azure Stream Analytics ma wbudowane funkcje odzyskiwania na wypadek awarii podczas dostarczania zdarzeń.Azure Stream Analytics has built-in recovery capabilities in case the delivery of an event fails. Stream Analytics udostępnia również wbudowane punkty kontrolne do utrzymania stanu zadania i zapewniają powtarzalne wyniki.Stream Analytics also provides built-in checkpoints to maintain the state of your job and provides repeatable results.

Jako usługa zarządzana, Stream Analytics gwarantuje przetwarzanie zdarzeń o dostępności 99,9% na poziomie minuty.As a managed service, Stream Analytics guarantees event processing with a 99.9% availability at a minute level of granularity. Aby uzyskać więcej informacji, zobacz stronę umów SLA Stream Analytics .For more information, see the Stream Analytics SLA page.

ZabezpieczeniaSecurity

Z punktu widzenia zabezpieczeń usługa Azure Stream Analytics szyfruje całą komunikację przychodzącą i wychodzącą oraz obsługuje protokół TLS 1.2.In terms of security, Azure Stream Analytics encrypts all incoming and outgoing communications and supports TLS 1.2. Wbudowane punkty kontrolne również są szyfrowane.Built-in checkpoints are also encrypted. Usługa Stream Analytics nie przechowuje danych przychodzących, ponieważ całe przetwarzanie odbywa się w pamięci.Stream Analytics doesn't store the incoming data since all processing is done in-memory.

ZgodnośćCompliance

Usługa Azure Stream Analytics zapewnia dostosowanie do wielu certyfikatów zgodności, co zostało opisane w przeglądzie zgodności platformy Azure.Azure Stream Analytics follows multiple compliance certifications as described in the overview of Azure compliance.

WydajnośćPerformance

Stream Analytics może przetwarzać miliony zdarzeń co sekundę i może dostarczać wyniki przy użyciu bardzo małych opóźnień.Stream Analytics can process millions of events every second and it can deliver results with ultra low latencies. Umożliwia skalowanie w górę lub zwiększanie skali w poziomie w celu obsługi dużych aplikacji z przetwarzaniem złożonych zdarzeń oraz przetwarzaniem w czasie rzeczywistym.It allows you to scale-up and scale-out to handle large real-time and complex event processing applications. Stream Analytics obsługuje wyższą wydajność przez partycjonowanie, dzięki czemu złożone zapytania mogą być równoległe i wykonywane na wielu węzłach przesyłania strumieniowego.Stream Analytics supports higher performance by partitioning, allowing complex queries to be parallelized and executed on multiple streaming nodes. Usługa Azure Stream Analytics jest oparta na Trill, aparacie analizy przesyłania strumieniowego w pamięci o wysokiej wydajności opracowanym we współpracy z Microsoft Research.Azure Stream Analytics is built on Trill, a high-performance in-memory streaming analytics engine developed in collaboration with Microsoft Research.

Następne krokiNext steps

Masz już podstawowe informacje o usłudze Azure Stream Analytics.You now have an overview of Azure Stream Analytics. Teraz możesz utworzyć pierwsze zadanie w usłudze Stream Analytics:Next, you can dive deep and create your first Stream Analytics job: