PartitionSender クラス

定義

名前空間:

Microsoft.Azure.EventHubs

アセンブリ:

Microsoft.Azure.EventHubs.dll

パッケージ:

Microsoft.Azure.EventHubs v4.3.2

ソース:

PartitionSender.cs

この送信側クラスは、特定の EventHub パーティションにイベントを送信する論理的な表現です。 特定のパーティションへのイベントの送信を気にしない場合は、このクラスを使用しないでください。代わりに を使用 SendAsync(EventData)します。

public sealed class PartitionSender : Microsoft.Azure.EventHubs.ClientEntity

type PartitionSender = class
    inherit ClientEntity

Public NotInheritable Class PartitionSender
Inherits ClientEntity

継承

Object

ClientEntity

PartitionSender

プロパティ

ClientId	クライアント ID を取得します。 (継承元 ClientEntity)
EventHubClient	この PartitionSender に関連付けられている を EventHubClient 取得します。
IsClosed	クライアント オブジェクトが閉じているかどうかを表すブール値を返します。 (継承元 ClientEntity)
PartitionId	この PartitionSenderのパーティション ID を取得します。
RegisteredPlugins	このクライアントの現在登録されているプラグインの一覧を取得します。 (継承元 ClientEntity)
RetryPolicy	ClientEntity の を RetryPolicy 取得します。 (継承元 ClientEntity)

メソッド

Close()	ClientEntity を閉じます。 (継承元 ClientEntity)
CloseAsync()	のリソースを閉じて解放します PartitionSender。
CreateBatch()	後で SendAsync 呼び出しのためにイベント データ オブジェクトを追加できるバッチを作成します。
CreateBatch(BatchOptions)	後で SendAsync 呼び出しのためにイベント データ オブジェクトを追加できるバッチを作成します。
OnRetryPolicyUpdate()	再試行ポリシーの更新のためにオーバーライドする派生エンティティ。 (継承元 ClientEntity)
RegisterPlugin(EventHubsPlugin)	EventHubsPluginこのクライアントで使用する を登録します。 (継承元 ClientEntity)
SendAsync(EventData)	特定の EventHub パーティションに送信 EventData します。 ターゲット パーティションは、この PartitionSender の作成時に事前に決定されます。 この送信パターンは、一般提供と待機時間に対するデータの相関関係を強調しています。 EventHubs に送信する方法は 3 つあります。各方法はメソッドとして公開されています (sendBatch オーバーロードと共に)。 i. SendAsync(EventData) または SendAsync(IEnumerable<EventData>) ii. SendAsync(EventData, String) または SendAsync(IEnumerable<EventData>, String) iii. SendAsync(EventData) または SendAsync(IEnumerable<EventData>) 次の場合は、この種類の送信を使用します。 a。 クライアントは、パーティション間でのデータの分散を直接制御したいと考えています。 この場合、クライアントは、イベント ハブ パーティションごとに少なくとも 1 つの送信者があることを確認する必要があります。 b. ユーザーは、特定のパーティションにイベントを転送するための平均としてパーティション キーを使用することはできませんが、パーティション構成とのデータ関連付けが必要です。
SendAsync(EventDataBatch)	で EventDataBatchのバッチをEventData送信します。
SendAsync(IEnumerable<EventData>)	特定の EventHub パーティションに送信 EventData します。 対象となるパーティションは、この PartitionSender の作成時に事前に決定されます。 EventHubs に送信する方法は 3 つあります。この特定の種類の送信を理解するには、同じ種類の送信であり、単一EventDataの を送信するために使用されるオーバーロード SendAsync(EventData)を参照します。 のバッチを EventData送信すると、次の場合に便利です。 i. 効率的な送信 - の EventData バッチを送信すると、EventHubs のサービスに対して作成されたセッションの数を最適に使用して、全体的なスループットが最大化されます。 ii. トランザクションで複数 EventDataの を送信しています。 ACID プロパティを実現するために、ゲートウェイ サービスは、バッチ内のすべての EventDataの を 1 つの EventHub パーティションに転送します。
ThrowIfClosed()	クライアント オブジェクトが既に閉じている場合は、例外をスローします。 (継承元 ClientEntity)
UnregisterPlugin(String)	の登録を解除します EventHubsPlugin。 (継承元 ClientEntity)

こちらもご覧ください

• CreateFromConnectionString(String)
• CreatePartitionSender(String)