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 ú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.
Související obsah
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.
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í.