EventHubConsumerClient.ReadEventsAsync 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
| ReadEventsAsync(CancellationToken) |
Liest Ereignisse aus allen Partitionen des Event Hubs als asynchrone Aufzählung, sodass Ereignisse durchlaufen werden können, sobald sie auf der Partition verfügbar werden, und wartet bei Bedarf, falls keine Ereignisse verfügbar sind. Dieser Enumerator kann für einen unbestimmten Zeitraum für einen |
| ReadEventsAsync(ReadEventOptions, CancellationToken) |
Liest Ereignisse aus allen Partitionen des Event Hubs als asynchrone Aufzählung, sodass Ereignisse durchlaufen werden können, sobald sie auf der Partition verfügbar werden, und wartet bei Bedarf, falls keine Ereignisse verfügbar sind. Dieser Enumerator kann für einen unbestimmten Zeitraum für einen |
| ReadEventsAsync(Boolean, ReadEventOptions, CancellationToken) |
Liest Ereignisse aus allen Partitionen des Event Hubs als asynchrone Aufzählung, sodass Ereignisse durchlaufen werden können, sobald sie auf der Partition verfügbar werden, und wartet bei Bedarf, falls keine Ereignisse verfügbar sind. Dieser Enumerator kann für einen unbestimmten Zeitraum für einen |
ReadEventsAsync(CancellationToken)
- Quelle:
- EventHubConsumerClient.cs
- Quelle:
- EventHubConsumerClient.cs
Liest Ereignisse aus allen Partitionen des Event Hubs als asynchrone Aufzählung, sodass Ereignisse durchlaufen werden können, sobald sie auf der Partition verfügbar werden, und wartet bei Bedarf, falls keine Ereignisse verfügbar sind.
Dieser Enumerator kann für einen unbestimmten Zeitraum für einen await blockieren, wenn Ereignisse auf der Partition nicht verfügbar sind, sodass die Abbruch über die angefordert werden muss, um die cancellationToken Kontrolle zurückzugeben. Es wird empfohlen, für MaximumWaitTime Szenarien festzulegen, in denen eine deterministischere maximale Wartezeit gewünscht wird.
public virtual System.Collections.Generic.IAsyncEnumerable<Azure.Messaging.EventHubs.Consumer.PartitionEvent> ReadEventsAsync (System.Threading.CancellationToken cancellationToken = default);abstract member ReadEventsAsync : System.Threading.CancellationToken -> System.Collections.Generic.IAsyncEnumerable<Azure.Messaging.EventHubs.Consumer.PartitionEvent>
override this.ReadEventsAsync : System.Threading.CancellationToken -> System.Collections.Generic.IAsyncEnumerable<Azure.Messaging.EventHubs.Consumer.PartitionEvent>Public Overridable Function ReadEventsAsync (Optional cancellationToken As CancellationToken = Nothing) As IAsyncEnumerable(Of PartitionEvent)Parameter
- cancellationToken
- CancellationToken
Ein optionaler CancellationToken instance, um die Anforderung zum Abbrechen des Vorgangs zu signalisieren.
Gibt zurück
Ein IAsyncEnumerable<T> , der zum Durchlaufen von Ereignissen in der Partition verwendet werden soll.
Ausnahmen
Tritt auf, wenn ein EventHubConsumerClient nicht aus dem Event Hub lesen kann, weil ein anderer Leser den exklusiven Besitz geltend gemacht hat. In diesem Fall wird auf EventHubsException.FailureReason festgelegt ConsumerDisconnected.
Hinweise
Diese Methode wird für die Verwendung in der Produktion nicht empfohlen. sollte EventProcessorClient zum Lesen von Ereignissen aus allen Partitionen in einem Produktionsszenario verwendet werden, da es eine viel robustere Umgebung mit höherem Durchsatz bietet.
Es ist wichtig zu beachten, dass diese Methode die Fairness zwischen den Partitionen während der Iteration nicht garantiert; jede Partition konkurrieren, um Ereignisse zu veröffentlichen, die vom Enumerator gelesen werden sollen. Je nach Dienstkommunikation kann es zu einem Clustering von Ereignissen pro Partition kommen, und/oder es kann eine erkennbare Verzerrung für eine bestimmte Partition oder Teilmenge von Partitionen auftreten.
Jeder Leser von Ereignissen wird mit einem unabhängigen Iterator angezeigt. wenn mehrere Leser vorhanden sind, erhält jeder seine eigene Kopie eines zu verarbeitenden Ereignisses, anstatt um sie zu konkurrieren.
Weitere Informationen
Gilt für:
ReadEventsAsync(ReadEventOptions, CancellationToken)
- Quelle:
- EventHubConsumerClient.cs
- Quelle:
- EventHubConsumerClient.cs
Liest Ereignisse aus allen Partitionen des Event Hubs als asynchrone Aufzählung, sodass Ereignisse durchlaufen werden können, sobald sie auf der Partition verfügbar werden, und wartet bei Bedarf, falls keine Ereignisse verfügbar sind.
Dieser Enumerator kann für einen unbestimmten Zeitraum für einen await blockieren, wenn Ereignisse auf der Partition nicht verfügbar sind, sodass die Abbruch über die angefordert werden muss, um die cancellationToken Kontrolle zurückzugeben. Es wird empfohlen, für MaximumWaitTime Szenarien festzulegen, in denen eine deterministischere maximale Wartezeit gewünscht wird.
public virtual System.Collections.Generic.IAsyncEnumerable<Azure.Messaging.EventHubs.Consumer.PartitionEvent> ReadEventsAsync (Azure.Messaging.EventHubs.Consumer.ReadEventOptions readOptions, System.Threading.CancellationToken cancellationToken = default);abstract member ReadEventsAsync : Azure.Messaging.EventHubs.Consumer.ReadEventOptions * System.Threading.CancellationToken -> System.Collections.Generic.IAsyncEnumerable<Azure.Messaging.EventHubs.Consumer.PartitionEvent>
override this.ReadEventsAsync : Azure.Messaging.EventHubs.Consumer.ReadEventOptions * System.Threading.CancellationToken -> System.Collections.Generic.IAsyncEnumerable<Azure.Messaging.EventHubs.Consumer.PartitionEvent>Public Overridable Function ReadEventsAsync (readOptions As ReadEventOptions, Optional cancellationToken As CancellationToken = Nothing) As IAsyncEnumerable(Of PartitionEvent)Parameter
- readOptions
- ReadEventOptions
Der Satz von Optionen, die zum Konfigurieren des Leseverhaltens verwendet werden sollen; wenn nicht angegeben, werden die Standardwerte verwendet.
- cancellationToken
- CancellationToken
Ein optionaler CancellationToken instance, um die Anforderung zum Abbrechen des Vorgangs zu signalisieren.
Gibt zurück
Ein IAsyncEnumerable<T> , der zum Durchlaufen von Ereignissen in der Partition verwendet werden soll.
Ausnahmen
Tritt auf, wenn ein EventHubConsumerClient nicht aus dem Event Hub lesen kann, weil ein anderer Leser den exklusiven Besitz geltend gemacht hat. In diesem Fall wird auf EventHubsException.FailureReason festgelegt ConsumerDisconnected.
Hinweise
Diese Methode wird für die Verwendung in der Produktion nicht empfohlen. sollte EventProcessorClient zum Lesen von Ereignissen aus allen Partitionen in einem Produktionsszenario verwendet werden, da es eine viel robustere Umgebung mit höherem Durchsatz bietet.
Es ist wichtig zu beachten, dass diese Methode die Fairness zwischen den Partitionen während der Iteration nicht garantiert; jede Partition konkurrieren, um Ereignisse zu veröffentlichen, die vom Enumerator gelesen werden sollen. Je nach Dienstkommunikation kann es zu einem Clustering von Ereignissen pro Partition kommen, und/oder es kann eine erkennbare Verzerrung für eine bestimmte Partition oder Teilmenge von Partitionen auftreten.
Jeder Leser von Ereignissen wird mit einem unabhängigen Iterator angezeigt. wenn mehrere Leser vorhanden sind, erhält jeder seine eigene Kopie eines zu verarbeitenden Ereignisses, anstatt um sie zu konkurrieren.
Weitere Informationen
Gilt für:
ReadEventsAsync(Boolean, ReadEventOptions, CancellationToken)
- Quelle:
- EventHubConsumerClient.cs
- Quelle:
- EventHubConsumerClient.cs
Liest Ereignisse aus allen Partitionen des Event Hubs als asynchrone Aufzählung, sodass Ereignisse durchlaufen werden können, sobald sie auf der Partition verfügbar werden, und wartet bei Bedarf, falls keine Ereignisse verfügbar sind.
Dieser Enumerator kann für einen unbestimmten Zeitraum für einen await blockieren, wenn Ereignisse auf der Partition nicht verfügbar sind, sodass die Abbruch über die angefordert werden muss, um die cancellationToken Kontrolle zurückzugeben. Es wird empfohlen, für MaximumWaitTime Szenarien festzulegen, in denen eine deterministischere maximale Wartezeit gewünscht wird.
public virtual System.Collections.Generic.IAsyncEnumerable<Azure.Messaging.EventHubs.Consumer.PartitionEvent> ReadEventsAsync (bool startReadingAtEarliestEvent, Azure.Messaging.EventHubs.Consumer.ReadEventOptions readOptions = default, System.Threading.CancellationToken cancellationToken = default);abstract member ReadEventsAsync : bool * Azure.Messaging.EventHubs.Consumer.ReadEventOptions * System.Threading.CancellationToken -> System.Collections.Generic.IAsyncEnumerable<Azure.Messaging.EventHubs.Consumer.PartitionEvent>
override this.ReadEventsAsync : bool * Azure.Messaging.EventHubs.Consumer.ReadEventOptions * System.Threading.CancellationToken -> System.Collections.Generic.IAsyncEnumerable<Azure.Messaging.EventHubs.Consumer.PartitionEvent>Public Overridable Function ReadEventsAsync (startReadingAtEarliestEvent As Boolean, Optional readOptions As ReadEventOptions = Nothing, Optional cancellationToken As CancellationToken = Nothing) As IAsyncEnumerable(Of PartitionEvent)Parameter
- startReadingAtEarliestEvent
- Boolean
true um mit dem Lesen der ersten in jeder Partition verfügbaren Ereignisse zu beginnen; Andernfalls beginnt das Lesen am Ende jeder Partition, die nur neue Ereignisse sieht, während sie veröffentlicht werden.
- readOptions
- ReadEventOptions
Der Satz von Optionen, die zum Konfigurieren des Leseverhaltens verwendet werden sollen; wenn nicht angegeben, werden die Standardwerte verwendet.
- cancellationToken
- CancellationToken
Ein optionaler CancellationToken instance, um die Anforderung zum Abbrechen des Vorgangs zu signalisieren.
Gibt zurück
Ein IAsyncEnumerable<T> , der zum Durchlaufen von Ereignissen in der Partition verwendet werden soll.
Ausnahmen
Tritt auf, wenn ein EventHubConsumerClient nicht aus dem Event Hub lesen kann, weil ein anderer Leser den exklusiven Besitz geltend gemacht hat. In diesem Fall wird auf EventHubsException.FailureReason festgelegt ConsumerDisconnected.
Hinweise
Diese Methode wird für die Verwendung in der Produktion nicht empfohlen. sollte EventProcessorClient zum Lesen von Ereignissen aus allen Partitionen in einem Produktionsszenario verwendet werden, da es eine viel robustere Umgebung mit höherem Durchsatz bietet.
Es ist wichtig zu beachten, dass diese Methode die Fairness zwischen den Partitionen während der Iteration nicht garantiert; jede Partition konkurrieren, um Ereignisse zu veröffentlichen, die vom Enumerator gelesen werden sollen. Je nach Dienstkommunikation kann es zu einem Clustering von Ereignissen pro Partition kommen, und/oder es kann eine erkennbare Verzerrung für eine bestimmte Partition oder Teilmenge von Partitionen auftreten.
Jeder Leser von Ereignissen wird mit einem unabhängigen Iterator angezeigt. wenn mehrere Leser vorhanden sind, erhält jeder seine eigene Kopie eines zu verarbeitenden Ereignisses, anstatt um sie zu konkurrieren.
Weitere Informationen
Gilt für:
Azure SDK for .NET