eventstream-authoring-cli

Automate Microsoft Fabric Eventstream topology creation and deployment via the Fabric Items REST API.

14|3|Updated Mar 13, 2026
One-click install
npx skills add https://github.com/patrikborosch/AnalyticsPlatformAgents --skill eventstream-authoring-cli-patrikborosch
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: eventstream-authoring-cli
Source: https://github.com/patrikborosch/AnalyticsPlatformAgents/tree/main/creator/skills/eventstream-authoring-cli
Command: npx skills add https://github.com/patrikborosch/AnalyticsPlatformAgents --skill eventstream-authoring-cli-patrikborosch

SYSTEM DOCUMENTATION & REQUIREMENTS

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.

Frequently Asked Questions about eventstream-authoring-cli

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I automate Microsoft Fabric Eventstream deployment via REST API?

You can automate Microsoft Fabric Eventstream deployment via REST API by using a CLI skill to manage topology creation, configuration, and publishing, eliminating manual JSON construction and API call errors.

What real-time data sources can I ingest using Microsoft Fabric Eventstream?

Fabric Eventstream supports real-time data ingestion from 25 source types, including Event Hubs, IoT Hub, CDC connectors, Kafka, and Sample Data, enabling diverse streaming pipelines.

Can I apply transformations like filtering and aggregation to event streams in Microsoft Fabric?

Yes, you can apply 8 transformation operators to event streams in Microsoft Fabric, including Filter, Aggregate, GroupBy, Join, ManageFields, Union, Expand, and SQL transformations for real-time processing.

What destinations does Fabric Eventstream support for routing processed real-time events?

Fabric Eventstream routes processed real-time events to 4 destination types: Lakehouse Delta tables, Eventhouse, Activator, and Custom Endpoints for downstream analytics and alerting.

How do I manage the full lifecycle of Eventstream items in Microsoft Fabric?

You can manage the full lifecycle of Eventstream items in Microsoft Fabric by using the Fabric Items REST API to create, update, delete, and publish event streaming topologies end-to-end.

Does the Fabric Eventstream REST API support CDC sources and multi-table fan-out routing?

Yes, the Fabric Eventstream REST API supports adding CDC sources with SQL-based Debezium payload flattening and assembling multi-table fan-out routing for complex real-time ingestion workflows.