Dela via


Strömmande inmatning och schemaändringar

Gäller för: ✅Microsoft FabricAzure Data Explorer

Klusternoder cachelagrar schemat för databaser som hämtar data via strömmande inmatning, vilket ökar prestanda och resursanvändning. Men när det finns schemaändringar kan det leda till fördröjningar i uppdateringar.

Eventhouse-noder cachelagrar schemat för databaser som hämtar data via strömmande inmatning, vilket ökar prestanda och resursanvändning. Men när det finns schemaändringar kan det leda till fördröjningar i uppdateringar.

Om schemaändringar och strömmande inmatning inte synkroniseras kan du stöta på fel som schemarelaterade fel eller ofullständiga och förvrängda data i tabellen.

Den här artikeln beskriver vanliga schemaändringar och ger vägledning om hur du undviker problem med strömmande inmatning under dessa ändringar.

Schemaändringar

I följande lista beskrivs viktiga exempel på schemaändringar:

Samordna schemaändringar med strömmande inmatning

Schemacachen behålls medan databasen är online. Om det finns schemaändringar uppdaterar systemet automatiskt cacheminnet, men den här uppdateringen kan ta flera minuter. Om du förlitar dig på den automatiska uppdateringen kan det uppstå okoordinerade inmatningsfel.

Du kan minska effekterna av spridningsfördröjning genom att uttryckligen rensa schemacachen på noderna. Om flödet för strömmande inmatning och schemaändringar samordnas kan du helt eliminera fel och deras associerade dataförvrängning.

Så här samordnar du flödet för strömmande inmatning med schemaändringar:

  1. Pausa inmatning av direktuppspelning.
  2. Vänta tills alla utestående begäranden om strömningsinmatning har slutförts.
  3. Gör schemaändringar.
  4. Utfärda ett eller flera .clear cache streaming ingestion schemakommandon.
    • Upprepa tills det lyckas och alla rader i kommandoutdata indikerar att det lyckades
  5. Återuppta strömningsinmatning.

Not

Om du har skapat ett program för anpassad inmatningrekommenderar vi att du hanterar schemarelaterade fel genom att antingen försöka igen under en viss varaktighet eller omdirigera data från misslyckade begäranden med hjälp av köade inmatningsmetoder.