Compétences azure-eventhub-ts
📦

azure-eventhub-ts

Sûr

Azure Event Hubs ストリーミングアプリケーションの構築

Azure Event Hubs を使用した高スループットのイベント取り込みとリアルタイムデータ処理を実装します。このスキルでは、プロデューサー、コンシューマー、チェックポイント戦略のための TypeScript SDK パターンを提供します。

Prend en charge: Claude Codex Code(CC)
🥉 75 Bronze
1

Télécharger le ZIP du skill

2

Importer dans Claude

Allez dans Paramètres → Capacités → Skills → Importer un skill

3

Activez et commencez à utiliser

Tester

Utilisation de "azure-eventhub-ts". 10 個のセンサーからの温度読み取り値を Event Hubs に送信する

Résultat attendu:

10 個のイベントバッチが作成され、パーティションキー device-123 でパーティション 0 に正常に送信されました

Utilisation de "azure-eventhub-ts". イベントを購読してチェックポイントで処理する

Résultat attendu:

パーティション 2 から 5 個のイベントを処理中、シーケンス番号 12847 でチェックポイントが保存されました

Utilisation de "azure-eventhub-ts". Event Hub のプロパティを取得する

Résultat attendu:

Event Hub my-eventhub には 4 つのパーティションがあり、最後のシーケンス番号は次の通りです：12847、12850、12849、12851

Audit de sécurité

Sûr
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
Fichiers analysés
274
Lignes analysées
0
résultats
1
Total des audits
Aucun problème de sécurité trouvé
Audité par: claude

Score de qualité

38
Architecture
100
Maintenabilité
87
Contenu
50
Communauté
100
Sécurité
100
Conformité aux spécifications

Ce que vous pouvez construire

IoT テレメトリ取り込み

数千の IoT デバイスからのセンサーデータを Azure Event Hubs にストリーミングして、リアルタイム処理と分析を行います。

リアルタイム分析パイプライン

正確に 1 回のセマンティクスを実現するためのチェックポイントを備えた、ストリーミングデータを処理するイベント駆動データパイプラインを構築します。

イベント駆動マイクロサービス

コンシューマーグループを使用して、分離されたマイクロサービス通信のための発行 - 購読パターンを実装します。

Essayez ces prompts

基本イベントプロデューサーのセットアップ 
環境変数を設定に使用して、温度センサーデータを Azure Event Hubs に送信する TypeScript EventHubProducerClient を作成してください。
ログ出力付きイベントコンシューマー 
イベントを購読し、受信した各イベントをパーティション ID とタイムスタンプと共にログ出力する EventHubConsumerClient を実装してください。
チェックポイント付きプロダクションコンシューマー 
各バッチの処理後にチェックポイントを行うために BlobCheckpointStore を使用し、一時的な障害に対するエラー処理を備えたイベントコンシューマーを作成してください。
パーティション対応イベント処理 
デバイス固有の順序を保証するためにパーティションキーを使用してイベントを送信し、指定されたタイムスタンプから特定のパーティションから消費するソリューションを設計してください。

Bonnes pratiques

  • 正確に 1 回のセマンティクスを確保するために、イベント処理の成功後に必ずチェックポイントを行う
  • 同じソースからの関連イベントの順序を維持するためにパーティションキーを使用する
  • 完了時に EventHubProducerClient と EventHubConsumerClient をクローズしてリソースを解放する

Éviter

  • 本番環境でチェックポイントをスキップすると、再起動時に重複処理が発生する
  • ビジネスロジックでイベント順序が重要な場合にパーティションキーを使用しない
  • プロデューサーまたはコンシューマークライアントを開いたままにすると、リーソースリークと接続枯渇を引き起こす

Foire aux questions

パーティション ID とパーティションキーの違いは何ですか？
パーティション ID は特定のパーティションを直接ターゲットにします。パーティションキーは一貫性のあるハッシュを使用して関連イベントを順序保証のために同じパーティションにルーティングします。
いつチェックポイントを使用すべきですか？
処理済みイベントを追跡するために本番環境ではチェックポイントを使用してください。正確に 1 回の処理を可能にし、コンシューマーが再起動後に最後の成功したポジションから再開できます。
メッセージ処理障害をどのように処理すればよいですか？
処理失敗時にはチェックポイントを行わないでください。イベントは次のコンシューマー開始時に再処理されます。エラーをログ出力し、必要に応じてリトライロジックを実装してください。
どのような認証方法がサポートされていますか？
このスキルはマネージド ID、環境認証情報、Azure CLI、Visual Studio 認証情報をサポートする DefaultAzureCredential を使用して、柔軟な認証を提供します。
特定の時点からイベントを読み取るにはどうすればよいですか？
Date オブジェクトに設定された enqueuedOn で startPosition オプションを使用するか、特定のオフセット値または @earliest/@latest でオフセットベースのポジショニングを使用してください。
コンシューマーグループの目的は何ですか？
コンシューマーグループを使用すると、複数の独立したアプリケーションがそれぞれのペースで同じイベントストリームを読み取ることができます。各コンシューマーグループは独自のチェックポイントポジションを維持します。

Détails du développeur

Auteur

sickn33

Licence

MIT

Dépôt

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

Réf

main

Structure de fichiers

📄 SKILL.md