SuperAPI AI 工具集

eventstream-consumption-cli

编程与开发

查看项目

更新于 10-16 00:32

技能介绍

用途:通过 Fabric Items REST API 列出、检查和监控 Microsoft Fabric Eventstream 实时事件摄取与路由管道,属于只读消费类技能,不用于修改拓扑或查询事件数据。

主要能力:跨工作区发现 Eventstream;获取单个 Eventstream 详情;通过 Topology API 查看运行时状态、错误信息和节点 ID;通过 getDefinition 获取并 base64 解码 eventstream.json,梳理 sources、destinations、operators、streams 节点;检查保留天数与吞吐等级;校验源与目标配置;为 Custom Endpoint 源获取 Kafka/Event Hub 连接信息。

使用方式:使用 az rest 调用,必须带 --resource https://api.fabric.microsoft.com。先用工作区列表加 JMESPath 过滤解析工作区 ID,再列出该工作区 Eventstream 并按名称过滤。定义接口用 POST .../getDefinition,拓扑接口用 GET .../topology。解码示例:az rest --method POST --url "https://api.fabric.microsoft.com/v1/workspaces/${WORKSPACE_ID}/eventstreams/${EVENTSTREAM_ID}/getDefinition" --resource "https://api.fabric.microsoft.com" --body '{}' | jq -r '.definition.parts[] | select(.path=="eventstream.json") | .payload' | base64 -d | jq .。Custom Endpoint 连接需先取 topology 中的 sourceId,再调用 GET .../sources/{sourceId}/connection,该接口需 Eventstream.ReadWrite.All 权限,会返回密钥与连接字符串,调用前应获得用户确认并对敏感字段脱敏。

适用场景:运维巡检、健康与吞吐检查、源目标配置校验、为下游分析(Eventhouse、Lakehouse、Activator、Real-Time Hub)做交叉核对。

限制:Eventstream 与 Eventhouse 是不同工作负载,KQL 查询应使用 eventhouse-consumption-cli;本技能不修改拓扑,写入需用 eventstream-authoring-cli;不能通过 Eventstream API 查询事件数据;部分预览源类型仅存在于 UI;列表响应需处理 continuationUri 分页,定义请求可能返回 202 需轮询。首次会话使用前需按资料要求执行更新检查。