azure-eventhub-ts
Azure Event Hubs 스트리밍 애플리케이션 구축
Azure Event Hubs 를 활용한 대용량 이벤트 수집 및 실시간 데이터 처리를 구현합니다. 이 스킬은 프로듀서, 컨슈머 및 체크포인팅 전략을 위한 TypeScript SDK 패턴을 제공합니다.
تنزيل ZIP المهارة
رفع في Claude
اذهب إلى Settings → Capabilities → Skills → Upload skill
فعّل وابدأ الاستخدام
اختبرها
استخدام "azure-eventhub-ts". 10 개의 센서에서 온도 읽기 값을 Event Hubs 로 전송
النتيجة المتوقعة:
10 개의 이벤트 배치가 생성되어 파티션 키 device-123 으로 파티션 0 에 성공적으로 전송됨
استخدام "azure-eventhub-ts". 이벤트 구독 및 체크포인팅과 함께 처리
النتيجة المتوقعة:
파티션 2 에서 5 개 이벤트 처리됨, 시퀀스 번호 12847 에서 체크포인트 저장됨
استخدام "azure-eventhub-ts". Event Hub 속성 가져오기
النتيجة المتوقعة:
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 로 스트리밍하여 실시간 처리 및 분석을 수행합니다.
실시간 분석 파이프라인
정확히 한 번의 시맨틱을 위한 체크포인팅으로 스트리밍 데이터를 처리하는 이벤트 드리븐 데이터 파이프라인을 구축합니다.
이벤트 드리븐 마이크로서비스
컨슈머 그룹을 사용하여 분리된 마이크로서비스 통신을 위한 게시 - 구독 패턴을 구현합니다.
جرّب هذه الموجهات
환경 변수를 구성으로 사용하여 Azure Event Hubs 에 온도 센서 데이터를 전송하는 TypeScript EventHubProducerClient 를 생성합니다.
이벤트를 구독하고 각 수신된 이벤트를 파티션 ID 및 타임스탬프와 함께 로깅하는 EventHubConsumerClient 를 구현합니다.
각 배치 처리 후 체크포인팅을 위해 BlobCheckpointStore 를 사용하고 일시적 오류에 대한 오류 처리를 포함한 이벤트 컨슈머를 생성합니다.
디바이스별 순서를 위한 파티션 키로 이벤트를 전송하고 주어진 타임스탬프에서 특정 파티션으로부터 소비하는 솔루션을 설계합니다.
أفضل الممارسات
- 정확히 한 번의 시맨틱을 보장하기 위해 이벤트 처리 성공 후 항상 체크포인팅 수행
- 동일한 소스에서 온 관련 이벤트의 순서를 유지하기 위해 파티션 키 사용
- 완료 시 EventHubProducerClient 및 EventHubConsumerClient 를 닫아 리소스 해제
تجنب
- 프로덕션 환경에서 체크포인팅을 생략하면 재시작 시 중복 처리 발생
- 비즈니스 로직에 이벤트 순서가 중요한 경우 파티션 키를 사용하지 않음
- 프로듀서 또는 컨슈머 클라이언트를 열어두면 리소스 누수 및 연결 고갈 발생