EventHubBufferedProducerClient.EnqueueEventsAsync Methode
Definition
Wichtig
Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.
Überlädt
| EnqueueEventsAsync(IEnumerable<EventData>, CancellationToken) |
Quediert einen Satz von EventData in den Puffer, der im Event Hub veröffentlicht werden soll. Wenn beim Aufrufen dieser Methode nicht genügend Kapazität im Puffer vorhanden ist, wartet sie, bis Speicherplatz verfügbar ist, und stellt sicher, dass alle Wenn dieser Aufruf zurückgibt, wurden die |
| EnqueueEventsAsync(IEnumerable<EventData>, EnqueueEventOptions, CancellationToken) |
Quediert einen Satz von EventData in den Puffer, der im Event Hub veröffentlicht werden soll. Wenn beim Aufrufen dieser Methode nicht genügend Kapazität im Puffer vorhanden ist, wartet sie, bis Speicherplatz verfügbar ist, und stellt sicher, dass alle Wenn dieser Aufruf zurückgibt, wurden die |
EnqueueEventsAsync(IEnumerable<EventData>, CancellationToken)
Quediert einen Satz von EventData in den Puffer, der im Event Hub veröffentlicht werden soll. Wenn beim Aufrufen dieser Methode nicht genügend Kapazität im Puffer vorhanden ist, wartet sie, bis Speicherplatz verfügbar ist, und stellt sicher, dass alle events in der events Gruppe in die Warteschlange gestellt wurden.
Wenn dieser Aufruf zurückgibt, wurden die events im Puffer akzeptiert, aber möglicherweise noch nicht veröffentlicht.
Die Veröffentlichung erfolgt in Zukunft an einem nicht deterministischen Punkt, während der Puffer verarbeitet wird.
public virtual System.Threading.Tasks.Task<int> EnqueueEventsAsync (System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.EventData> events, System.Threading.CancellationToken cancellationToken = default);abstract member EnqueueEventsAsync : seq<Azure.Messaging.EventHubs.EventData> * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>
override this.EnqueueEventsAsync : seq<Azure.Messaging.EventHubs.EventData> * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>Public Overridable Function EnqueueEventsAsync (events As IEnumerable(Of EventData), Optional cancellationToken As CancellationToken = Nothing) As Task(Of Integer)Parameter
- events
- IEnumerable<EventData>
Die Gruppe von Ereignissen, die in den Puffer queuiert und später veröffentlicht werden sollen.
- cancellationToken
- CancellationToken
Ein optionaler CancellationToken instance, um die Anforderung zum Abbrechen des Vorgangs zu signalisieren.
Gibt zurück
Die Gesamtzahl der Ereignisse, die derzeit gepuffert werden und auf die Veröffentlichung warten, über alle Partitionen hinweg.
Ausnahmen
Tritt auf, wenn derzeit kein SendEventBatchFailedAsync Handler registriert ist.
Hinweise
Sollte der Abbruch oder eine unerwartete Ausnahme auftreten, kann es sein, dass Aufrufe dieser Methode zu einem teilweisen Fehler führen, bei dem einige, aber nicht alle, sich events in die Warteschlange gestellt haben. In Szenarien, in denen es wichtig ist zu verstehen, ob jedes einzelne Ereignis in die Warteschlange gestellt wurde, empfiehlt es sich, anstelle dieser Methode die See EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken) - oder EnqueueEventAsync(EventData, CancellationToken) Überladungen aufzurufen.
Beim ersten Versuch, Ereignisse in Quequeue zu stellen, können die SendEventBatchSucceededAsync Handler und SendEventBatchFailedAsync nicht mehr geändert werden.
Gilt für:
EnqueueEventsAsync(IEnumerable<EventData>, EnqueueEventOptions, CancellationToken)
Quediert einen Satz von EventData in den Puffer, der im Event Hub veröffentlicht werden soll. Wenn beim Aufrufen dieser Methode nicht genügend Kapazität im Puffer vorhanden ist, wartet sie, bis Speicherplatz verfügbar ist, und stellt sicher, dass alle events in der events Gruppe in die Warteschlange gestellt wurden.
Wenn dieser Aufruf zurückgibt, wurden die events im Puffer akzeptiert, aber möglicherweise noch nicht veröffentlicht.
Die Veröffentlichung erfolgt in Zukunft an einem nicht deterministischen Punkt, während der Puffer verarbeitet wird.
public virtual System.Threading.Tasks.Task<int> EnqueueEventsAsync (System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.EventData> events, Azure.Messaging.EventHubs.Producer.EnqueueEventOptions options, System.Threading.CancellationToken cancellationToken = default);abstract member EnqueueEventsAsync : seq<Azure.Messaging.EventHubs.EventData> * Azure.Messaging.EventHubs.Producer.EnqueueEventOptions * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>
override this.EnqueueEventsAsync : seq<Azure.Messaging.EventHubs.EventData> * Azure.Messaging.EventHubs.Producer.EnqueueEventOptions * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>Public Overridable Function EnqueueEventsAsync (events As IEnumerable(Of EventData), options As EnqueueEventOptions, Optional cancellationToken As CancellationToken = Nothing) As Task(Of Integer)Parameter
- events
- IEnumerable<EventData>
Die Gruppe von Ereignissen, die in den Puffer queuiert und später veröffentlicht werden sollen.
- options
- EnqueueEventOptions
Der Satz von Optionen, die beim Veröffentlichen dieser Ereignisse angewendet werden sollen.
- cancellationToken
- CancellationToken
Ein optionaler CancellationToken instance, um die Anforderung zum Abbrechen des Vorgangs zu signalisieren.
Gibt zurück
Die Gesamtzahl der Ereignisse, die derzeit gepuffert werden und auf die Veröffentlichung warten, über alle Partitionen hinweg.
Ausnahmen
Tritt auf, wenn ein ungültiger Partitionsbezeichner in optionsangegeben wurde.
Hinweise
Sollte der Abbruch oder eine unerwartete Ausnahme auftreten, kann es sein, dass Aufrufe dieser Methode zu einem teilweisen Fehler führen, bei dem einige, aber nicht alle, sich events in die Warteschlange gestellt haben. In Szenarien, in denen es wichtig ist zu verstehen, ob jedes einzelne Ereignis in die Warteschlange gestellt wurde, empfiehlt es sich, anstelle dieser Methode die See EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken) - oder EnqueueEventAsync(EventData, CancellationToken) Überladungen aufzurufen.
Beim ersten Versuch, Ereignisse in Quequeue zu stellen, können die SendEventBatchSucceededAsync Handler und SendEventBatchFailedAsync nicht mehr geändert werden.
Gilt für:
Azure SDK for .NET