Azure Event Hubs SDK for Rust
使用 Rust 流式传输 Azure Event Hubs 事件
在 Rust 中构建事件驱动应用程序需要可靠的事件摄取。本技能提供了用于生产者和消费者的官方 Azure Event Hubs SDK 模式。
下载技能 ZIP
在 Claude 中上传
前往 设置 → 功能 → 技能 → 上传技能
开启并开始使用
测试它
正在使用“Azure Event Hubs SDK for Rust”。 将一批传感器读数发送到 Event Hubs
预期结果:
成功发送包含 50 个事件的批次到分区 2。批次大小：4096 字节。序列号：1001-1050
正在使用“Azure Event Hubs SDK for Rust”。 从分区 0 接收带有检查点的事件
预期结果:
从分区 0 接收到 25 个事件。最后序列号：2847。检查点已保存到 blob 存储。处理时间：120ms
安全审计
安全This skill contains documentation-only content for the Azure Event Hubs Rust SDK. No executable code, scripts, or dangerous patterns detected. Static analysis scanned 0 files with 0 risk factors. The skill provides guidance on using Azure's official Rust client library for event streaming.
质量评分
你能构建什么
实时数据摄取管道
构建可扩展的事件生产者，将来自 IoT 设备或应用程序日志的流式数据摄取到 Azure Event Hubs 中进行下游处理
事件驱动微服务
实现消费者客户端以处理来自特定分区的事件，实现跨微服务实例的并行消费
遥测收集系统
部署基于 Rust 的事件收集器，具有适当的错误处理和重试逻辑，高效批处理和发送遥测数据
试试这些提示
创建一个使用 Azure Event Hubs SDK 的 Rust 函数，将带有 JSON 负载的单个事件发送到配置的事件中心
编写 Rust 代码创建事件批次，添加多个带有元数据的事件，检查批次容量，并将批次发送到 Azure Event Hubs
实现一个 Rust 消费者，为所有分区打开接收器，并发地从每个分区接收事件，并打印事件元数据
构建一个使用 ConsumerClient 和 Blob 检查点存储的 Rust 应用程序，跟踪处理进度并为分布式消费实现故障转移恢复
最佳实践
- 重用 ProducerClient 和 ConsumerClient 实例，而不是为每个操作创建新实例
- 使用批量发送而不是单个事件以提高吞吐量并减少延迟
- 运行分布式消费者时使用 Blob 存储实现检查点以确保可靠恢复
避免
- 为每个事件创建新客户端实例而不是重用连接
- 在需要吞吐量时在循环中单独发送事件而不进行批处理
- 忽略批次容量限制，这可能导致事件丢失或发送失败