Händelsedrivna applikationer

Utveckla applikationer på AWS

Ricardo Sueiras

Principal Technologist

Vad är en händelse?

 

• Ett meddelande är en arbetsenhet som skickas mellan komponenter.
• En händelse registrerar att något redan inträffat.
• Tjänster kommunicerar genom att publicera händelser.
• Andra tjänster reagerar självständigt på dessa händelser.
• Frikoppling minskar beroenden och förbättrar skalbarhet.

Händelseproducenter

 

• Producenter skapar och publicerar händelser när åtgärder inträffar.
• Både AWS-tjänster och anpassade applikationer kan producera händelser.
• Att ladda upp en fil till Amazon S3 är ett exempel.
• Amazon S3 skickar då en object-created-händelse.

Händelsekonsumenter

 

• Konsumenter tar emot och bearbetar händelser asynkront.
• Händelsekällor använder olika leveransmodeller.
• Push-baserad: händelser levereras omedelbart.
• Pollbaserad: konsumenter hämtar händelser vid polling.

Händelsekällsmappning

• AWS Lambda är en vanlig händelsekonsument.
• Den pollar källor och hämtar poster i batchar automatiskt.

 

Finjustering av Lambda-händelsekällsmappningar

• Justera händelsekällsmappningar för bättre genomströmning.
• Ange batchstorlek för att styra antal poster per anrop.
• Konfigurera återförsöksstyrning för misslyckade poster.
• Använd partiella batchsvar på källor som stöder det.
• ReportBatchItemFailures undviker ombearbetning av lyckade poster.

 

Amazon EventBridge

• EventBridge dirigerar händelser mellan tjänster och applikationer.
• Det möjliggör dynamisk dirigering utan tight koppling av tjänster.
• Applikationer publicerar sina händelser till EventBridge.
• Dirigeringsregler avgör vilka mål som tar emot varje händelse.

 

EventBridge-funktioner

 

• EventBridge erbjuder flera dirigeringsfunktioner.
• Regler skickar en händelse vidare till flera mål.
• Schemalagda regler eliminerar behovet av cron-servrar.
• Scheman stöder uttrycken rate(), at() och cron().
• Pipes ger punkt-till-punkt-integration.
• Pipes möjliggör även filtrering och transformering.

Händelsebussar

 

• Olika händelsebussar optimerar hur händelser dirigeras.
• Standardbussen tar emot händelser från AWS-tjänster.
• Anpassade bussar hanterar applikationsspecifika händelser.
• Partnerbussar tar emot händelser från tredjepartsleverantörer.
• Regler placeras mellan varje buss och dess mål.

Schemaidentifiering

 

• Producenter och konsumenter utvecklas ofta oberoende av varandra.
• Det är viktigt att förstå händelsernas struktur.
• Schemaidentifiering fångar strukturen hos inkommande händelser.
• Använd det för att granska händelsers innehåll.
• Använd det för att validera integrationer.
• Använd det för att generera bindningar för stödda språk.

Schemaregister

• Schemaregistret lagrar dina händelsescheman.
• Det hjälper utvecklare att förstå händelsestrukturer och generera bindningar.

 

Händelsefiltrering

• Filtrering minskar onödig bearbetning.
• Definiera matchningar med JSON-händelsemönster.
• Mönster matchar endast de specifika händelser du vill ha.
• Nedströms system bearbetar då bara relevanta händelser.

 

Händelseordning

• Händelseordning är inte alltid garanterad.
• Vissa tjänster kan bearbeta händelser i fel ordning.
• Använd ordningsstyrning för att genomdriva sekvens explicit.

 

Arkivering och uppspelning av händelser

 

• EventBridge kan arkivera och senare spela upp händelser igen.
• Spela upp händelser för att återhämta sig från fel.
• Spela upp händelser för att testa nya konsumenter.
• Spela upp händelser för att återskapa nedströmssystem.

Felhantering

 

• Händelsedrivna appar måste hantera fel på ett säkert sätt.
• Fel inkluderar dubbletter av händelser.
  • Misslyckad bearbetning.
  • Otillgängliga konsumenter.
• Utforma konsumenter att vara idempotenta så långt som möjligt.

DLQ:er och destinations

 

• Använd DLQ:er för att isolera händelser som upprepade gånger misslyckas.
• I EventBridge konfigureras DLQ:er per regelsmål, inte per funktion.
• Lambda Destinations utökar denna dirigering.
• Destinations dirigerar både lyckade och misslyckade resultat.

Testning och validering av händelser

• Testning av händelsedrivna appar validerar dirigering.
• Det validerar även händelsefiltrering.
• Det validerar även återförsök av händelser.
• Det bekräftar bearbetning i distribuerade system.
• Använd AWS SAM för att generera exempeltesthändelser.
• Exempelhändelser replikerar exakt JSON-utdata.

 

Vad du ska testa

• SAM låter dig testa lokalt innan driftsättning.
• Validera matchning av händelsemönster.
• Validera beteende vid återförsök.
• Validera begränsningsscenarier.
• Validera leverans av dubbletter av händelser.
• Validera idempotent konsumentbeteende.

 

Nu kör vi en övning!

Utveckla applikationer på AWS