Dela via


Pausa och återuppta dataströmmar

Anteckning

Förbättrade funktioner aktiveras som standard när du skapar eventstreams. Om du har eventstreams som du har skapat via standardfunktioner fortsätter dessa händelseströmmar att fungera. Du kan fortfarande redigera och använda dem som vanligt. Vi rekommenderar att du skapar en ny händelseström för att ersätta standardhändelseströmmar så att du kan dra nytta av ytterligare funktioner och fördelar med förbättrade eventstreams.

Funktionerna Pausa och återuppta (d.v.s . Inaktivera och aktivera) i Eventstream ger dig fullständig kontroll över dina dataströmmar, så att du kan pausa dataströmning från olika källor och mål i Eventstream. Du kan sedan återuppta dataströmningen sömlöst från den pausade tiden eller en anpassad tid, vilket säkerställer att inga data går förlorade.

  • Aktivera/inaktivera alla: Pausa snabbt och återuppta all datatrafik som flödar in och ut från Eventstream med alternativen Aktivera alla och Inaktivera alla på menyraden.
  • Aktivera/inaktivera växlingsknappen: Varje nod har en växlingsknapp så att du kan aktivera (dvs. återuppta) eller inaktivera (dvs. pausa) data som strömmas från eller till valda källor och mål.

I följande tabell beskrivs beskrivningen av olika nodstatusar:

Nodstatus beskrivning
Aktiv Datakällan är för närvarande aktiv och data flödar in eller ut ur Eventstream.
Inaktiv Datakällan är för närvarande inaktiv och inga data flödar in eller ut ur Eventstream.
Loading Datakällan håller på att aktiveras eller inaktiveras.
Error Datakällan pausas för närvarande på grund av fel.
Warning Datakällan fungerar men har vissa problem, även om datatrafiken fortfarande inträffar.

Aktivera eller inaktivera en nod med växlingsknappen

För noder som stöder pausa och återuppta funktioner kan du enkelt hantera deras dataflöde med hjälp av växlingsknappen. Hitta önskad nod och aktivera eller inaktivera reglaget för att aktivera (dvs. återuppta) eller inaktivera (dvs pausa) datatrafiken. Noder som för närvarande inte stöder paus- och återuppta-funktioner har ingen växlingsväxel.

Tabellen nedan beskriver de tillgängliga CV-alternativen:

Återuppta valmöjlighet beskrivning
När strömning senast stoppades Återupptar från den punkt där direktuppspelning senast stoppades
Nu Återupptas från nuvarande tidpunkt
Anpassad tid Återstart från en anpassad tid

Skärmbild som visar omkopplare på noden och detaljer.

Anteckning

När du konfigurerar en Händelseström läggs källan, transformeringslogik och mål vanligtvis ihop. När du publicerar Eventstream börjar serverdelstjänsterna för både datainmatning och dataroutning som standard med Now respektive . Datainmatningen kan dock börja snabbare än dataroutning, vilket gör att vissa data matas in i Eventstream innan routningen initieras helt. Det innebär att dessa data kanske inte dirigeras till målet.

Ett vanligt exempel är en cdc-databaskälla, där vissa initiala ögonblicksbilddata kan finnas kvar i Eventstream utan att dirigeras till målet.

Följ dessa steg för att minimera detta:

  1. När du konfigurerar en Eventhouse (händelsebearbetning före inmatning) eller Lakehouse-destination avmarkerar du Aktivera inmatning efter att du har lagt till datakällan.

    En skärmbild av KQL-databasen utan att välja Aktivera inmatning efter att datakällan har lagts till.

  2. Aktivera inmatning manuellt när Eventstream har publicerats.

  3. Använd alternativet Anpassad tid för att välja en tidigare tidsstämpel, vilket säkerställer att inledande data bearbetas korrekt och dirigeras.

    En skärmbild av att återuppta KQL-databasen.

Här är en detaljerad tabell över noderna som stöder funktionaliteten för paus och återuppta, tillsammans med de tillgängliga alternativen för att återuppta.

Node Typ Stödjer paus och återupptagning Alternativ för återupptagning
Azure Data Explorer Database (förhandsversion) Källa JA – När strömning senast stoppades
Azure Event Hubs Källa JA – När strömning senast stoppades
-Nu
– Anpassad tid
Namnområde för Azure Event Grid (förhandsversion) Källa NEJ
Azure Service Bus (förhandsversion) Källa JA – När strömning senast stoppades
Azure IoT Hub Källa JA – När strömning senast stoppades
-Nu
– Anpassad tid
Exempeldata Källa JA -Nu
Realtidsväder (förhandsversion) Källa JA – När strömning senast stoppades
Azure SQL Database CDC Källa JA – När strömning senast stoppades
PostgreSQL-databas CDC Källa JA – När strömning senast stoppades
MongoDB CDC (förhandsversion) Källa JA – När strömning senast stoppades
MySQL-Databasen CDC Källa JA – När strömning senast stoppades
Azure Cosmos DB CDC Källa JA – När strömning senast stoppades
SQL Server på VM DB CDC Källa JA – När strömning senast stoppades
Azure SQL Managed Instance CDC Källa JA – När strömning senast stoppades
Google Cloud Pub/Sub (meddelandetjänst) Källa JA – När strömning senast stoppades
Amazon Kinesis Data Streams (dataströmmar från Amazon Kinesis) Källa JA – När strömning senast stoppades
Confluent Kafka Källa JA – När strömning senast stoppades
Apache Kafka (förhandsversion) Källa JA – När strömning senast stoppades
Amazon MSK Kafka Källa JA – När strömning senast stoppades
Anpassad slutpunkt (dvs. anpassad app i standardfunktion) Källa NEJ
Källa för fabric Workspace-händelser Källa NEJ
Fabric OneLake-händelser Källa NEJ
Händelser för Fabric-jobb Källa NEJ
Azure Blob Storage-lagringstjänst Källa NEJ
MQTT (förhandsversion) Källa JA – När strömning senast stoppades
Solace PubSub+ (förhandsversion) Källa JA – När strömning senast stoppades
Sjöhus Destination JA – När strömning senast stoppades
-Nu
– Anpassad tid
Eventhouse (Händelsebearbetning före inmatning) Destination JA – När strömning senast stoppades
-Nu
– Anpassad tid
Anpassad slutpunkt (dvs. anpassad app i standardfunktion) Destination NEJ
Eventhouse (direkt inmatning) Destination NEJ
Vävaktiverare (förhandsversion) Destination JA – När strömning senast stoppades
-Nu
– Anpassad tid
Härlett flöde Destination NEJ
Node Typ Stödjer paus och återupptagning Alternativ för återupptagning
Exempeldata Källa JA -Nu
Azure Event Hubs Källa JA – När strömning senast stoppades
-Nu
– Anpassad tid
Azure IoT Hub Källa JA – När strömning senast stoppades
-Nu
– Anpassad tid
Anpassad app Källa NEJ
Anpassad app Destination NEJ
Sjöhus Destination JA – När strömning senast stoppades
-Nu
– Anpassad tid
KQL-databas (direkt inmatning) Destination NEJ
KQL-databas (händelsebearbetning före inmatning) Destination JA – När strömning senast stoppades
-Nu
– Anpassad tid
Infrastrukturaktivator Destination JA – När strömning senast stoppades
-Nu
– Anpassad tid

Aktivera eller inaktivera alla noder

Du kan enkelt pausa eller återuppta all datatrafik i Eventstream genom att välja alternativet Aktivera alla eller Inaktivera alla i menyraden. När du väljer Aktivera allakan de tillgängliga alternativen för återupptagning skilja sig beroende på de källor och destinationer som du har konfigurerat i din händelseström. Se den detaljerade tabellen i föregående avsnitt för specifika återuppta-alternativ för varje nod. Den här åtgärden återupptar eller pausar all datatrafik som flödar in eller ut ur Eventstream. Den gäller endast för noder som stöder paus- och återuppta-funktioner. För noder som för närvarande inte stöder den här funktionen kan datatrafiken inte pausas.

Skärmbild som visar hur du aktivt eller inaktiverar alla noder samtidigt.

Limitation

  • Efter CI/CD (Git-integrering och distributionspipeline) blir alla resurser i målhändelseströmmen aktiva, såvida de inte misslyckas på grund av anslutningsproblem eller konfigurationsproblem. Resurserna i den ursprungliga händelseströmmen (exporteras till Git) och i den händelseström som distribueras behåller de sina tillstånd.