Freigeben über


PartitionReceiver Klasse

Definition

Ermöglicht das Lesen von Ereignissen aus einer bestimmten Partition eines Event Hubs und im Kontext einer bestimmten Consumergruppe, das Lesen mit einem höheren Maß an Kontrolle über die Kommunikation mit dem Event Hubs-Dienst als von anderen Ereignisconsumern angeboten wird.

public class PartitionReceiver : IAsyncDisposable
type PartitionReceiver = class
    interface IAsyncDisposable
Public Class PartitionReceiver
Implements IAsyncDisposable
Vererbung
PartitionReceiver
Implementiert

Hinweise

Für die meisten Szenarien wird empfohlen, oder EventProcessorClientEventHubConsumerClient zum Lesen und Verarbeiten von Ereignissen zu verwenden. Der Partitionsempfänger soll Szenarien mit speziellen Anforderungen ermöglichen, die eine direktere Steuerung erfordern.

Ist PartitionReceiver sicher, während der Lebensdauer einer Anwendung zwischenzuspeichern und zu verwenden. Dies ist die bewährte Methode, wenn die Anwendung Ereignisse regelmäßig oder halb regelmäßig liest. Der Empfänger ist dafür verantwortlich, eine effiziente Netzwerk-, CPU- und Arbeitsspeichernutzung sicherzustellen. Wenn Sie entweder CloseAsync(CancellationToken) oder DisposeAsync() aufrufen, während die Anwendung heruntergefahren wird, wird sichergestellt, dass Netzwerkressourcen und andere nicht verwaltete Objekte ordnungsgemäß bereinigt werden.

Konstruktoren

PartitionReceiver()

Initialisiert eine neue Instanz der PartitionReceiver-Klasse.

PartitionReceiver(String, String, EventPosition, EventHubConnection, PartitionReceiverOptions)

Initialisiert eine neue Instanz der PartitionReceiver-Klasse.

PartitionReceiver(String, String, EventPosition, String, PartitionReceiverOptions)

Initialisiert eine neue Instanz der PartitionReceiver-Klasse.

PartitionReceiver(String, String, EventPosition, String, String, AzureNamedKeyCredential, PartitionReceiverOptions)

Initialisiert eine neue Instanz der PartitionReceiver-Klasse.

PartitionReceiver(String, String, EventPosition, String, String, AzureSasCredential, PartitionReceiverOptions)

Initialisiert eine neue Instanz der PartitionReceiver-Klasse.

PartitionReceiver(String, String, EventPosition, String, String, PartitionReceiverOptions)

Initialisiert eine neue Instanz der PartitionReceiver-Klasse.

PartitionReceiver(String, String, EventPosition, String, String, TokenCredential, PartitionReceiverOptions)

Initialisiert eine neue Instanz der PartitionReceiver-Klasse.

Eigenschaften

ConsumerGroup

Der Name der Consumergruppe, der dieser Client zugeordnet ist. Ereignisse werden im Kontext dieser Gruppe nur gelesen.

EventHubName

Der Name des Event Hubs, mit dem der Client verbunden ist, spezifisch für den Event Hubs-Namespace, der ihn enthält.

FullyQualifiedNamespace

Der vollqualifizierte Event Hubs-Namespace, dem der Client zugeordnet ist. Dies ist wahrscheinlich ähnlich wie .{yournamespace}.servicebus.windows.net

Identifier

Ein eindeutiger Name, der zum Identifizieren dieses Empfängers verwendet wird.

InitialPosition

Die Position innerhalb der Partition, an der der Client mit dem Lesen von Ereignissen beginnt.

IsClosed

Gibt an, ob diese PartitionReceiver geschlossen wurde.

PartitionId

Der Bezeichner der Event Hub-Partition, der dieser Client zugeordnet ist. Ereignisse werden aus dieser Partition schreibgeschützter.

Methoden

CloseAsync(CancellationToken)

Schließt den Client.

DisposeAsync()

Führt die Aufgabe aus, die zum sauber von verwendeten Ressourcen erforderlich ist, einschließlich der PartitionReceiverSicherstellung, dass der Client selbst geschlossen wurde.

GetPartitionPropertiesAsync(CancellationToken)

Ruft Informationen zur Partition ab, der dieser Client zugeordnet ist, einschließlich Elementen, die die verfügbaren Ereignisse im Partitionsereignisstream beschreiben.

ReadLastEnqueuedEventProperties()

Eine Reihe von Informationen zum letzten Warteschlangenereignis der Partition, die diesem Empfänger zugeordnet ist, die beobachtet wird, wenn Ereignisse vom Event Hubs-Dienst empfangen werden. Dies ist nur verfügbar, wenn der Empfänger mit TrackLastEnqueuedEventProperties set erstellt wurde. Andernfalls enthalten die Eigenschaften Standardwerte.

ReceiveBatchAsync(Int32, CancellationToken)

Empfängt einen Batch von EventData von der Event Hub-Partition, der dieser Client zugeordnet ist.

ReceiveBatchAsync(Int32, TimeSpan, CancellationToken)

Empfängt einen Batch von EventData von der Event Hub-Partition, der dieser Client zugeordnet ist.

Gilt für:

Weitere Informationen