What problem does it solve?
This Skill eliminates the tedious, error-prone manual work of building and deploying Microsoft Fabric Eventstream real-time event streaming topologies via raw REST API calls, saving hours of development, testing, and debugging time for data engineers and analytics professionals.
Core Features & Use Cases
- 25 Supported Source Types: Ingest real-time data from Event Hubs, IoT Hub, CDC connectors, Kafka, Sample Data, and 20 other supported sources.
- 8 Transformation Operators: Apply Filter, Aggregate, GroupBy, Join, ManageFields, Union, Expand, and SQL transformations to process event streams in real time.
- 4 Destination Types: Route processed events to Lakehouse Delta, Eventhouse, Activator, or Custom Endpoints for downstream use.
- CDC & Fan-Out Support: Add CDC sources with SQL-based Debezium payload flattening, and assemble multi-table fan-out routing for complex ingestion workflows.
- Full Lifecycle Management: Create, update, delete, and publish Eventstream topologies end-to-end via the Fabric Items REST API.
For example, you can use this Skill to build an IoT sensor ingestion pipeline that pulls data from Event Hubs, filters out invalid readings, aggregates metrics by device, and routes results to both a Lakehouse for historical storage and an Activator for real-time alerts.
Quick Start
Use the eventstream-authoring-cli skill to create and publish a new Eventstream topology that ingests IoT sensor data from Event Hubs, filters for temperature readings above 30 degrees, and routes the results to a Lakehouse Delta table.