$ loading_
Create, update, and publish Microsoft Fabric Eventstream topologies via REST APIs.
Copy the install command and let the AI configure it · recommended for beginners
Please install the "eventstream-authoring-cli" skill from askskill: 1. Download https://raw.githubusercontent.com/microsoft/skills-for-fabric/main/skills/eventstream-authoring-cli/SKILL.md 2. Save it as ~/.claude/skills/eventstream-authoring-cli/SKILL.md 3. Reload skills and tell me it's ready
Design a Microsoft Fabric Eventstream topology that reads order events from Azure Event Hubs, filters invalid records, aggregates sales by region, and writes the results to both Lakehouse Delta and Eventhouse. Output a publishable topology definition and key configuration notes.
A deployable Eventstream topology definition including sources, operators, destinations, and wiring details.
Help me create a Fabric Eventstream definition that connects to a SQL Server CDC source, uses SQL/Debezium payload flattening, extracts changes from the orders and customers tables, and routes each table's data to its own DerivedStream.
An eventstream definition plan with CDC source configuration, flattening logic, and multi-table fan-out routing.
Modify an existing Fabric Eventstream by adding a Kafka source, inserting Join and ManageFields operators, sending the result to a Custom Endpoint, and removing an unused destination. Provide the updated topology definition.
An updated Eventstream topology definition clearly showing added, changed, and removed components.
Update Check — ONCE PER SESSION (mandatory) The first time this skill is used in a session, run the check-updates skill before proceeding.
- GitHub Copilot CLI / VS Code: invoke the
check-updatesskill.- Claude Code / Cowork / Cursor / Windsurf / Codex: compare local vs remote package.json version.
- Skip if the check was already performed earlier in this session.
CRITICAL NOTES
- To find the workspace details (including its ID) from workspace name: list all workspaces and, then, use JMESPath filtering
- To find the item details (including its ID) from workspace ID, item type, and item name: list all items of that type in that workspace and, then, use JMESPath filtering
- Eventstream ≠ Eventhouse. Eventstream is a real-time event ingestion and routing pipeline. For KQL database operations, use
eventhouse-authoring-clioreventhouse-consumption-cli.
| Task | Reference | Notes |
|---|---|---|
| Finding Workspaces and Items in Fabric | COMMON-CLI.md § Finding Workspaces and Items in Fabric | Mandatory — READ link first [needed for finding workspace id by its name or item id by its name, item type, and workspace id] |
| Fabric Topology & Key Concepts | COMMON-CORE.md § Fabric Topology & Key Concepts | |
| Environment URLs | COMMON-CORE.md § Environment URLs | |
| Authentication & Token Acquisition | COMMON-CORE.md § Authentication & Token Acquisition | Wrong audience = 401; read before any auth issue |
| Core Control-Plane REST APIs | COMMON-CORE.md § Core Control-Plane REST APIs | Includes pagination, LRO polling, and rate-limiting patterns |
| Gotchas, Best Practices & Troubleshooting | COMMON-CORE.md § Gotchas, Best Practices & Troubleshooting | |
| Tool Selection Rationale | COMMON-CLI.md § Tool Selection Rationale | |
| Authentication Recipes | COMMON-CLI.md § Authentication Recipes | az login flows and token acquisition |
Fabric Control-Plane API via az rest | COMMON-CLI.md § Fabric Control-Plane API via az rest | Always pass --resource; includes pagination and LRO helpers |
| Gotchas & Troubleshooting (CLI-Specific) | COMMON-CLI.md § Gotchas & Troubleshooting (CLI-Specific) | az rest audience, shell escaping, token expiry |
| Quick Reference | COMMON-CLI.md § Quick Reference | az rest template + token audience/tool matrix |
| Eventstream Resource Model | EVENTSTREAM-AUTHORING-CORE.md § Eventstream Resource Model | Read first — graph-based topology with sources, operators, streams, destinations |
| Source Configuration | EVENTSTREAM-AUTHORING-CORE.md § Source Configuration | 25 API-supported source types with per-source properties |
| Transformation Operators | EVENTSTREAM-AUTHORING-CORE.md § Transformation Operators | 8 operator types: Filter, Aggregate, GroupBy, Join, ManageFields, Union, Expand, SQL |
| Destination Configuration | EVENTSTREAM-AUTHORING-CORE.md § Destination Configuration | 4 API-supported destination types with node schema |
…
Inspect Fabric alerts, notifications, and automated actions via read-only API calls.
Run authoring T-SQL for Fabric warehouses and SQL endpoints from CLI.
Monitor, inspect, and query Fabric Dataflows Gen2 through a read-only CLI.
Query Fabric Eventhouse data, analyze time series, and monitor ingestion health.
Migrate Databricks notebooks, jobs, and paths into Microsoft Fabric.
List, inspect, and validate Microsoft Fabric Eventstream topology and configuration.
Author and manage Fabric Dataflows Gen2 with preview and refresh via CLI.
Create Fabric alerts, notifications, and event-driven automated actions.
Run read-only T-SQL queries on Fabric warehouse and lakehouse data.
Build Fabric Spark workflows, author notebook code, and manage lakehouse resources.
Analyze Fabric warehouse performance via CLI and get optimization recommendations.
Query and operate the Sigma Streaming Platform from AI clients.