المهارات azure-eventhub-ts
📦

azure-eventhub-ts

آمن

Build Azure Event Hubs streaming applications

Implement high-throughput event ingestion and real-time data processing with Azure Event Hubs. This skill provides TypeScript SDK patterns for producers, consumers, and checkpointing strategies.

يدعم: Claude Codex Code(CC)
🥉 75 برونزي
1

تنزيل ZIP المهارة

2

رفع في Claude

اذهب إلى Settings → Capabilities → Skills → Upload skill

3

فعّل وابدأ الاستخدام

اختبرها

استخدام "azure-eventhub-ts". Send temperature readings from 10 sensors to Event Hubs

النتيجة المتوقعة:

Batch of 10 events created and sent successfully to partition 0 with partition key device-123

استخدام "azure-eventhub-ts". Subscribe to events and process with checkpointing

النتيجة المتوقعة:

Processing 5 events from partition 2, checkpoint saved at sequence number 12847

استخدام "azure-eventhub-ts". Get Event Hub properties

النتيجة المتوقعة:

Event Hub my-eventhub has 4 partitions with last sequence numbers: 12847, 12850, 12849, 12851

التدقيق الأمني

آمن
v1 • 2/24/2026

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.

1
الملفات التي تم فحصها
274
الأسطر التي تم تحليلها
0
النتائج
1
إجمالي عمليات التدقيق
لا توجد مشكلات أمنية
تم تدقيقه بواسطة: claude

درجة الجودة

38
الهندسة المعمارية
100
قابلية الصيانة
87
المحتوى
50
المجتمع
100
الأمان
100
الامتثال للمواصفات

ماذا يمكنك بناءه

IoT Telemetry Ingestion

Stream sensor data from thousands of IoT devices to Azure Event Hubs for real-time processing and analytics.

Real-Time Analytics Pipeline

Build event-driven data pipelines that process streaming data with checkpointing for exactly-once semantics.

Event-Driven Microservices

Implement publish-subscribe patterns for decoupled microservices communication using consumer groups.

جرّب هذه الموجهات

Basic Event Producer Setup 
Create a TypeScript EventHubProducerClient that sends temperature sensor data to Azure Event Hubs using environment variables for configuration.
Event Consumer with Logging 
Implement an EventHubConsumerClient that subscribes to events and logs each received event with partition ID and timestamp.
Production Consumer with Checkpointing 
Create an event consumer that uses BlobCheckpointStore for checkpointing after processing each batch, with error handling for transient failures.
Partition-Aware Event Processing 
Design a solution that sends events with partition keys for device-specific ordering and consumes from specific partitions starting from a given timestamp.

أفضل الممارسات

  • Always checkpoint after successful event processing to ensure exactly-once semantics
  • Use partition keys to maintain ordering for related events from the same source
  • Close EventHubProducerClient and EventHubConsumerClient when done to release resources

تجنب

  • Skipping checkpointing in production environments causes duplicate processing on restart
  • Not using partition keys when event ordering matters for business logic
  • Leaving producer or consumer clients open leads to resource leaks and connection exhaustion

الأسئلة المتكررة

What is the difference between partition ID and partition key?
Partition ID targets a specific partition directly. Partition key uses consistent hashing to route related events to the same partition for ordering guarantees.
When should I use checkpointing?
Use checkpointing in production to track processed events. It enables exactly-once processing and allows consumers to resume from the last successful position after restarts.
How do I handle message processing failures?
Do not checkpoint on processing failures. The events will be reprocessed on the next consumer start. Log the error and optionally implement retry logic.
What authentication methods are supported?
The skill uses DefaultAzureCredential which supports managed identity, environment credentials, Azure CLI, and Visual Studio credentials for flexible authentication.
How do I read events from a specific point in time?
Use the startPosition option with enqueuedOn set to a Date object, or use offset-based positioning with specific offset values or @earliest/@latest.
What is the purpose of consumer groups?
Consumer groups allow multiple independent applications to read the same event stream at their own pace. Each consumer group maintains its own checkpoint position.

تفاصيل المطور

المؤلف

sickn33

الترخيص

MIT

المستودع

https://github.com/sickn33/antigravity-awesome-skills/tree/main/skills/azure-eventhub-ts

مرجع

main

بنية الملفات

📄 SKILL.md