Azure Event Hubs TypeScript 技能
帮助 TypeScript 开发者构建高吞吐、可分区且支持检查点的 Azure Event Hubs 流处理应用。
文档采用 DefaultAzureCredential/Managed Identity，并通过环境变量传入命名空间、事件中心和存储配置；未见恶意行为、凭据窃取或隐蔽外传。但示例会输出事件载荷和属性，未说明敏感数据、RBAC 最小权限、数据流、用户确认、成本影响或回滚，因此扣分。
核心生产者、消费者、批处理、检查点、错误处理和关闭流程均有示例，且仓库提供 CI 与测试基础设施。静态内容存在未统一的变量名、部分示例未处理空批次、若干断言式“exactly-once”表述过强，且没有针对该技能的可执行覆盖证据；按静态上限保守评分。
描述明确面向 TypeScript/JavaScript 的 Azure Event Hubs 高吞吐、遥测和分区消费者场景，覆盖发送、消费、检查点和消费组。未充分声明非适用范围、触发边界、网络/区域前提或中文使用支持；依赖 Azure 服务和海外文档可达性也未说明，因此扣分。
主文档结构清晰，安装、环境变量、认证、核心流程和引用资料分层较好；提供 MIT、作者和 1.0.0 版本信息。缺少技能专属变更日志、维护责任、更新路径、FAQ、依赖版本约束和系统化故障排查，部分引用目标文件未在提供材料中出现，因此扣分。
内容覆盖常见 Event Hubs 编程任务，代码片段可作为起点并具有直接参考价值。由于静态审查无法验证编译和运行，且存在空数组检查、变量一致性、检查点语义和 exactly-once 说明等潜在问题，用户仍需审阅和修正，故未接近满分。
证据包括版本化技能文件、引用文档、MIT 许可、仓库 CI 工作流和测试代码，但 CI/测试材料未显示覆盖该技能的真实执行路径，也没有第三方执行结果或交叉验证；静态证据有限，按上限评分。
- 不要将“exactly-once processing”视为 SDK 自动保证；需要幂等下游操作并明确至少一次语义。
- 在生产环境补充 RBAC 最小权限、敏感事件日志脱敏、检查点失败告警、重试/死信策略和成本说明。
- 运行前核对 @azure/event-hubs 及检查点存储包的当前 API，修正变量命名、空批次和认证配置示例。
- 该技能依赖 Azure Event Hubs、Blob Storage、Azure Identity 及网络访问；未提供中国大陆可达性或区域限制说明。
它能做什么 & 适用场景
该技能面向使用 JavaScript 版 Azure Event Hubs SDK 的 TypeScript 开发者。它覆盖事件批量发送、指定分区或分区键发送、消费者订阅、事件位置、批处理参数、事件属性和错误处理。它还介绍使用 BlobCheckpointStore 进行生产环境检查点管理，以及使用 DefaultAzureCredential 或 ManagedIdentityCredential 认证。该技能属于 Microsoft/skills 集合中的独立 TypeScript 技能，集合采用 MIT 许可证并处于持续开发中。
提供安装命令、环境变量和 TypeScript 示例；创建 EventHubProducerClient 与 EventHubConsumerClient；批量发送事件并按分区 ID 或分区键路由；订阅并处理事件、错误和指定起始位置；使用 Azure Blob Storage 保存检查点；读取 Event Hub 与分区属性；配置最大批大小和等待时间；展示事件属性访问、失败时不更新检查点以及关闭客户端的做法。
- 需要把设备温度、IoT 遥测或其他结构化事件批量写入 Azure Event Hubs 的 TypeScript 开发者。
- 需要按分区消费事件并构建实时分析或事件驱动处理管道的团队。
- 需要在生产消费者中使用 Blob Storage 检查点，以便处理后恢复进度的工程师。
- 需要使用分区键保持相关事件顺序，或从最早、最新、指定偏移量或指定时间开始读取事件的开发者。
优缺点一览
- 覆盖生产级常见流程，包括批量发送、分区消费、检查点、起始位置、错误处理和客户端关闭。
- 同时提供 DefaultAzureCredential 与 ManagedIdentityCredential 的认证示例。
- 内容直接围绕 `@azure/event-hubs`，并包含可复制的 TypeScript 代码片段。
- 说明如何读取分区信息、配置批处理并监控已入队与已处理序列号之间的延迟。
- 依赖 Azure Event Hubs 和相关 Azure 资源；源材料未提供本地或离线替代方案。
- 源材料没有给出该独立技能的专门测试场景或测试结果。
- 需要开发者自行配置命名空间、事件中心、身份凭据，并在检查点场景中配置 Blob Storage。
如何安装
在项目中运行 npm install @azure/event-hubs @azure/identity。如果需要 Blob 检查点，再运行 npm install @azure/eventhubs-checkpointstore-blob @azure/storage-blob。安装整个技能集合可运行 npx skills add microsoft/skills，然后在向导中选择所需技能；README 未提供该技能在向导中的具体选择步骤。
如何使用
将该技能放入所选 Agent 的技能目录；README 以 GitHub Copilot 为例使用 .github/skills/。使用提示，例如：“请用 TypeScript 和 @azure/event-hubs 构建一个高吞吐事件生产者与分区消费者，使用 DefaultAzureCredential、批量发送和 Blob 检查点。”根据示例设置 EVENTHUB_NAMESPACE、EVENTHUB_NAME，以及启用检查点时的存储账户和容器变量。