Mi az az Azure Stream Analytics?What is Azure Stream Analytics?

A Azure Stream Analytics egy valós idejű elemzési és összetett eseményvezérelt motor, amely nagy mennyiségű, egyszerre több forrásból származó gyors adatfolyam-adatok elemzésére és feldolgozására szolgál.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. A minták és kapcsolatok a számos bemeneti forrásból kinyert információk, például az eszközök, érzékelők, kattintássorozatokból, közösségi média-hírcsatornák és alkalmazások alapján azonosíthatók.Patterns and relationships can be identified in information extracted from a number of input sources including devices, sensors, clickstreams, social media feeds, and applications. Ezek a minták a műveletek indításához és olyan munkafolyamatok elindításához használhatók, mint például a riasztások létrehozása, az információk bejelentési eszközre való etetése vagy az átalakított adatok későbbi használatra való tárolása.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. A Stream Analytics Azure IoT Edge futtatókörnyezetben is elérhető, amely lehetővé teszi az IoT-eszközökön tárolt adatfeldolgozást.Also, Stream Analytics is available on Azure IoT Edge runtime, enabling to process data on IoT devices.

A következő forgatókönyvek példákat mutatnak a Azure Stream Analytics használatára:The following scenarios are examples of when you can use Azure Stream Analytics:

  • Valós idejű telemetria streamek elemzése a IoT-eszközökrőlAnalyze real-time telemetry streams from IoT devices
  • Webnaplók és kattintássorozatok elemzéseWeb logs/clickstream analytics
  • Térinformatikai elemzés flottakezeléshez és vezető nélküli járművekhezGeospatial analytics for fleet management and driverless vehicles
  • Távoli monitorozás és prediktív karbantartás a nagy értékű eszközökönRemote monitoring and predictive maintenance of high value assets
  • A pénztári adatok valós idejű elemzése készletszabályozáshoz és anomáliadetektáláshozReal-time analytics on Point of Sale data for inventory control and anomaly detection

Hogyan működik a Stream Analytics?How does Stream Analytics work?

Az Azure Stream Analytics feladatok egy bemenetből, lekérdezésből és kimenetből állnak.An Azure Stream Analytics job consists of an input, query, and an output. Stream Analytics az Azure-Event Hubs (beleértve Apache Kafka az Azure-Event Hubst is), az Azure IoT Hub vagy az 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. A lekérdezés, amely SQL-lekérdezési nyelven alapul, egyszerűen szűrheti, rendezheti, összesítheti és összekapcsolhatja az adatfolyam-adatokat egy adott időszakban.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. Ezt az SQL nyelvet a JavaScript és a C# felhasználó által definiált függvények (UDF) használatával is kiterjesztheti.You can also extend this SQL language with JavaScript and C# user defined functions (UDFs). Az összesítési műveletek egyszerű nyelvi szerkezeteken és/vagy konfigurációkon keresztül történő előírásával egyszerűen beállíthatja az események rendezési beállításait és időtartamát.You can easily adjust the event ordering options and duration of time windows when preforming aggregation operations through simple language constructs and/or configurations.

Minden feladathoz tartozik egy vagy több kimenet az átalakított adatokhoz, és szabályozható, hogy mi történik az elemzett információkra adott válaszként.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. Megteheti például a következőt:For example, you can:

  • Adatokat küldhet a szolgáltatásoknak, például a Azure Functionsnak, Service Bus témákat vagy várólistákat a kommunikáció vagy az egyéni munkafolyamatok alsóbb rétegbeli elindításához.Send data to services such as Azure Functions, Service Bus Topics or Queues to trigger communications or custom workflows downstream.
  • Adatküldés egy Power BI Irányítópultra a valós idejű irányítópultok számára.Send data to a Power BI dashboard for real-time dashboarding.
  • Az adatok tárolása más Azure Storage-szolgáltatásokban (például Azure Data Lake, Azure szinapszis Analitika stb.) a gépi tanulási modell betanításához a korábbi adatok alapján, illetve a Batch-elemzések elvégzéséhez.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.

Az alábbi képen látható, hogyan történik az adatok továbbítása Stream Analytics, elemzése és elküldése más műveletekhez, például a tároláshoz vagy a bemutatóhoz:The following image shows how data is sent to Stream Analytics, analyzed, and sent for other actions like storage or presentation:

Stream Analytics bevezető folyamat

Főbb képességek és előnyökKey capabilities and benefits

Az Azure Stream Analytics szolgáltatást könnyen használhatónak, rugalmasnak, megbízhatónak és bármely feladathoz méretezhetőnek tervezték.Azure Stream Analytics is designed to be easy to use, flexible, reliable, and scalable to any job size. Több Azure-régióban is elérhető.It is available across multiple Azure regions. Az alábbi ábra a Azure Stream Analytics főbb képességeit szemlélteti:The following image illustrates the key capabilities of Azure Stream Analytics:

A Stream Analytics főbb képességei

Könnyű első lépésekEase of getting started

Azure Stream Analytics könnyen elindítható.Azure Stream Analytics is easy to start. Csak néhány kattintással csatlakozhat több forráshoz és mosogatóhoz, így végpontok közötti folyamatot hozhat létre.It only takes a few clicks to connect to multiple sources and sinks, creating an end-to-end pipeline. Stream Analytics tud csatlakozni az azure Event Hubshoz és az Azure IoT hubhoz a folyamatos adatfeldolgozáshoz, valamint az Azure Blob Storage -hoz a korábbi adatmennyiségek betöltéséhez.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. A feladatok bemenete tartalmazhat statikus vagy lassan változó hivatkozási adatokat az Azure Blob Storage-ból vagy SQL Database , hogy a keresési műveletek elvégzéséhez csatlakozhat a folyamatos átvitelhez.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 a feladatok kimenetét számos olyan tárolási rendszerre irányíthatja, mint például az Azure Blob Storage, a Azure SQL Database, a Azure Data Lake Storeés az 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. Futtathatja a Batch Analytics szolgáltatást a tárolt kimeneteken az Azure HDInsight, vagy elküldheti a kimenetet egy másik szolgáltatásba, például a Event Hubst a felhasználáshoz, vagy Power bi a valós idejű vizualizációhoz.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.

A Stream Analytics kimenetek teljes listájáért lásd: Azure stream Analyticsokból származó kimenetek megismerése.For the entire list of Stream Analytics outputs, see Understand outputs from Azure Stream Analytics.

Programozói termelékenységProgrammer productivity

Azure Stream Analytics egy egyszerű SQL-alapú lekérdezési nyelvet használ, amely hatékony időbeli korlátozásokkal bővült a mozgásban lévő adatelemzéshez.Azure Stream Analytics uses a simple SQL-based query language that has been augmented with powerful temporal constraints to analyze data in motion. A feladattranszformációk a Stream Analytics egyszerű, deklaratív lekérdező nyelvével definiálhatók, amely lehetővé teszi, hogy egyszerű SQL-szerkezetekkel hozzon létre összetett historikus lekérdezéseket.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. Mivel Stream Analytics lekérdezés nyelve konzisztens az SQL nyelvével, az SQL megfelelő ismerete elegendő a feladatok létrehozásának megkezdéséhez.Because Stream Analytics query language is consistent to the SQL language, familiarity with SQL is sufficient to start creating jobs. A feladatokat olyan fejlesztői eszközök használatával is létrehozhatja Stream Analytics, mint például a Azure PowerShell, a Visual Studio Tools, a stream Analytics Visual Studio Code bővítményvagy a Azure Resource Manager sablonok.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. A fejlesztői eszközök használatával offline módon fejleszthet transzformációs lekérdezéseket és a folyamatos integrációs és folyamatos teljesítési folyamattal küldhet be feladatokat az Azure-ba.Using developer tools allow you to develop transformation queries offline and use the CI/CD pipeline to submit jobs to Azure.

A Stream Analytics lekérdezési nyelv a streaming adatok elemzéséhez és feldolgozásához használható függvények széles skáláját kínálja.The Stream Analytics query language offers a wide array of functions for analyzing and processing streaming data. Ez a lekérdezési nyelv támogatja az egyszerű adatmanipulációt, az összesítési és elemzési funkciókat, a térinformatikai funkciókat, a mintázat megfeleltetését és a rendellenességek észlelését.This query language supports simple data manipulation, aggregation and analytics functions, geospatial functions, pattern matching and anomaly detection. Szerkesztheti a lekérdezéseket a portálon, és tesztelheti azokat az élő streamből kinyert mintaadatok használatával.You can edit queries in the portal and test them using sample data that is extracted from a live stream.

A lekérdező nyelv lehetőségei függvények definiálásával és meghívásával tovább bővíthetők.You can extend the capabilities of the query language by defining and invoking additional functions. A Azure Machine Learningban megadhatja az Azure Machine Learning megoldások előnyeit, valamint a JavaScript vagy C# felhasználó által definiált függvények (UDF) vagy a felhasználó által definiált összesítések integrálását az Stream Analytics lekérdezés részeként összetett számítások végrehajtásához.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.

Teljes körű felügyeletFully managed

Az Azure Stream Analytics egy teljes körűen felügyelt Azure-beli kiszolgáló nélküli (PaaS-) ajánlat.Azure Stream Analytics is a fully managed serverless (PaaS) offering on Azure. Nem kell hardvert kiépítenie, a fürtöket a feladatok futtatásához vagy az operációs rendszer vagy a szoftver frissítéséhez sem kell kezelnie.You don't have to provision any hardware, manage clusters to run your jobs, or update OS or software. Azure Stream Analytics teljes mértékben felügyeli a feladatot, így az üzleti logikára koncentrálhat, nem pedig az infrastruktúrán.Azure Stream Analytics fully manages your job, so you can focus on your business logic and not on the infrastructure.

Futtatás a felhőben vagy az intelligens Edge-benRun in the cloud or on the intelligent edge

A Azure Stream Analytics a felhőben, a nagyméretű elemzések futtatásához, vagy a IoT Edge-on való futtatásához rendkívül alacsony késésű elemzésekhez.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 ugyanazokat az eszközöket és lekérdezési nyelvet használja mind a felhőben, mind a peremen, így a fejlesztők valóban hibrid architektúrákat építhetnek ki az adatfolyam-feldolgozáshoz.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.

Alacsony teljes tulajdonlási díjLow total cost of ownership

Felhőszolgáltatásként a Stream Analytics költségoptimalizált.As a cloud service, Stream Analytics is optimized for cost. Nincsenek előzetes költségek – csak a felhasznált folyamatos átviteli egységekértkell fizetnie.There are no upfront costs involved - you only pay for the streaming units you consume. Nincs szükség kötelezettségvállalásra vagy fürtök kiosztására, és az üzleti igényeknek megfelelően akár fel, akár le is méretezheti a feladatokat.There is no commitment or cluster provisioning required, and you can scale the job up or down based on your business needs.

Feladat – kritikusan készMission-critical ready

Azure Stream Analytics világszerte több régióban érhető el, és úgy tervezték, hogy kritikus fontosságú számítási feladatokat futtasson a megbízhatósági, biztonsági és megfelelőségi követelmények támogatásával.Azure Stream Analytics is available across multiple regions worldwide and is designed to run mission-critical workloads by supporting reliability, security and compliance requirements.

MegbízhatóságReliability

Azure Stream Analytics garantálja a pontosan egyszeri esemény-feldolgozást és az események legalább egyszeri kézbesítését, így az események soha nem vesznek el.Azure Stream Analytics guarantees exactly-once event processing and at-least-once delivery of events, so events are never lost. A pontosan egyszeri feldolgozás garantált a kiválasztott kimenettel, az esemény kézbesítési garanciáiközött leírtak szerint.Exactly-once processing is guaranteed with selected output as described in Event Delivery Guarantees.

A Azure Stream Analytics beépített helyreállítási képességekkel rendelkezik abban az esetben, ha egy esemény kézbesítése meghiúsul.Azure Stream Analytics has built-in recovery capabilities in case the delivery of an event fails. A Stream Analytics beépített ellenőrzőpontokat is biztosít a feladatok állapotának fenntartásához, és megismételhető eredményeket biztosít.Stream Analytics also provides built-in checkpoints to maintain the state of your job and provides repeatable results.

Felügyelt szolgáltatásként Stream Analytics az események feldolgozását az 99,9%-os rendelkezésre állással biztosítja percenkénti részletességgel.As a managed service, Stream Analytics guarantees event processing with a 99.9% availability at a minute level of granularity. További információ: stream Analytics SLA oldal.For more information, see the Stream Analytics SLA page.

BiztonságSecurity

A biztonság szempontjából Azure Stream Analytics titkosítja az összes bejövő és kimenő kommunikációt, és támogatja a TLS 1,2-et.In terms of security, Azure Stream Analytics encrypts all incoming and outgoing communications and supports TLS 1.2. A beépített ellenőrzőpontok is titkosítva vannak.Built-in checkpoints are also encrypted. A Stream Analytics nem tárolja a bejövő adatmennyiséget, mert az összes feldolgozás a memóriában történik.Stream Analytics doesn't store the incoming data since all processing is done in-memory.

MegfelelőségCompliance

Azure Stream Analytics az Azure megfelelőségének áttekintésecímű témakörben leírtak szerint több megfelelőségi tanúsítványt követ.Azure Stream Analytics follows multiple compliance certifications as described in the overview of Azure compliance.

TeljesítményPerformance

A Stream Analytics másodpercenként több millió eseményt képes feldolgozni, és az eredményeket rendkívül alacsony késéssel kézbesítheti.Stream Analytics can process millions of events every second and it can deliver results with ultra low latencies. Lehetővé teszi a vertikális felskálázást és a méretezést a nagy valós idejű és összetett eseménykezelő alkalmazások kezeléséhez.It allows you to scale-up and scale-out to handle large real-time and complex event processing applications. Stream Analytics a particionálás nagyobb teljesítményt nyújt, és lehetővé teszi, hogy az összetett lekérdezések párhuzamosak legyenek, és több folyamatos átviteli csomóponton fussanak.Stream Analytics supports higher performance by partitioning, allowing complex queries to be parallelized and executed on multiple streaming nodes. A Azure Stream Analytics a trilla-ra épülő, nagy teljesítményű, memóriabeli adatfolyam-elemzési motor, amely a Microsoft Research szolgáltatással együttműködve lett kifejlesztve.Azure Stream Analytics is built on Trill, a high-performance in-memory streaming analytics engine developed in collaboration with Microsoft Research.

Következő lépésekNext steps

A cikk az Azure Stream Analytics szolgáltatásról nyújtott áttekintést.You now have an overview of Azure Stream Analytics. Ezután megismerheti a részleteket, és létrehozhatja első Stream Analytics-feladatát:Next, you can dive deep and create your first Stream Analytics job: