Freigeben über


EventHubBufferedProducerClient.EnqueueEventAsync Methode

Definition

Überlädt

EnqueueEventAsync(EventData, CancellationToken)

Stellt eine EventData in die Warteschlange in den Puffer, der im Event Hub veröffentlicht werden soll. Wenn beim Aufrufen dieser Methode keine Kapazität im Puffer vorhanden ist, wartet sie, bis Speicherplatz verfügbar ist, und stellt sicher, dass der eventData in die Warteschlange eingereiht wurde.

Wenn dieser Aufruf zurückgibt, wurde der eventData im Puffer akzeptiert, aber es wurde möglicherweise noch nicht veröffentlicht. Die Veröffentlichung erfolgt zu einem nicht deterministischen Zeitpunkt in der Zukunft, während der Puffer verarbeitet wird.

EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken)

Stellt eine EventData in die Warteschlange in den Puffer, der im Event Hub veröffentlicht werden soll. Wenn beim Aufrufen dieser Methode keine Kapazität im Puffer vorhanden ist, wartet sie, bis Speicherplatz verfügbar ist, und stellt sicher, dass der eventData in die Warteschlange eingereiht wurde.

Wenn dieser Aufruf zurückgibt, wurde der eventData im Puffer akzeptiert, aber es wurde möglicherweise noch nicht veröffentlicht. Die Veröffentlichung erfolgt zu einem nicht deterministischen Zeitpunkt in der Zukunft, während der Puffer verarbeitet wird.

EnqueueEventAsync(EventData, CancellationToken)

Stellt eine EventData in die Warteschlange in den Puffer, der im Event Hub veröffentlicht werden soll. Wenn beim Aufrufen dieser Methode keine Kapazität im Puffer vorhanden ist, wartet sie, bis Speicherplatz verfügbar ist, und stellt sicher, dass der eventData in die Warteschlange eingereiht wurde.

Wenn dieser Aufruf zurückgibt, wurde der eventData im Puffer akzeptiert, aber es wurde möglicherweise noch nicht veröffentlicht. Die Veröffentlichung erfolgt zu einem nicht deterministischen Zeitpunkt in der Zukunft, während der Puffer verarbeitet wird.

public virtual System.Threading.Tasks.Task<int> EnqueueEventAsync (Azure.Messaging.EventHubs.EventData eventData, System.Threading.CancellationToken cancellationToken = default);
abstract member EnqueueEventAsync : Azure.Messaging.EventHubs.EventData * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>
override this.EnqueueEventAsync : Azure.Messaging.EventHubs.EventData * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>
Public Overridable Function EnqueueEventAsync (eventData As EventData, Optional cancellationToken As CancellationToken = Nothing) As Task(Of Integer)

Parameter

eventData
EventData

Das Ereignis, das in den Puffer eingereiht und später veröffentlicht werden soll.

cancellationToken
CancellationToken

Ein optionaler CancellationToken instance, um der Anforderung zu signalisieren, den Vorgang abzubrechen.

Gibt zurück

Die Gesamtanzahl der Ereignisse, die derzeit gepuffert sind und auf die Veröffentlichung warten, über alle Partitionen hinweg.

Ausnahmen

Tritt auf, wenn derzeit kein SendEventBatchFailedAsync Handler registriert ist.

Hinweise

Beim ersten Versuch, ein Ereignis in die Warteschlange zu stellen, können die SendEventBatchSucceededAsync Handler und SendEventBatchFailedAsync nicht mehr geändert werden.

Gilt für:

EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken)

Stellt eine EventData in die Warteschlange in den Puffer, der im Event Hub veröffentlicht werden soll. Wenn beim Aufrufen dieser Methode keine Kapazität im Puffer vorhanden ist, wartet sie, bis Speicherplatz verfügbar ist, und stellt sicher, dass der eventData in die Warteschlange eingereiht wurde.

Wenn dieser Aufruf zurückgibt, wurde der eventData im Puffer akzeptiert, aber es wurde möglicherweise noch nicht veröffentlicht. Die Veröffentlichung erfolgt zu einem nicht deterministischen Zeitpunkt in der Zukunft, während der Puffer verarbeitet wird.

public virtual System.Threading.Tasks.Task<int> EnqueueEventAsync (Azure.Messaging.EventHubs.EventData eventData, Azure.Messaging.EventHubs.Producer.EnqueueEventOptions options, System.Threading.CancellationToken cancellationToken = default);
abstract member EnqueueEventAsync : Azure.Messaging.EventHubs.EventData * Azure.Messaging.EventHubs.Producer.EnqueueEventOptions * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>
override this.EnqueueEventAsync : Azure.Messaging.EventHubs.EventData * Azure.Messaging.EventHubs.Producer.EnqueueEventOptions * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>
Public Overridable Function EnqueueEventAsync (eventData As EventData, options As EnqueueEventOptions, Optional cancellationToken As CancellationToken = Nothing) As Task(Of Integer)

Parameter

eventData
EventData

Das Ereignis, das in den Puffer eingereiht und später veröffentlicht werden soll.

options
EnqueueEventOptions

Der Satz von Optionen, die beim Veröffentlichen dieses Ereignisses angewendet werden sollen.

cancellationToken
CancellationToken

Ein optionaler CancellationToken instance, um der Anforderung zu signalisieren, den Vorgang abzubrechen.

Gibt zurück

Die Gesamtanzahl der Ereignisse, die derzeit gepuffert sind und auf die Veröffentlichung warten, über alle Partitionen hinweg.

Ausnahmen

Tritt auf, wenn ein ungültiger Partitionsbezeichner in optionsangegeben wurde.

Hinweise

Beim ersten Versuch, ein Ereignis in die Warteschlange zu stellen, können die SendEventBatchSucceededAsync Handler und SendEventBatchFailedAsync nicht mehr geändert werden.

Gilt für: