azure-eventhub-ts
构建 Azure Event Hubs 流式应用程序
使用 Azure Event Hubs 实现高吞吐量事件摄入和实时数据处理。本技能提供用于生产者、消费者和检查点策略的 TypeScript SDK 模式。
下载技能 ZIP
在 Claude 中上传
前往 设置 → 功能 → 技能 → 上传技能
开启并开始使用
测试它
正在使用“azure-eventhub-ts”。 发送 10 个传感器的温度读数到 Event Hubs
预期结果:
成功创建并发送包含 10 个事件的批次到分区 0，分区键为 device-123
正在使用“azure-eventhub-ts”。 订阅事件并使用检查点处理
预期结果:
从分区 2 处理 5 个事件，检查点已保存在序列号 12847
正在使用“azure-eventhub-ts”。 获取 Event Hub 属性
预期结果:
Event Hub my-eventhub 有 4 个分区，最后序列号为：12847, 12850, 12849, 12851
安全审计
安全This skill contains documentation for the official Azure Event Hubs SDK for TypeScript. Static analyzer flagged Markdown code block delimiters as shell commands (false positive). All code patterns are standard Azure SDK usage: environment variable configuration, DefaultAzureCredential authentication, and Azure Storage endpoints for checkpointing. No security concerns identified.
质量评分
你能构建什么
IoT 遥测摄入
将来自数千个 IoT 设备的传感器数据流式传输到 Azure Event Hubs 进行实时处理和分析。
实时分析管道
构建事件驱动数据管道，使用检查点处理流式数据以实现精确一次语义。
事件驱动微服务
使用消费者组实现发布 - 订阅模式，用于解耦微服务通信。
试试这些提示
创建 TypeScript EventHubProducerClient，使用环境变量配置将温度传感器数据发送到 Azure Event Hubs。
实现 EventHubConsumerClient 订阅事件并记录每个接收到的事件，包括分区 ID 和时间戳。
创建事件消费者，使用 BlobCheckpointStore 在处理每批后进行检查点，带有处理瞬态故障的错误处理。
设计使用分区键发送事件的解决方案以实现设备特定排序，并从给定时间戳从特定分区消费。
最佳实践
- 始终在成功处理事件后进行检查点以确保精确一次语义
- 使用分区键为来自同一来源的相关事件维护顺序
- 完成后关闭 EventHubProducerClient 和 EventHubConsumerClient 以释放资源
避免
- 在生产环境中跳过检查点会导致重启时重复处理
- 当事件顺序对业务逻辑重要时不使用分区键
- 保持生产者或消费者客户端打开会导致资源泄漏和连接耗尽