V bankovním prostředí vidíme stále větší poptávku po digitalizaci všech agend a služeb. S tím roste i počet systémů a jejich vzájemná výměna dat. Klienti zároveň očekávají, že budou mít své produkty a služby stále dostupné s okamžitou reakcí na jejich požadavky.

Události přenášejí informace

Vedle dlouhodobých trendů v integraci, jako je decentralizace, kontejnerizace, využití API managementu a snahy vytvářet menší a pružnější řešení, představuje event-stream neboli proud událostí další téma, kterému je třeba věnovat pozornost. Jde o architektonicko-technologický koncept, který pomáhá řešit narůstající požadavky v integrační sféře, a to především v oblasti event-driven integrace. Řada českých bank už event streamy využívá jako kritický integrační nástroj.

Za událost se v tomto integračním schématu považuje popis něčeho, co je (fakt) - například adresa zákazníka nebo účetní zůstatek. Spadá pod ni ale i oznámení o změně stavu, jako je změna adresy zákazníka nebo notifikace o překročení povoleného limitu, či různé pokyny k akci v rámci daného systému.

Jak se zpracovávají proudy událostí

Jednou z možností, jak efektivně řídit a zpracovávat události, je zapojení platformy pro streamování dat. Převládající technologií se v tomto ohledu stala Apache Kafka, open source distribuovaná streamovací platforma, kterou lze použít k vytváření aplikací a kanálů pro streamování dat v reálném čase.

Za vznikem Apache Kafka stojí vývojáři ze společnosti LinkedIn, kteří potřebovali nástroj pro rychlý, bezpečný a škálovatelný přenos velkého množství dat v rámci celého světa. Tehdejší integrační nástroje a postupy nedokázaly tyto požadavky dostatečně reflektovat. Dnes se Kafka používá v mnoha odvětvích a společnostech od těch středních až po globální korporace.

Když použijete tuto streamovací platformu jako páteřní technologii pro integraci, lze implementovat systémy služeb a mikroslužeb tak, aby si vyměňovaly události v reálném čase a zároveň vytvářely události nové, například v reakci na to, co právě dělá koncový uživatel v aplikaci.

V praxi tak například může událost po přidání položky do košíku na e-shopu vést k vytvoření aktualizovaného obsahu košíku, nastavení nové odpovídající ceny a aktualizaci skladových zásob. Kafka zároveň umožňuje s událostmi pracovat v bezvýpadkovém režimu 24 hodin denně 7 dní v týdnu. Události jsou spolu se svými daty bezpečně uložené v Kafka clusteru a dostupné mnoha aplikacím a službám. To je v dnešní době klíčové, všechno se zrychlilo a klienti dnes očekávají, že služby poběží bez výpadků, budou škálovatelné a vše bude hned vyřízené.

Dostát tomuto požadavku lze díky tomu, že veškerá komunikace mezi systémy v Kafce probíhá asynchronně. To znamená, že systémy jsou mezi sebou volně svázané a jsou navzájem nezávislé. K výhodám tohoto přístupu patří možnost systémy snadno aktualizovat, škálovat a provozovat v mnoha replikách po celém světě, tak aby dokázaly zpracovat neustále zvyšující se počet klientských požadavků.

Je však důležité, aby na začátku celého projektu nejprve proběhla datová analýza, výběr integračních vzorů, které Kafka umožňuje, správná definice přenosových kanálů v Kafce a jejich schémat. Pod­stat­né je také ošetřit chyby, ke kterým může docházet při vytváření i čtení zpráv – správný návrh je jako vždy pro úspěch klíčový.

Kdy má událostmi řízená architektura smysl?

Využití Kafky dává smysl všude tam, kde je potřeba zpracovat obrovské množství dat v reálném čase a bez prodlevy. Typicky se event-driven integrace prosazuje v prostředí, které používá mikroservisní architekturu, kterou dobře doplňuje v oblasti škálovatelnosti, odolnosti proti výpadkům a agility.

Typickým příkladem, se kterým se setkáváme, je zpracování logů (aplikačních i auditních), monitoring uživatelských aktivit a online vyhodnocení klientských nabídek či „klasická“ aplikační integrace. Především v posledním případě je nutné navrhnout správný přístup k distribuci a konzumaci událostí, protože event-streaming pro stávající systémy může být složitější na implementaci než jiné typy integrace.

Odměnou za správnou realizaci je pak obrovský potenciál do bu­douc­na – schopnost rychleji reagovat na nové klientské požadavky (často bez nutnosti výpadku), efektivně škálovat s růstem klientské základny a zajistit stabilní a stále dostupné služby pro zákazníky.

Petr Dlouhý Autor článku pracuje v oblasti IT již více než 20 let a věnuje se dodávkám komplex­ních řešení hlavně pro finanční instituce. V současnosti působí ve společnosti Trask, kde na pozici Integration and Client Director vede tým 80 integračních expertů.