Azure Event Hubs SDK for Rust
Rust で Azure Event Hubs によるイベントストリーミング
Rust でのイベント駆動アプリケーション構築には、信頼性の高いイベント取り込みが必要です。このスキルでは、プロデューサーとコンシューマー向けの公式 Azure Event Hubs SDK パターンを提供します。
スキルZIPをダウンロード
Claudeでアップロード
設定 → 機能 → スキル → スキルをアップロードへ移動
オンにして利用開始
テストする
「Azure Event Hubs SDK for Rust」を使用しています。 センサー読み取り値のバッチを Event Hubs に送信する
期待される結果:
パーティション 2 に 50 個のイベントを含むバッチを送信しました。バッチサイズ：4096 バイト。シーケンス番号：1001-1050
「Azure Event Hubs SDK for Rust」を使用しています。 チェックポイント機能を使用してパーティション 0 からイベントを受信する
期待される結果:
パーティション 0 から 25 個のイベントを受信しました。最後のシーケンス番号：2847。チェックポイントを Blob ストレージに保存しました。処理時間：120ms
セキュリティ監査
安全This skill contains documentation-only content for the Azure Event Hubs Rust SDK. No executable code, scripts, or dangerous patterns detected. Static analysis scanned 0 files with 0 risk factors. The skill provides guidance on using Azure's official Rust client library for event streaming.
品質スコア
作れるもの
リアルタイムデータ取り込みパイプライン
スケーラブルなイベントプロデューサーを構築し、IoT デバイスやアプリケーションログからのストリーミングデータを Azure Event Hubs に取り込んでダウンストリーム処理を行う
イベント駆動マイクロサービス
コンシューマークライアントを実装して特定のパーティションからイベントを処理し、マイクロサービスインスタンス全体で並列消費を可能にする
テレメトリ収集システム
適切なエラーハンドリングと再試行ロジックを備えた Rust ベースのイベントコレクターをデプロイし、テレメトリデータを効率的にバッチ処理して送信する
これらのプロンプトを試す
Azure Event Hubs SDK を使用して、JSON ペイロードを持つ単一のイベントを設定済みのイベントハブに送信する Rust 関数を作成する
イベントバッチを作成し、メタデータを持つ複数のイベントを追加し、バッチ容量を確認して Azure Event Hubs にバッチを送信する Rust コードを記述する
すべてのパーティションに対してレシーバーを開き、各パーティションから同時にイベントを受信し、イベントメタデータを表示する Rust コンシューマーを実装する
ConsumerClient と Blob チェックポイントストアを使用して Rust アプリケーションを構築し、処理進行状況を追跡して分散消費のためのフェイルオーバーリカバリを有効にする
ベストプラクティス
- 各操作ごとに新しいインスタンスを作成するのではなく、ProducerClient と ConsumerClient インスタンスを再利用する
- スループットを向上させ、レイテンシを削減するために、個別のイベントではなくバッチ送信を使用する
- 信頼性の高いリカバリーのために分散コンシューマーを実行する際は、Blob ストレージでチェックポイントを実装する
回避
- 接続を再利用せずに、イベントごとに新しいクライアントインスタンスを作成する
- スループットが重要な場合に、バッチ処理なしでループ内で個別にイベントを送信する
- イベントの損失や送信失敗を引き起こす可能性があるバッチ容量制限を無視する