Události
Staňte se certifikovaným Datoví technici fabric
14. 1. 23 - 31. 3. 23
Zkontrolujte, jestli máte nárok na nabídku slev na zkoušku, a zaregistrujte se na bezplatné živé relace a připravte se na zkoušku DP-700.
Další informaceTento prohlížeč se už nepodporuje.
Upgradujte na Microsoft Edge, abyste mohli využívat nejnovější funkce, aktualizace zabezpečení a technickou podporu.
Jak je vysvětleno v článku replikace zpráv a federace mezi oblastmi, replikace sekvencí zpráv mezi dvojicemi entit služby Service Bus a mezi Service Bus a dalšími zdroji zpráv a cíli se obecně spoléhá na Azure Functions.
Azure Functions je škálovatelné a spolehlivé spouštěcí prostředí pro konfiguraci a spouštění bezserverových aplikací, včetně replikace zpráv a úloh federace .
V tomto přehledu se dozvíte o integrovaných funkcích Azure Functions pro takové aplikace, o blocích kódu, které můžete přizpůsobit a upravit pro úlohy transformace, a o tom, jak nakonfigurovat aplikaci Azure Functions tak, aby se ideálně integruje se službou Service Bus a dalšími službami zasílání zpráv Azure. V mnoha podrobnostech tento článek odkazuje na dokumentaci ke službě Azure Functions.
Úloha replikace přijímá události ze zdroje a předává je do cíle. Většina úloh replikace předá události beze změny a na většině případů provede mapování mezi strukturami metadat, pokud se zdrojový a cílový protokol liší.
Úlohy replikace jsou obecně bezstavové, což znamená, že nesdílejí stav ani jiné vedlejší účinky napříč sekvenčními nebo paralelními prováděními úlohy. To platí také pro dávkování a řetězení, které je možné implementovat nad stávající stav datového proudu.
Díky tomu se úlohy replikace liší od úloh agregace, které jsou obecně stavové a jsou doménou analytických architektur a služeb, jako je Azure Stream Analytics.
Ve službě Azure Functions se úloha replikace implementuje pomocí triggeru, který získává vstupní zprávy z nakonfigurovaného zdroje a výstupní vazbu, která předává zprávy zkopírované ze zdroje do nakonfigurovaného cíle.
Úlohy replikace se nasazují do aplikace replikace prostřednictvím stejných metod nasazení jako jakákoli jiná aplikace Azure Functions. Do stejné aplikace můžete nakonfigurovat více úloh.
S Azure Functions Premium může více aplikací replikace sdílet stejný základní fond zdrojů, označovaný jako plán služby App Service. To znamená, že můžete snadno sloučit úlohy replikace napsané v .NET pomocí úloh replikace, které jsou napsané v Javě, například. To bude důležité, pokud chcete využít konkrétní knihovny, jako je Apache Camel, které jsou k dispozici pouze pro Javu, a pokud jsou to nejlepší možnost pro konkrétní cestu integrace, i když byste pro ostatní úlohy replikace běžně preferoval jiný jazyk a modul runtime.
Kdykoli je k dispozici, měli byste upřednostnit dávkové triggery před aktivačními událostmi, které doručují jednotlivé události nebo zprávy, a měli byste vždy získat úplnou událost nebo strukturu zpráv, a nespoléhat se na výrazy vazby parametrů funkce Azure Functions.
Název funkce by měl odrážet dvojici zdroje a cíle, který připojujete, a měli byste předponovat odkazy na připojovací řetězec nebo jiné konfigurační prvky v konfiguračních souborech aplikace s tímto názvem.
Jakmile se rozhodnete pro dvojici vstupních triggerů a výstupních vazeb, budete muset provést určité mapování mezi různými typy událostí nebo zpráv, pokud typ triggeru a výstup není stejný.
U jednoduchých úloh replikace, které kopírují zprávy mezi službou Event Hubs a Service Bus, nemusíte psát vlastní kód, ale můžete se spoléhat na knihovnu nástrojů, která je součástí ukázek replikace.
Pokud se chcete vyhnout ztrátě dat během události dostupnosti na obou stranách funkce replikace, musíte nakonfigurovat zásady opakování tak, aby byly robustní. Informace o konfiguraci zásad opakování najdete v dokumentaci ke službě Azure Functions.
Nastavení zásad zvolených pro ukázkové projekty v ukázkovém úložišti konfiguruje exponenciální strategii zpětného ukončení s intervaly opakování od 5 sekund do 15 minut s nekonečnými opakováními, aby nedošlo ke ztrátě dat.
Obecně dostupná verze zásad opakování pro Azure Functions podporuje pouze triggery služby Event Hubs a Časovač. Byla odebrána podpora náhledu pro všechny ostatní triggery.
Aplikace replikace je hostitel spouštění pro jednu nebo více úloh replikace.
Jedná se o aplikaci Azure Functions, která je nakonfigurovaná tak, aby běžela buď v plánu Consumption, nebo (doporučeno) v plánu Azure Functions Premium. Všechny aplikace replikace musí běžet pod spravovanou identitou přiřazenou systémem nebo přiřazenou uživatelem.
Propojené šablony Azure Resource Manageru (ARM) vytvoří a nakonfigurují replikační aplikaci pomocí:
Aplikace replikace, které musí přistupovat ke službě Event Hubs vázané na virtuální síť Azure, musí používat plán Azure Functions Premium a musí být nakonfigurované pro připojení ke stejné virtuální síti, což je také jedna z dostupných možností.
Nasadit | Vizualizace | |
---|---|---|
Plán Consumption služby Azure Functions | ||
Plán Azure Functions Premium | ||
Plán Azure Functions Premium s virtuální sítí |
Úložiště ukázek obsahuje několik příkladů úloh replikace, které kopírují události mezi službami Event Hubs a/nebo mezi entitami služby Service Bus.
Ke kopírování dat událostí mezi centry událostí použijete trigger služby Event Hubs s výstupní vazbou služby Event Hubs:
[FunctionName("telemetry")]
[ExponentialBackoffRetry(-1, "00:00:05", "00:05:00")]
public static Task Telemetry(
[EventHubTrigger("telemetry", ConsumerGroup = "$USER_FUNCTIONS_APP_NAME.telemetry", Connection = "telemetry-source-connection")] EventData[] input,
[EventHub("telemetry-copy", Connection = "telemetry-target-connection")] EventHubClient outputClient,
ILogger log)
{
return EventHubReplicationTasks.ForwardToEventHub(input, outputClient, log);
}
Ke kopírování zpráv mezi entitami služby Service Bus použijte aktivační událost a výstupní vazbu služby Service Bus:
[FunctionName("jobs-transfer")]
[ExponentialBackoffRetry(-1, "00:00:05", "00:05:00")]
public static Task JobsTransfer(
[ServiceBusTrigger("jobs-transfer", Connection = "jobs-transfer-source-connection")] Message[] input,
[ServiceBus("jobs", Connection = "jobs-target-connection")] IAsyncCollector<Message> output,
ILogger log)
{
return ServiceBusReplicationTasks.ForwardToServiceBus(input, output, log);
}
Pomocné metody můžou snadno replikovat mezi Event Hubs a Service Bus:
Source | Cíl | Vstupní bod |
---|---|---|
Event Hubs | Event Hubs | Azure.Messaging.Replication.EventHubReplicationTasks.ForwardToEventHub |
Centra událostí | Service Bus | Azure.Messaging.Replication.EventHubReplicationTasks.ForwardToServiceBus |
Service Bus | Centra událostí | Azure.Messaging.Replication.ServiceBusReplicationTasks.ForwardToEventHub |
Service Bus | Service Bus | Azure.Messaging.Replication.ServiceBusReplicationTasks.ForwardToServiceBus |
Informace o tom, jak monitorovat aplikaci replikace, najdete v části monitorování v dokumentaci ke službě Azure Functions.
Zvlášť užitečný vizuální nástroj pro monitorování úloh replikace je mapa aplikace Application Insights, která se automaticky generuje z zachycených informací o monitorování a umožňuje zkoumat spolehlivost a výkon zdroje úloh replikace a cílových přenosů.
Pro okamžité diagnostické přehledy můžete pracovat s nástrojem portálu Live Metrics , který poskytuje vizualizaci podrobností protokolu s nízkou latencí.
Události
Staňte se certifikovaným Datoví technici fabric
14. 1. 23 - 31. 3. 23
Zkontrolujte, jestli máte nárok na nabídku slev na zkoušku, a zaregistrujte se na bezplatné živé relace a připravte se na zkoušku DP-700.
Další informaceŠkolení
Postup výuky
Naučte se vytvářet spolehlivé zasílání zpráv pro své aplikace a využívat služby bezserverových aplikací v Azure.
Certifikace
Microsoft Certified: Azure Developer Associate - Certifications
Build end-to-end solutions in Microsoft Azure to create Azure Functions, implement and manage web apps, develop solutions utilizing Azure storage, and more.
Dokumentace
Vzory úloh replikace zpráv – Azure Service Bus - Azure Service Bus
Tento článek obsahuje podrobné pokyny k implementaci konkrétních vzorů úloh replikace zpráv.
Replikace zpráv a federace mezi oblastmi – Azure Service Bus - Azure Service Bus
Tento článek obsahuje přehled replikace událostí a federace mezi oblastmi pomocí služby Azure Service Bus.
Pokročilé funkce se službou Azure Service Bus
V této epizodě se Ashish Chhabria připojí k Cecilovi, aby mluvil o některých pokročilejších funkcích služby Azure Service Bus. Budou se zabývat tématy, jako je plánování, odložené zprávy, detekce duplicit, zotavení po havárii a další.[00:37] – Použití relací[04:46]- Automatické přeposílání[07:24] – Plánování zpráv[09:00] – Odložené zprávy[13:17] – Detekce duplicit[16:00] – Vysoká dostupnost a zotavení po havárii[22:49] – Funkce zabezpečení pro Azure Service BusUžitečné odkazyZasílání zpráv služby Azure Serv