帮助你创建、修改并发布 Microsoft Fabric Eventstream 实时流拓扑与路由定义。
复制安装指令,让 AI 自动完成配置 · 推荐新手
请帮我安装 askskill 上的 "eventstream-authoring-cli" 技能: 1. 下载 https://raw.githubusercontent.com/microsoft/skills-for-fabric/main/plugins/fabric-skills/skills/eventstream-authoring-cli/SKILL.md 2. 保存为 ~/.claude/skills/eventstream-authoring-cli/SKILL.md 3. 装好后重载技能,告诉我可以用了
请为 Microsoft Fabric 生成一个 Eventstream 定义:从 Azure Event Hubs 读取订单事件,先过滤无效记录,再按地区聚合销售额,最后分别写入 Lakehouse Delta 和 Eventhouse。请输出可发布的拓扑结构说明与关键配置字段。
一份可用于创建 Eventstream 的拓扑定义,包含源、算子、目标和连接关系说明。
请在现有 Eventstream 中新增一个 SQL Server CDC 数据源,使用 Debezium 风格消息结构,并通过 SQL 或字段管理方式展开 payload,提取 after 内的业务字段后发送到 DerivedStream。请给出修改后的定义。
更新后的 Eventstream 定义,展示 CDC 源配置、字段展开逻辑和新的路由关系。
我有一个 CDC 事件流,包含 customers、orders、payments 三张表。请设计一个 Eventstream 拓扑,按表名分流到不同的 DerivedStream,并分别写入对应目标;同时保留一条 DefaultStream 作为统一审计流。请输出完整方案。
一套多表分流的 Eventstream 设计方案,包含分流规则、各分支目标及默认审计流配置。
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 |
…