SuperAPI AI 工具集

eventstream-authoring-cli

编程与开发

查看项目

更新于 10-16 00:32

技能介绍

用途:通过 Fabric Items REST API 以命令行方式创建、配置、更新和删除 Microsoft Fabric Eventstream 实时事件摄取与路由管道。Eventstream 与 Eventhouse 是不同工作负载,KQL 数据库操作应使用 eventhouse 相关技能。

主要能力:支持 25 种 API 源类型(如 Event Hubs、IoT 等)、8 种转换算子(Filter、Aggregate、GroupBy、Join、ManageFields、Union、Expand、SQL)和 4 种目标类型;拓扑为图结构,含 sources、streams、operators、destinations,节点通过 inputNodes 引用上游。支持 DefaultStream(自动)与 DerivedStream(算子输出)。

使用方式:首次会话需先运行 check-updates 技能。用 az rest 调用 API,必须传 --resource https://api.fabric.microsoft.com。先列出工作区并用 JMESPath 过滤解析名称到 ID,再创建空 Eventstream 或直接用 Create Item with Definition 一次性部署完整拓扑。eventstream.json 与可选的 eventstreamProperties.json 需 Base64 编码(无换行)后作为 InlineBase64 提交。更新流程为 getDefinition、解码、修改、重新编码、updateDefinition;更新返回 202,需轮询 Location 头。删除用 DELETE 返回 200。

限制与注意:拓扑必须恰好一个 DefaultStream;算子条件中 column 与 value 必须用嵌套对象,裸字符串会被静默拒绝;显示名不得含下划线和点,自定义节点名仅允许字母数字 PascalCase;CustomEndpoint 源与相关目标合计不超过 11 个;不要硬编码工作区或项目 ID;不要将 Eventstream 与 Eventhouse 混淆。eventstreamProperties.json 省略时默认 retentionTimeInDays 为 1、eventThroughputLevel 为 Low。具体源类型属性、目标节点 schema 等细节资料未完整提供。