Nápady na řešení
Tento článek popisuje myšlenku řešení. Váš cloudový architekt může pomocí těchto pokynů vizualizovat hlavní komponenty pro typickou implementaci této architektury. Tento článek slouží jako výchozí bod k návrhu dobře navrženého řešení, které odpovídá konkrétním požadavkům vaší úlohy.
Tento článek popisuje variantu bezserverové architektury řízené událostmi, která běží ve službě Azure Kubernetes Service (AKS) se škálováním KEDA. Řešení ingestuje datový proud, zpracuje data a pak zapíše výsledky do back-endové databáze.
Architektura
Stáhněte si soubor aplikace Visio s touto architekturou.
Tok dat
- AKS se škálovacím nástrojem KEDA se používá k automatickému škálování kontejnerů Azure Functions na základě počtu událostí, které je potřeba zpracovat.
- Události přicházejí do vstupního centra událostí.
- Funkce Azure Functions pro zrušení dávkování a filtrování se aktivuje pro zpracování události. Tento krok vyfiltruje nežádoucí události a před odesláním do výstupního centra událostí zruší dávky přijatých událostí.
- Pokud se službě Azure Functions nepodaří úspěšně uložit dávku a filtrování, událost se odešle do centra událostí Deadletter 1.
- Události přicházející do výstupního centra událostí aktivují transformaci funkce Azure Functions. Tato funkce Azure Transformuje událost na zprávu pro instanci služby Azure Cosmos DB.
- Událost je uložená v databázi Azure Cosmos DB.
Komponenty
- Azure Kubernetes Service (AKS) zjednodušuje nasazení spravovaného clusteru Kubernetes v Azure tím, že přesměruje provozní režii do Azure. Azure jako hostovaná služba Kubernetes zpracovává důležité úlohy, jako je monitorování stavu a údržba.
- KEDA je automatické škálování řízené událostmi, které se používá ke škálování kontejnerů v clusteru Kubernetes na základě počtu událostí, které je potřeba zpracovat.
- Event Hubs ingestuje datový proud. Služba Event Hubs je navržená pro scénáře streamování dat s vysokou propustností.
- Azure Functions je bezserverová výpočetní možnost. Používá model řízený událostmi, kde aktivační událost vyvolá část kódu ( funkce).
- Azure Cosmos DB je vícemodelová databázová služba, která je dostupná v bezserverovém režimu založeném na spotřebě. V tomto scénáři ukládá funkce zpracování událostí záznamy JSON pomocí služby Azure Cosmos DB for NoSQL.
Poznámka:
Pro scénáře Internetu věcí (IoT) doporučujeme Azure IoT Hub. IoT Hub má integrovaný koncový bod, který je kompatibilní s rozhraním API služby Azure Event Hubs, takže v této architektuře můžete použít některou službu bez velkých změn v back-endovém zpracování. Další informace najdete v tématu Připojení zařízení IoT k Azure: IoT Hub a Event Hubs.
Podrobnosti scénáře
Tento článek popisuje bezserverovou architekturu řízenou událostmi, která běží v AKS se škálováním KEDA. Řešení ingestuje datový proud, zpracuje data a pak zapíše výsledky do back-endové databáze.
Další informace o základních konceptech, aspektech a přístupech pro zpracování událostí bez serveru najdete v referenční architektuře zpracování bezserverových událostí.
Případ potenciálního použití
Oblíbený případ použití pro implementaci vzoru zpracování streamu událostí od konce do konce zahrnuje službu pro příjem a zpracování událostí služby Event Hubs pro příjem a zpracování událostí za sekundu s využitím logiky de-batching a transformace implementované s vysoce škálovatelnými funkcemi aktivovanými centrem událostí.
Přispěvatelé
Tento článek spravuje Microsoft. Původně byla napsána následujícími přispěvateli.
Hlavní autor:
- Rajasa Savant | Vedoucí inženýr pro vývoj softwaru
Pokud chcete zobrazit neveřejné profily LinkedIn, přihlaste se na LinkedIn.
Další kroky
- Seznámení se službou Azure Kubernetes Service
- Dokumentace ke službě Azure Event Hubs
- Seznámení s Azure Functions
- Dokumentace ke službě Azure Functions
- Přehled služby Azure Cosmos DB
- Volba rozhraní API ve službě Azure Cosmos DB
Související prostředky
- Bezserverové zpracování událostí je referenční architektura podrobně popisující typickou architekturu tohoto typu s ukázkami kódu a diskuzí o důležitých aspektech.
- Scénář privátního propojení při zpracování datových proudů událostí je řešením pro implementaci podobné architektury ve virtuální síti s privátními koncovými body, aby se zlepšilo zabezpečení.