用途
本技能针对 Azure Event Hubs 的 .NET SDK（Azure.Messaging.EventHubs），用于通过 Azure Event Hubs 构建高吞吐的事件流发送与接收流程。
主要能力与客户端类型
- EventHubProducerClient：按批立即发送事件，适合实时发送并能完全控制批处理。
- EventHubBufferedProducerClient：后台自动批处理发送，适合高吞吐的“发出即忘”场景。
- EventHubConsumerClient：简单事件读取，仅适合原型验证，不用于生产。
- EventProcessorClient：生产环境事件处理，生产接收应始终使用它。
安装与版本
- dotnet add package Azure.Messaging.EventHubs（核心发送与简单接收）
- dotnet add package Azure.Messaging.EventHubs.Processor（带检查点的生产级接收）
- dotnet add package Azure.Identity（认证）
- dotnet add package Azure.Storage.Blobs（检查点所需）
- 当前版本：Azure.Messaging.EventHubs v5.12.2、Azure.Messaging.EventHubs.Processor v5.12.2
配置与认证
需要环境变量 EVENTHUB_FULLY_QUALIFIED_NAMESPACE 与 EVENTHUB_NAME；检查点还需 BLOB_STORAGE_CONNECTION_STRING 与 BLOB_CONTAINER_NAME。也可用连接字符串认证（EVENTHUB_CONNECTION_STRING），但不建议用于生产。生产环境建议使用 DefaultAzureCredential。所需 RBAC 角色：发送为 Azure Event Hubs Data Sender，接收为 Azure Event Hubs Data Receiver，二者兼有可用 Azure Event Hubs Data Owner。
使用方式
发送可创建批（CreateBatchAsync）并按容量限制 TryAdd，满批则发送并重建批；高吞吐场景可用缓冲生产者的 EnqueueEventAsync 与 FlushAsync。接收使用 EventProcessorClient，绑定 Blob 容器做检查点，注册 ProcessEventAsync 与 ProcessErrorAsync，通过 StartProcessingAsync 启动、StopProcessingAsync 优雅停止。分区操作可获取分区 ID、指定 PartitionId 发送或使用 PartitionKey 保证同键事件进入同一分区。EventPosition 提供 Earliest、Latest、FromOffset、FromSequenceNumber、FromEnqueuedTime 等读取起点。ASP.NET Core 中可通过 AddAzureClients 注册 EventHubProducerClient 并注入使用。
最佳实践与错误处理
接收用 EventProcessorClient；策略性检查点（按 N 条事件或时间间隔）；用分区键保序；客户端作为单例复用；使用 await using 确保释放；始终注册 ProcessErrorAsync；用 CreateBatchAsync 遵守大小限制；高吞吐用缓冲生产者。错误处理中可区分 ServiceBusy、瞬态错误（可重试）与非瞬态错误。检查点策略包括每条事件、每 N 条事件、基于时间、批处理完成后。
适用场景
适用于需要 .NET 向 Azure Event Hubs 发送事件流、或从 Event Hubs 生产级接收并处理事件的开发任务。
限制
仅当任务与上述范围明确匹配时使用；输出不能替代针对具体环境的验证、测试或专家审查；缺少必要输入、权限、安全边界或成功标准时应停下并请求澄清。相关 SDK 还包括 Azure.ResourceManager.EventHubs（管理面）与 Microsoft.Azure.WebJobs.Extensions.EventHubs（Azure Functions 绑定）。