Azure Event Hubs Go SDK (azeventhubs) を使用して最新のイベントを利用するにはどうすればよいですか?

php エディター Strawberry は、Azure Event Hubs Go SDK (azeventhubs) を使用して最新のイベントを使用する方法に関するガイドを提供します。 Azure Event Hubs は、大量のイベント データの処理に使用できる、スケーラビリティの高いリアルタイム データ転送サービスです。このガイドでは、azeventhubs パッケージを使用して Azure Event Hubs と対話する方法について説明し、最新のイベント機能を使用してリアルタイム データを取得する方法を示します。この記事のガイダンスに従って、Go アプリケーションで Azure Event Hubs を簡単に使用し、最新のイベント機能を活用してリアルタイム データを取得および処理できるようになります。

質問の内容

azure-event-hubs-go/v3 から新しい azeventhubs Go SDK に移行しています。古いバージョンの SDK には、イベントの消費を開始する場所を指定できる ReceiveOption パラメーターがありました。

新しい SDK では、次のコードを使用してプロセッサを初期化します:

リーリー

ただし、イベントは最後に送信されたイベントではなく、最後のチェックポイントから消費されることに気付きました。

私が試したこと: ConsumingEventsUsingConsumerClient と ConsumingEventsWithCheckpoints の例を試しましたが、どちらも同じように動作し、最新のチェックポイントではなく最後のチェックポイントからイベントを消費します。

私の期待: プロセッサが、メッセージを毎秒送信するデバイスから送信された最新のイベントの使用を開始するようにしたいと考えています。 azeventhubs Go SDK を使用してこの動作を実現するにはどうすればよいですか?

解決策

当初、AMQP の基礎となるメカニズムを理解するのは困難でした。しかしながら、問題が無事に解決されたことをご報告させていただきます。

リーリー

Azure カスタマー サポート サービス チームの貴重な支援に感謝の意を表します。

以上がAzure Event Hubs Go SDK (azeventhubs) を使用して最新のイベントを利用するにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。