Azure.Messaging.EventHubs (.NET)
使用 Azure Event Hubs 构建事件流
此技能帮助开发者将 Azure Event Hubs 集成到 .NET 应用程序中,实现实时事件流传输,支持可扩展的发布 - 订阅消息传递和事件驱动架构。
下载技能 ZIP
在 Claude 中上传
前往 设置 → 功能 → 技能 → 上传技能
开启并开始使用
测试它
正在使用“Azure.Messaging.EventHubs (.NET)”。 展示如何在 .NET 中创建 Event Hubs 生产者
预期结果:
要在 .NET 中创建 Event Hubs 生产者,请使用 Azure.Messaging.EventHubs 包中的 EventHubProducerClient。首先安装 NuGet 包,然后使用连接字符串和 Hub 名称创建生产者实例。生产者可以发送单个事件或事件批次。完成后请记得释放生产者或使用 'using' 语句进行自动清理。
正在使用“Azure.Messaging.EventHubs (.NET)”。 解释 Event Hubs 中的分区和消费者组
预期结果:
分区是 Event Hubs 中的基本并行单元。每个分区包含一个事件序列并可独立处理。消费者组是维护自己在流中位置的逻辑订阅者。多个消费者组使不同的消费者能够独立读取相同的事件。对于有序处理,所有相关事件应使用分区键发送到同一分区。
安全审计
安全This is a prompt-only skill with no executable code. The static analyzer scanned 0 files (0 lines) and detected no security issues. The skill provides guidance on Azure Event Hubs .NET SDK usage through prompts and documentation. No dangerous patterns, network requests, filesystem access, environment variable usage, or external command execution were detected.
质量评分
你能构建什么
构建事件驱动微服务
创建通过事件流进行通信的松散耦合微服务,实现可扩展的分布式系统
实现实时数据管道
实时处理来自 IoT 设备、点击流或日志聚合的流式数据
现代化传统消息系统
通过 Event Hubs 集成从传统消息队列迁移到事件流
试试这些提示
展示如何在 .NET 中创建 Event Hubs 生产者以向特定 Hub 发送消息。
创建一个处理事件并保存检查点的 Event Hubs 消费者以实现可靠处理。
生成批量发布事件的代码以提高吞吐量和性能。
解释如何实现分区路由策略以进行有序事件处理。
最佳实践
- 对相关事件使用分区键以维护分区内的顺序
- 在消费者中实现检查点以支持故障后恢复
- 在高吞吐场景中使用批量发布以减少网络开销
避免
- 不要为每条消息创建新的生产者——重用生产者实例
- 避免在接收回调中同步处理事件——使用异步处理
- 实现检查点时不要忽略 PartitionContext 以确保可靠处理