azure-eventhub-ts
Azure Event Hubs ストリーミングアプリケーションの構築
Azure Event Hubs を使用した高スループットのイベント取り込みとリアルタイムデータ処理を実装します。このスキルでは、プロデューサー、コンシューマー、チェックポイント戦略のための TypeScript SDK パターンを提供します。
スキルZIPをダウンロード
Claudeでアップロード
設定 → 機能 → スキル → スキルをアップロードへ移動
オンにして利用開始
テストする
「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 にストリーミングして、リアルタイム処理と分析を行います。
リアルタイム分析パイプライン
正確に 1 回のセマンティクスを実現するためのチェックポイントを備えた、ストリーミングデータを処理するイベント駆動データパイプラインを構築します。
イベント駆動マイクロサービス
コンシューマーグループを使用して、分離されたマイクロサービス通信のための発行 - 購読パターンを実装します。
これらのプロンプトを試す
環境変数を設定に使用して、温度センサーデータを Azure Event Hubs に送信する TypeScript EventHubProducerClient を作成してください。
イベントを購読し、受信した各イベントをパーティション ID とタイムスタンプと共にログ出力する EventHubConsumerClient を実装してください。
各バッチの処理後にチェックポイントを行うために BlobCheckpointStore を使用し、一時的な障害に対するエラー処理を備えたイベントコンシューマーを作成してください。
デバイス固有の順序を保証するためにパーティションキーを使用してイベントを送信し、指定されたタイムスタンプから特定のパーティションから消費するソリューションを設計してください。
ベストプラクティス
- 正確に 1 回のセマンティクスを確保するために、イベント処理の成功後に必ずチェックポイントを行う
- 同じソースからの関連イベントの順序を維持するためにパーティションキーを使用する
- 完了時に EventHubProducerClient と EventHubConsumerClient をクローズしてリソースを解放する
回避
- 本番環境でチェックポイントをスキップすると、再起動時に重複処理が発生する
- ビジネスロジックでイベント順序が重要な場合にパーティションキーを使用しない
- プロデューサーまたはコンシューマークライアントを開いたままにすると、リーソースリークと接続枯渇を引き起こす