EventHubProducerClient.SendAsync メソッド

定義

名前空間:

Azure.Messaging.EventHubs.Producer

アセンブリ:

Azure.Messaging.EventHubs.dll

パッケージ:

Azure.Messaging.EventHubs v5.11.3

オーバーロード

SendAsync(EventDataBatch, CancellationToken)	バッチ処理された方法を使用して、関連付けられているイベント ハブに一連のイベントを送信します。
SendAsync(IEnumerable<EventData>, CancellationToken)	関連付けられたイベント ハブに一連のイベントを 1 回の操作として送信します。 クライアントのサイズの測定と検証に関連するオーバーヘッドを回避するために、検証は Event Hubs サービスに委任され、操作が呼び出されるまで遅延されます。 指定したイベント セットのサイズが 1 つのバッチの最大許容サイズを超えると、呼び出しは失敗します。
SendAsync(IEnumerable<EventData>, SendEventOptions, CancellationToken)	関連付けられたイベント ハブに一連のイベントを 1 回の操作として送信します。 クライアントのサイズの測定と検証に関連するオーバーヘッドを回避するために、検証は Event Hubs サービスに委任され、操作が呼び出されるまで遅延されます。 指定したイベント セットのサイズが 1 つのバッチの最大許容サイズを超えると、呼び出しは失敗します。

SendAsync(EventDataBatch, CancellationToken)

ソース:

EventHubProducerClient.cs

バッチ処理された方法を使用して、関連付けられているイベント ハブに一連のイベントを送信します。

public virtual System.Threading.Tasks.Task SendAsync (Azure.Messaging.EventHubs.Producer.EventDataBatch eventBatch, System.Threading.CancellationToken cancellationToken = default);

abstract member SendAsync : Azure.Messaging.EventHubs.Producer.EventDataBatch * System.Threading.CancellationToken -> System.Threading.Tasks.Task
override this.SendAsync : Azure.Messaging.EventHubs.Producer.EventDataBatch * System.Threading.CancellationToken -> System.Threading.Tasks.Task

Public Overridable Function SendAsync (eventBatch As EventDataBatch, Optional cancellationToken As CancellationToken = Nothing) As Task

パラメーター

eventBatch

EventDataBatch

送信するイベント データのセット。 バッチは、 を使用して CreateBatchAsync(CancellationToken)作成できます。

cancellationToken

CancellationToken

操作を取り消す要求を通知する省略可能 CancellationToken な インスタンス。

戻り値

Task

操作が完了したときに解決されるタスク。待機中に例外がスローされない場合、Event Hubs サービスは受信確認を行い、バッチの配信に対する責任を負います。

例外

InvalidOperationException

パーティション識別子とパーティション キーの両方がバッチによって指定されている場合に発生します。

注釈

発行されると、結果はアトミックになります。バッチに属するすべてのイベントが成功したか、すべて失敗したかのいずれかです。 部分的な成功は不可能です。

こちらもご覧ください

• CreateBatchAsync(CancellationToken)

SendAsync(IEnumerable<EventData>, CancellationToken)

ソース:

EventHubProducerClient.cs

関連付けられたイベント ハブに一連のイベントを 1 回の操作として送信します。 クライアントのサイズの測定と検証に関連するオーバーヘッドを回避するために、検証は Event Hubs サービスに委任され、操作が呼び出されるまで遅延されます。 指定したイベント セットのサイズが 1 つのバッチの最大許容サイズを超えると、呼び出しは失敗します。

public virtual System.Threading.Tasks.Task SendAsync (System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.EventData> eventBatch, System.Threading.CancellationToken cancellationToken = default);

abstract member SendAsync : seq<Azure.Messaging.EventHubs.EventData> * System.Threading.CancellationToken -> System.Threading.Tasks.Task
override this.SendAsync : seq<Azure.Messaging.EventHubs.EventData> * System.Threading.CancellationToken -> System.Threading.Tasks.Task

Public Overridable Function SendAsync (eventBatch As IEnumerable(Of EventData), Optional cancellationToken As CancellationToken = Nothing) As Task

パラメーター

eventBatch

IEnumerable<EventData>

送信するイベント データのセット。

cancellationToken

CancellationToken

操作を取り消す要求を通知する省略可能 CancellationToken な インスタンス。

戻り値

Task

操作が完了したときに解決されるタスク。待機中に例外がスローされない場合、Event Hubs サービスは受信を確認し、一連のイベントをパーティションに配信する責任を負います。

例外

EventHubsException

イベント のセットが、Event Hubs サービスによって決定される 1 つのバッチで許可される最大サイズを超えたときに発生します。 Reasonこの場合、 は にMessageSizeExceeded設定されます。

SerializationException

の eventBatch イベントの 1 つに、シリアル化でサポートされていない型のメンバーがコレクションに Properties 含まれている場合に発生します。 詳細については、 Properties 解説を参照してください。

注釈

発行されると、結果はアトミックになります。セットに属するすべてのイベントが成功したか、すべて失敗しました。 部分的な成功は不可能です。

こちらもご覧ください

• CreateBatchAsync(CancellationToken)
• SendAsync(IEnumerable<EventData>, SendEventOptions, CancellationToken)
• SendAsync(EventDataBatch, CancellationToken)

SendAsync(IEnumerable<EventData>, SendEventOptions, CancellationToken)

ソース:

EventHubProducerClient.cs

関連付けられたイベント ハブに一連のイベントを 1 回の操作として送信します。 クライアントのサイズの測定と検証に関連するオーバーヘッドを回避するために、検証は Event Hubs サービスに委任され、操作が呼び出されるまで遅延されます。 指定したイベント セットのサイズが 1 つのバッチの最大許容サイズを超えると、呼び出しは失敗します。

public virtual System.Threading.Tasks.Task SendAsync (System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.EventData> eventBatch, Azure.Messaging.EventHubs.Producer.SendEventOptions options, System.Threading.CancellationToken cancellationToken = default);

abstract member SendAsync : seq<Azure.Messaging.EventHubs.EventData> * Azure.Messaging.EventHubs.Producer.SendEventOptions * System.Threading.CancellationToken -> System.Threading.Tasks.Task
override this.SendAsync : seq<Azure.Messaging.EventHubs.EventData> * Azure.Messaging.EventHubs.Producer.SendEventOptions * System.Threading.CancellationToken -> System.Threading.Tasks.Task

Public Overridable Function SendAsync (eventBatch As IEnumerable(Of EventData), options As SendEventOptions, Optional cancellationToken As CancellationToken = Nothing) As Task

パラメーター

eventBatch

IEnumerable<EventData>

送信するイベント データのセット。

options

SendEventOptions

このバッチを送信するときに考慮するオプションのセット。

cancellationToken

CancellationToken

操作を取り消す要求を通知する省略可能 CancellationToken な インスタンス。

戻り値

Task

操作が完了したときに解決されるタスク。待機中に例外がスローされない場合、Event Hubs サービスは受信を確認し、一連のイベントをパーティションに配信する責任を負います。

例外

InvalidOperationException

でパーティション識別子とパーティション キーの両方が指定されている場合に発生します options。

EventHubsException

イベント のセットが、Event Hubs サービスによって決定される 1 つのバッチで許可される最大サイズを超えたときに発生します。 Reasonこの場合、 は にMessageSizeExceeded設定されます。

SerializationException

の eventBatch イベントの 1 つに、シリアル化でサポートされていない型のメンバーがコレクションに Properties 含まれている場合に発生します。 詳細については、 Properties 解説を参照してください。

注釈

発行されると、結果はアトミックになります。セットに属するすべてのイベントが成功したか、すべて失敗しました。 部分的な成功は不可能です。

こちらもご覧ください

• CreateBatchAsync(CreateBatchOptions, CancellationToken)
• SendAsync(IEnumerable<EventData>, CancellationToken)
• SendAsync(EventDataBatch, CancellationToken)