Realtidsbehandling

Realtidsbehandling behandler indgående hændelser løbende efter et latensmål, der er fastlagt for applikationen. I stedet for at vente på en komplet batch reagerer applikationen på en datastrøm. Ordet »realtid« angiver ikke i sig selv en fast millisekundgrænse eller en garanteret maksimal reaktionstid.

I et fiktivt eksempel tæller et dashboard afsluttede eksportjob pr. minut. Afslutningshændelsen for J-31 opstår klokken 10:04, men når først behandlingen klokken 10:07. Begge klokkeslæt bruger samme tidszone. En beregning efter hændelsestid placerer den i minuttet 10:04; en beregning efter behandlingstid i minuttet 10:07. De besvarer forskellige spørgsmål.

Afstem hurtig visning og fuldstændige resultater

Tæller visningen efter hændelsestid, kræver det en regel for forsinkede meldinger: Skal et allerede vist minuttal rettes, eller skal den forsinkede hændelse registreres separat? Længere ventetid kan få flere forsinkede hændelser med, men udskyder resultatet. Et watermark markerer den antagne fremdrift i hændelsestiden. Hændelser med tidligere tidsstempler kan stadig ankomme bagefter.

Fastlæg, hvor latensmålingen begynder og slutter, hvor gammel den ældste ventende post er, og hvordan ophobning bliver synlig. Tidsstempler og synkronisering af ure hører også til en pålidelig tidsplacering. Et dashboard, der opdateres regelmæssigt, beviser ikke i sig selv, at alle de underliggende hændelser allerede er behandlet.

Kilder

• Apache Flink — Timely Stream Processing