Sdílet prostřednictvím


Přidání a správa zdroje událostí v eventstreamu

Jakmile vytvoříte eventstream, můžete ho připojit k různým zdrojům dat a cílům.

Poznámka:

Vylepšené funkce jsou ve výchozím nastavení povolené při vytváření eventstreamů. Pokud máte streamy událostí vytvořené pomocí standardních funkcí, budou tyto streamy událostí dál fungovat. Pořád je můžete upravovat a používat jako obvykle. Doporučujeme vytvořit nový stream událostí, který nahradí standardní streamy událostí, abyste mohli využívat další možnosti a výhody rozšířených streamů událostí.

Jakmile vytvoříte eventstream, můžete ho připojit k různým zdrojům a cílům dat.

Eventstream umožňuje nejen streamovat data ze zdrojů Microsoftu, ale také podporuje příjem dat z platforem třetích stran, jako je Google Cloud a Amazon Kinesis, s novými konektory pro zasílání zpráv. Tato rozšířená funkce nabízí bezproblémovou integraci externích datových proudů do prostředků infrastruktury a poskytuje větší flexibilitu a umožňuje získat přehledy z více zdrojů v reálném čase.

V tomto článku se dozvíte o zdrojích událostí, které můžete přidat do streamu událostí.

Požadavky

  • Přístup k pracovnímu prostoru v režimu licence kapacity Fabric (nebo) zkušebním režimu licence s oprávněními Přispěvatel nebo vyšší.
  • Požadavky specifické pro každý zdroj, který je zdokumentovaný v následujících článcích specifických pro zdroj.

Podporované zdroje

Streamy událostí infrastruktury s vylepšenými možnostmi podporují následující zdroje. Každý článek obsahuje podrobnosti a pokyny pro přidání konkrétních zdrojů.

Zdroje Popis
Azure Event Hubs Pokud máte centrum událostí Azure, můžete ingestovat data centra událostí do Microsoft Fabric pomocí eventstreamu.
Azure IoT Hub Pokud máte centrum Azure IoT, můžete ingestovat data IoT do Microsoft Fabric pomocí eventstreamu.
Azure SQL Database Change Data Capture (CDC) Zdrojový konektor Azure SQL Database CDC umožňuje zachytit snímek aktuálních dat v databázi Azure SQL. Konektor pak monitoruje a zaznamenává všechny budoucí změny na úrovni řádků na těchto datech.
Databáze PostgreSQL – CDC Zdrojový konektor PostgreSQL Database Change Data Capture (CDC) umožňuje zachytit snímek aktuálních dat v databázi PostgreSQL. Konektor pak monitoruje a zaznamenává všechny budoucí změny na úrovni řádků na těchto datech.
CdC databáze MySQL Zdrojový konektor Azure MySQL Database Change Data Capture (CDC) umožňuje zachytit snímek aktuálních dat v databázi Azure Database for MySQL. Můžete určit tabulky, které se mají monitorovat, a eventstream zaznamenává všechny budoucí změny na úrovni řádků v tabulkách.
Azure Cosmos DB CDC Zdrojový konektor Azure Cosmos DB Change Data Capture (CDC) pro streamy událostí Microsoft Fabric umožňuje zachytit snímek aktuálních dat v databázi Azure Cosmos DB. Konektor pak monitoruje a zaznamenává všechny budoucí změny na úrovni řádků na těchto datech.
SQL Server na virtuálním počítači (DATABÁZE) CDC Zdrojový konektor SQL Serveru na databázi virtuálních počítačů (CDC) pro streamy událostí Fabric umožňuje zachytit snímek aktuálních dat v databázi SQL Serveru na virtuálním počítači. Konektor pak monitoruje a zaznamenává všechny budoucí změny na úrovni řádků dat.
Azure SQL Managed Instance CDC Zdrojový konektor Azure SQL Managed Instance CDC pro streamy událostí Microsoft Fabric umožňuje zachytit snímek aktuálních dat v databázi služby SQL Managed Instance. Konektor pak monitoruje a zaznamenává všechny budoucí změny na úrovni řádků na těchto datech.
Google Cloud Pub/Sub Google Pub/Sub je služba zasílání zpráv, která umožňuje publikovat a odebírat streamy událostí. Do streamu událostí můžete přidat Google Pub/Sub jako zdroj, abyste mohli zaznamenávat, transformovat a směrovat události v reálném čase do různých cílů v Prostředcích infrastruktury.
Datové proudy Amazon Kinesis Amazon Kinesis Data Streams je široce škálovatelná, vysoce odolná služba pro příjem dat a zpracování optimalizovaná pro streamovaná data. Integrací datových proudů Amazon Kinesis jako zdroje v rámci streamu událostí můžete bez problémů zpracovávat datové proudy v reálném čase, než je směrujete do více cílů v rámci fabric.
Confluent Cloud Kafka Confluent Cloud Kafka je streamovací platforma nabízející výkonné funkce streamování a zpracování dat pomocí Apache Kafka. Integrací Confluent Cloud Kafka jako zdroje v rámci eventstreamu můžete bez problémů zpracovávat datové proudy v reálném čase, než je směrujete do více cílů v rámci fabric.
Amazon MSK Kafka Amazon MSK Kafka je plně spravovaná služba Kafka, která zjednodušuje nastavení, škálování a správu. Integrací Amazon MSK Kafka jako zdroje ve vašem eventstreamu můžete bezproblémově přenést události v reálném čase z MSK Kafka a zpracovat je před jejich směrováním do více cílů v rámci Fabric. 
Ukázková data Jako ukázkový zdroj dat můžete zvolit události Kolo, Žlutá taxi nebo Burzovní trh a otestovat příjem dat při nastavování eventstreamu.
Vlastní koncový bod (tedy vlastní aplikace ve standardních funkcích) Funkce vlastního koncového bodu umožňuje vašim aplikacím nebo klientům Kafka připojit se k Eventstreamu pomocí připojovací řetězec, což umožňuje hladký příjem streamovaných dat do eventstreamu.
Azure Service Bus (Preview) Pomocí eventstreamu můžete ingestovat data z fronty služby Azure Service Bus nebo odběru tématu do Microsoft Fabric.
Apache Kafka (Preview) Apache Kafka je opensourcová distribuovaná platforma pro vytváření škálovatelných datových systémů v reálném čase. Díky integraci Apache Kafka jako zdroje do eventstreamu můžete bezproblémově přenést události v reálném čase z Apache Kafka a zpracovat je před jejich směrováním do více cílů v rámci infrastruktury.
Události služby Azure Blob Storage (Preview) Události služby Azure Blob Storage se aktivují, když klient vytvoří, nahradí nebo odstraní objekt blob. Konektor umožňuje propojit události služby Blob Storage s událostmi infrastruktury v centru v reálném čase. Tyto události můžete převést na průběžné datové proudy a transformovat je před jejich směrováním do různých cílů v prostředcích infrastruktury.
Události položek pracovního prostoru infrastruktury (Preview) Události položek pracovního prostoru infrastruktury jsou samostatné události prostředků infrastruktury, ke kterým dochází, když dojde ke změnám v pracovním prostoru Infrastruktury. Mezi tyto změny patří vytvoření, aktualizace nebo odstranění položky infrastruktury. Pomocí streamů událostí Fabric můžete zachytit tyto události pracovního prostoru Infrastruktury, transformovat je a směrovat je do různých cílů v prostředcích infrastruktury pro další analýzu.
události Fabric OneLake (Preview) Události OneLake umožňují přihlásit se k odběru změn v souborech a složkách ve OneLake a pak reagovat na tyto změny v reálném čase. Pomocí streamů událostí ve Fabricu můžete zachytit tyto události v OneLake, transformovat je a směrovat je do různých cílů ve Fabricu pro další analýzu. Díky této bezproblémové integraci událostí OneLake v rámci streamů událostí Fabric získáte větší flexibilitu pro monitorování a analýzu aktivit ve oneLake.
Události úlohy Fabric (náhled) Události úloh vám umožňují přihlásit se k odběru změn, které nastanou při spuštění úlohy v rámci systému Fabric. Můžete například reagovat na změny při aktualizaci sémantického modelu, spuštění naplánovaného kanálu nebo spuštění poznámkového bloku. Každá z těchto aktivit může generovat odpovídající úlohu, která pak vygeneruje sadu odpovídajících událostí úlohy. Pomocí streamů událostí Fabric můžete zachytit tyto události spojené s úlohami, transformovat je a směrovat je do různých cílů v systému Fabric pro další analýzu. Tato bezproblémová integrace událostí úloh v datových proudech událostí Fabric poskytuje větší flexibilitu při monitorování a analýze aktivit ve vaší úloze.

Poznámka:

Maximální počet zdrojů a cílů pro jeden stream událostí je 11.

Požadavky

Než začnete, musíte splnit následující požadavky:

  • Přístup k pracovnímu prostoru v režimu licence kapacity Fabric (nebo) zkušebním režimu licence s oprávněními Přispěvatel nebo vyšší.
  • Pokud chcete přidat službu Azure Event Hubs nebo Azure IoT Hub jako zdroj eventstreamu, musíte mít odpovídající oprávnění pro přístup ke svým klíčům zásad. Musí být veřejně přístupné, a ne za bránou firewall nebo zabezpečenou ve virtuální síti.

Podporované zdroje

Streamy událostí infrastruktury podporují následující zdroje. Pomocí odkazů v tabulce přejděte na články, které obsahují další podrobnosti o přidávání konkrétních zdrojů.

Zdroje Popis
Azure Event Hubs Pokud máte centrum událostí Azure, můžete ingestovat data centra událostí do Microsoft Fabric pomocí eventstreamu.
Azure IoT Hub Pokud máte centrum Azure IoT, můžete ingestovat data IoT do Microsoft Fabric pomocí eventstreamu.
Ukázková data Jako ukázkový zdroj dat můžete zvolit události Kolo, Žlutá taxi nebo Burzovní trh a otestovat příjem dat při nastavování eventstreamu.
Vlastní aplikace Funkce vlastní aplikace umožňuje vašim aplikacím nebo klientům Kafka připojit se k Eventstreamu pomocí připojovací řetězec, což umožňuje hladký příjem streamovaných dat do eventstreamu.

Poznámka:

Maximální počet zdrojů a cílů pro jeden stream událostí je 11.

Správa zdroje

  • Úpravy/odebrání: Můžete vybrat zdroj eventstreamu, který chcete upravit nebo odebrat, a to buď prostřednictvím navigačního podokna, nebo plátna. Když vyberete Upravit, otevře se podokno úprav vpravo od hlavního editoru.

    Snímek obrazovky znázorňující úpravu a odstranění zdroje

  • Znovu vygenerovat klíč pro vlastní aplikaci: Pokud chcete znovu vygenerovat nový připojovací klíč pro vaši aplikaci, vyberte na plátně jeden z vlastních zdrojů aplikací a vyberte Znovu vygenerovat nový klíč připojení.

    Snímek obrazovky znázorňující, jak znovu vygenerovat klíč