用途：该技能用于在 TypeScript 中通过 Azure Event Hubs SDK 实现高吞吐事件流和实时数据摄取，涵盖发送事件与消费事件的基本工作流。
主要能力：支持创建 EventHubProducerClient 与 EventHubConsumerClient；使用 DefaultAzureCredential 进行身份验证；创建批次并批量发送事件；按 partitionId 或 partitionKey 发送至指定分区；订阅并处理事件；使用 BlobCheckpointStore 实现检查点；从指定位置（offset、时间、@earliest、@latest）开始接收；设置 maxBatchSize 与 maxWaitTimeInSeconds 批处理选项；读取分区与 Hub 属性；为事件附加 properties、contentType、correlationId；以及在消费中处理错误与实施最佳实践。
使用方式：安装依赖 npm install @azure/event-hubs @azure/identity，配合检查点需 npm install @azure/eventhubs-checkpointstore-blob @azure/storage-blob。通过环境变量配置 EVENTHUB_NAMESPACE、EVENTHUB_NAME、STORAGE_ACCOUNT_NAME、STORAGE_CONTAINER_NAME。使用 DefaultAzureCredential 创建客户端后，生产者调用 createBatch() 与 sendBatch()，消费者调用 subscribe() 并实现 processEvents 与 processError，必要时在批处理后调用 context.updateCheckpoint()。
适用场景：实时数据摄取、遥测事件处理、多消费者组流水线、需要按分区有序或精确一次处理的流式场景。
限制：仅当任务明确匹配上述范围时使用；输出不可替代特定环境的验证、测试或专家评审；若缺少必要输入、权限、安全边界或成功标准，应停止并请求澄清。
说明：资料未提供具体收费、价格或平台效果信息。