azure-eventhub-ts
建構 Azure Event Hubs 串流應用程式
使用 Azure Event Hubs 實現高吞吐量事件擷取和即時資料處理。此技能提供 TypeScript SDK 模式，適用於生產者、使用者以及檢查點策略。
تنزيل ZIP المهارة
رفع في Claude
اذهب إلى Settings → Capabilities → Skills → Upload skill
فعّل وابدأ الاستخدام
اختبرها
استخدام "azure-eventhub-ts". Send temperature readings from 10 sensors to Event Hubs
النتيجة المتوقعة:
已成功建立並傳送 10 個事件的批次至分割區 0，分割區金鑰為 device-123
استخدام "azure-eventhub-ts". Subscribe to events and process with checkpointing
النتيجة المتوقعة:
正在處理來自分割區 2 的 5 個事件，檢查點已儲存在序號 12847
استخدام "azure-eventhub-ts". Get Event Hub properties
النتيجة المتوقعة:
Event Hub my-eventhub 有 4 個分割區，最後序號為：12847、12850、12849、12851
التدقيق الأمني
آمنThis skill contains documentation for the official Azure Event Hubs SDK for TypeScript. Static analyzer flagged Markdown code block delimiters as shell commands (false positive). All code patterns are standard Azure SDK usage: environment variable configuration, DefaultAzureCredential authentication, and Azure Storage endpoints for checkpointing. No security concerns identified.
درجة الجودة
ماذا يمكنك بناءه
IoT 遙測資料擷取
將數千個 IoT 裝置的感測器資料串流至 Azure Event Hubs，以進行即時處理和分析。
即時分析管線
建構使用檢查點實現精確一次語義的事件驅動資料管線來處理串流資料。
事件驅動微服務
使用使用者群組實作發布-訂閱模式以進行去耦合的微服務通訊。
جرّب هذه الموجهات
建立 TypeScript EventHubProducerClient，使用環境變數進行設定，將溫度感測器資料傳送至 Azure Event Hubs。
實作 EventHubConsumerClient 來訂閱事件，並記錄每個收到的事件及其分割區 ID 和時間戳記。
建立事件消費者，在處理每個批次後使用 BlobCheckpointStore 進行檢查點，並針對暫時性失敗進行錯誤處理。
設計解決方案，使用分割區金鑰傳送事件以實現裝置特定排序，並從指定時間戳記開始消費特定分割區的事件。
أفضل الممارسات
- 在成功處理事件後務必進行檢查點，以確保精確一次語義
- 使用分割區金鑰維護來自相同來源之相關事件的排序
- 在完成後關閉 EventHubProducerClient 和 EventHubConsumerClient 以釋放資源
تجنب
- 在正式環境中跳過檢查點會導致重新啟動時的重複處理
- 當事件排序對業務邏輯很重要時不使用分割區金鑰
- 保持生產者或消費者用戶端開啟會導致資源洩漏和連線耗盡