PartitionSender Klasse

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)

Weitere Informationen

• CreateFromConnectionString(String)
• CreatePartitionSender(String)