Freigeben über

PartitionSender Klasse

  • Referenz

Definition

Namespace:
Microsoft.Azure.EventHubs
Assembly:
Microsoft.Azure.EventHubs.dll
Paket:
Microsoft.Azure.EventHubs v4.3.2
Quelle:
PartitionSender.cs

Diese Absenderklasse ist eine logische Darstellung des Sendens von Ereignissen an eine bestimmte EventHub-Partition. Verwenden Sie diese Klasse nicht, wenn Sie sich nicht um das Senden von Ereignissen an bestimmte Partitionen kümmern. Verwenden SendAsync(EventData)Sie stattdessen .

public sealed class PartitionSender : Microsoft.Azure.EventHubs.ClientEntity
type PartitionSender = class
    inherit ClientEntity
Public NotInheritable Class PartitionSender
Inherits ClientEntity
Vererbung
Object
ClientEntity
PartitionSender

Eigenschaften

ClientId

Ruft die Client-ID ab.

(Geerbt von ClientEntity)
EventHubClient

Ruft den ab, der EventHubClient diesem PartitionSender zugeordnet ist.
IsClosed

Gibt einen booleschen Wert zurück, der angibt, ob das Clientobjekt geschlossen ist oder nicht.

(Geerbt von ClientEntity)
PartitionId

Ruft die Partitions-ID für diesen PartitionSenderab.
RegisteredPlugins

Ruft eine Liste der aktuell registrierten Plug-Ins für diesen Client ab.

(Geerbt von ClientEntity)
RetryPolicy

Ruft den RetryPolicy für clientEntity ab.

(Geerbt von ClientEntity)

Methoden

Close()

Schließt clientEntity.

(Geerbt von ClientEntity)
CloseAsync()

Schließt und gibt Ressourcen für frei PartitionSender.
CreateBatch()

Erstellt einen Batch, in dem Ereignisdatenobjekte für einen späteren SendAsync-Aufruf hinzugefügt werden können.
CreateBatch(BatchOptions)

Erstellt einen Batch, in dem Ereignisdatenobjekte für einen späteren SendAsync-Aufruf hinzugefügt werden können.
OnRetryPolicyUpdate()

Abgeleitete Entität, die für Wiederholungsrichtlinienupdates außer Kraft gesetzt werden soll.

(Geerbt von ClientEntity)
RegisterPlugin(EventHubsPlugin)

Registriert eine EventHubsPlugin , die mit diesem Client verwendet werden soll.

(Geerbt von ClientEntity)
SendAsync(EventData)

Senden sie EventData an eine bestimmte EventHub-Partition. Die Zielpartition wird beim Erstellen dieses PartitionSenders vorab bestimmt. Dieses Sendemuster betont die Datenkorrelation gegenüber der allgemeinen Verfügbarkeit und Latenz.

Es gibt drei Möglichkeiten, an EventHubs zu senden, die jeweils als Methode verfügbar gemacht werden (zusammen mit der sendBatch-Überladung):

i. SendAsync(EventData) oder SendAsync(IEnumerable<EventData>)

ii. SendAsync(EventData, String) oder SendAsync(IEnumerable<EventData>, String)

iii. SendAsync(EventData) oder SendAsync(IEnumerable<EventData>)

Verwenden Sie diesen Sendetyp, wenn:

a. Der Client möchte die direkte Kontrolle über die Verteilung von Daten auf Partitionen übernehmen. In diesem Fall ist der Client dafür verantwortlich, dass es mindestens einen Absender pro Event Hub-Partition gibt.

b. Der Benutzer kann den Partitionsschlüssel nicht als Mittel verwenden, um Ereignisse an eine bestimmte Partition weiterzuleiten. Dennoch ist eine Datenkorrelation mit dem Partitionierungsschema erforderlich.
SendAsync(EventDataBatch)

Senden Sie einen Batch von EventData in EventDataBatch.
SendAsync(IEnumerable<EventData>)

Senden sie EventData an eine bestimmte EventHub-Partition. Die Zielpartition wird beim Erstellen dieses PartitionSenders vorab festgelegt.

Es gibt 3 Möglichkeiten, an EventHubs zu senden. Um diese bestimmte Art von Senden zu verstehen, verweisen Sie auf die Überladung SendAsync(EventData), die den gleichen Sendetyp ist und zum Senden einzelner EventDataverwendet wird.

Das Senden eines Batches von EventData's ist in den folgenden Fällen nützlich:

i. Effizientes Senden: Das Senden eines Batches von EventData maximiert den Gesamtdurchsatz, indem die Anzahl der Sitzungen, die für den EventHubs-Dienst erstellt wurden, optimal verwendet wird.

ii. Senden von mehreren EventDatás in einer Transaktion. Um ACID-Eigenschaften zu erzielen, leitet der Gatewaydienst alle EventData's im Batch an eine einzelne EventHub-Partition weiter.
ThrowIfClosed()

Löst eine Ausnahme aus, wenn das Clientobjekt bereits geschlossen ist.

(Geerbt von ClientEntity)
UnregisterPlugin(String)

Hebt die Registrierung eines auf EventHubsPlugin.

(Geerbt von ClientEntity)

Gilt für:

Weitere Informationen