用途:面向 TypeScript 的 Azure Event Hubs SDK,用于高吞吐事件流与实时数据接入。
安装:npm install @azure/event-hubs @azure/identity;使用使用者组检查点需再安装 @azure/eventhubs-checkpointstore-blob @azure/storage-blob。
配置:通过环境变量 EVENTHUB_NAMESPACE、EVENTHUB_NAME、STORAGE_ACCOUNT_NAME、STORAGE_CONTAINER_NAME 提供命名空间、事件中心与存储信息。
认证:使用 DefaultAzureCredential 构造凭据,分别创建 EventHubProducerClient(生产)与 EventHubConsumerClient(消费)。
主要能力:发送事件支持 createBatch、tryAdd、sendBatch、close;可按 partitionId 或 partitionKey 定向分区;消费端通过 subscribe 的 processEvents/processError 处理事件,支持简单消费与生产级检查点(BlobCheckpointStore + updateCheckpoint)。可指定 startPosition(offset 为 @earliest、@latest、具体 offset 或 enqueuedOn 时间)。可读取事件中心属性 getEventHubProperties 与分区属性 getPartitionProperties。支持 maxBatchSize、maxWaitTimeInSeconds 分批选项。
适用场景:需要从设备或服务持续写入并实时消费事件、按分区有序处理、需要断点续读的流式数据管线。
限制:资料未提供定价、性能基准、配额、平台支持矩阵与错误重试等细节;需注意检查点依赖 Azure Blob 存储,具体环境变量与凭据需按实际部署配置。