EventProcessorClient Konstruktoren

Definition

Namespace:

Azure.Messaging.EventHubs

Assembly:

Azure.Messaging.EventHubs.Processor.dll

Paket:

Azure.Messaging.EventHubs.Processor v5.10.0

Überlädt

EventProcessorClient()	Initialisiert eine neue Instanz der EventProcessorClient-Klasse.
EventProcessorClient(BlobContainerClient, String, String)	Initialisiert eine neue Instanz der EventProcessorClient-Klasse.
EventProcessorClient(BlobContainerClient, String, String, EventProcessorClientOptions)	Initialisiert eine neue Instanz der EventProcessorClient-Klasse.
EventProcessorClient(BlobContainerClient, String, String, String)	Initialisiert eine neue Instanz der EventProcessorClient-Klasse.
EventProcessorClient(BlobContainerClient, String, String, String, EventProcessorClientOptions)	Initialisiert eine neue Instanz der EventProcessorClient-Klasse.
EventProcessorClient(BlobContainerClient, String, String, String, AzureNamedKeyCredential, EventProcessorClientOptions)	Initialisiert eine neue Instanz der EventProcessorClient-Klasse.
EventProcessorClient(BlobContainerClient, String, String, String, AzureSasCredential, EventProcessorClientOptions)	Initialisiert eine neue Instanz der EventProcessorClient-Klasse.
EventProcessorClient(BlobContainerClient, String, String, String, TokenCredential, EventProcessorClientOptions)	Initialisiert eine neue Instanz der EventProcessorClient-Klasse.

EventProcessorClient()

Initialisiert eine neue Instanz der EventProcessorClient-Klasse.

protected EventProcessorClient ();

Protected Sub New ()

EventProcessorClient(BlobContainerClient, String, String)

Initialisiert eine neue Instanz der EventProcessorClient-Klasse.

public EventProcessorClient (Azure.Storage.Blobs.BlobContainerClient checkpointStore, string consumerGroup, string connectionString);

new Azure.Messaging.EventHubs.EventProcessorClient : Azure.Storage.Blobs.BlobContainerClient * string * string -> Azure.Messaging.EventHubs.EventProcessorClient

Public Sub New (checkpointStore As BlobContainerClient, consumerGroup As String, connectionString As String)

Parameter

checkpointStore

BlobContainerClient

Der Client, der für das Beibehalten von Prüfpunkten und den Prozessorstatus in dauerhaftem Speicher verantwortlich ist. Prozessorinstanzen, die diesen Speicher gemeinsam nutzen, versuchen, die Arbeit zu koordinieren und freizugeben. Es wird erwartet, dass der zugeordnete Container vorhanden ist.

consumerGroup

String

Der Name der Consumergruppe, mit der dieser Prozessor verknüpft ist. Der Prozessor beansprucht exklusiven Lesezugriff auf Partitionen für diese Gruppe.

connectionString

String

Die Verbindungszeichenfolge, die zum Herstellen einer Verbindung mit dem Event Hubs-Namespace verwendet werden soll; Es wird erwartet, dass der Event Hub-Name und die Shared Key-Eigenschaften in dieser Verbindungszeichenfolge enthalten sind.

Hinweise

Der container, der dem checkpointStore zugeordnet ist, wird erwartet, dass er vorhanden ist. der EventProcessorClient geht nicht von der Möglichkeit aus, das Speicherkonto zu verwalten, und kann nur mit Lese-/Schreibberechtigungen für Blobs im Container ausgeführt werden. Es wird empfohlen, dass dieser Container für die vom Prozessor verwendete Event Hub- und Consumergruppe eindeutig ist und keine anderen Blobs miteinander verknüpft.

Wenn die Verbindungszeichenfolge aus dem Event Hubs-Namespace kopiert wird, enthält sie wahrscheinlich nicht den Namen des gewünschten Event Hubs, der benötigt wird. In diesem Fall kann der Name manuell hinzugefügt werden, indem "; EntityPath=[[ EVENT HUB NAME ]]" am Ende der Verbindungszeichenfolge. Beispiel: "; EntityPath=telemetry-hub".

Wenn Sie eine Shared Access-Richtlinie direkt im Event Hub selbst definiert haben, führt das Kopieren der Verbindungszeichenfolge aus diesem Event Hub zu einer Verbindungszeichenfolge, die den Namen enthält.

EventProcessorClient(BlobContainerClient, String, String, EventProcessorClientOptions)

Initialisiert eine neue Instanz der EventProcessorClient-Klasse.

public EventProcessorClient (Azure.Storage.Blobs.BlobContainerClient checkpointStore, string consumerGroup, string connectionString, Azure.Messaging.EventHubs.EventProcessorClientOptions clientOptions);

new Azure.Messaging.EventHubs.EventProcessorClient : Azure.Storage.Blobs.BlobContainerClient * string * string * Azure.Messaging.EventHubs.EventProcessorClientOptions -> Azure.Messaging.EventHubs.EventProcessorClient

Public Sub New (checkpointStore As BlobContainerClient, consumerGroup As String, connectionString As String, clientOptions As EventProcessorClientOptions)

Parameter

checkpointStore

BlobContainerClient

Der Client, der für das Beibehalten von Prüfpunkten und den Prozessorstatus in dauerhaftem Speicher verantwortlich ist. Prozessorinstanzen, die diesen Speicher gemeinsam nutzen, versuchen, die Arbeit zu koordinieren und freizugeben. Es wird erwartet, dass der zugeordnete Container vorhanden ist.

consumerGroup

String

Der Name der Consumergruppe, mit der dieser Prozessor verknüpft ist. Der Prozessor beansprucht exklusiven Lesezugriff auf Partitionen für diese Gruppe.

connectionString

String

Die Verbindungszeichenfolge, die zum Herstellen einer Verbindung mit dem Event Hubs-Namespace verwendet werden soll; Es wird erwartet, dass der Event Hub-Name und die Shared Key-Eigenschaften in dieser Verbindungszeichenfolge enthalten sind.

clientOptions

EventProcessorClientOptions

Der Satz von Optionen, die für diesen Prozessor verwendet werden sollen.

Hinweise

Der container, der dem checkpointStore zugeordnet ist, wird erwartet, dass er vorhanden ist. der EventProcessorClient geht nicht von der Möglichkeit aus, das Speicherkonto zu verwalten, und kann nur mit Lese-/Schreibberechtigungen für Blobs im Container ausgeführt werden. Es wird empfohlen, dass dieser Container für die vom Prozessor verwendete Event Hub- und Consumergruppe eindeutig ist und keine anderen Blobs miteinander verknüpft.

Wenn die Verbindungszeichenfolge aus dem Event Hubs-Namespace kopiert wird, enthält sie wahrscheinlich nicht den Namen des gewünschten Event Hubs, der benötigt wird. In diesem Fall kann der Name manuell hinzugefügt werden, indem "; EntityPath=[[ EVENT HUB NAME ]]" am Ende der Verbindungszeichenfolge. Beispiel: "; EntityPath=telemetry-hub".

Wenn Sie eine Shared Access-Richtlinie direkt im Event Hub selbst definiert haben, führt das Kopieren der Verbindungszeichenfolge aus diesem Event Hub zu einer Verbindungszeichenfolge, die den Namen enthält.

EventProcessorClient(BlobContainerClient, String, String, String)

Initialisiert eine neue Instanz der EventProcessorClient-Klasse.

public EventProcessorClient (Azure.Storage.Blobs.BlobContainerClient checkpointStore, string consumerGroup, string connectionString, string eventHubName);

new Azure.Messaging.EventHubs.EventProcessorClient : Azure.Storage.Blobs.BlobContainerClient * string * string * string -> Azure.Messaging.EventHubs.EventProcessorClient

Public Sub New (checkpointStore As BlobContainerClient, consumerGroup As String, connectionString As String, eventHubName As String)

Parameter

checkpointStore

BlobContainerClient

Der Client, der für das Beibehalten von Prüfpunkten und den Prozessorstatus in dauerhaftem Speicher verantwortlich ist. Prozessorinstanzen, die diesen Speicher gemeinsam nutzen, versuchen, die Arbeit zu koordinieren und freizugeben. Es wird erwartet, dass der zugeordnete Container vorhanden ist.

consumerGroup

String

Der Name der Consumergruppe, mit der dieser Prozessor verknüpft ist. Der Prozessor beansprucht exklusiven Lesezugriff auf Partitionen für diese Gruppe.

connectionString

String

Die Verbindungszeichenfolge, die zum Herstellen einer Verbindung mit dem Event Hubs-Namespace verwendet werden soll; Es wird erwartet, dass die Eigenschaften des freigegebenen Schlüssels in dieser Verbindungszeichenfolge enthalten sind, aber nicht der Event Hub-Name.

eventHubName

String

Der Name des spezifischen Event Hubs, dem der Prozessor zugeordnet werden soll.

Hinweise

Der container, der dem checkpointStore zugeordnet ist, wird erwartet, dass er vorhanden ist. der EventProcessorClient geht nicht von der Möglichkeit aus, das Speicherkonto zu verwalten, und kann nur mit Lese-/Schreibberechtigungen für Blobs im Container ausgeführt werden. Es wird empfohlen, dass dieser Container für die vom Prozessor verwendete Event Hub- und Consumergruppe eindeutig ist und keine anderen Blobs miteinander verknüpft.

Wenn die Verbindungszeichenfolge aus dem Event Hub selbst kopiert wird, enthält sie den Namen des gewünschten Event Hubs und kann direkt verwendet werden, ohne das eventHubNamezu übergeben. Der Name des Event Hubs sollte nur einmal übergeben werden, entweder als Teil der Verbindungszeichenfolge oder separat.

EventProcessorClient(BlobContainerClient, String, String, String, EventProcessorClientOptions)

Initialisiert eine neue Instanz der EventProcessorClient-Klasse.

public EventProcessorClient (Azure.Storage.Blobs.BlobContainerClient checkpointStore, string consumerGroup, string connectionString, string eventHubName, Azure.Messaging.EventHubs.EventProcessorClientOptions clientOptions);

new Azure.Messaging.EventHubs.EventProcessorClient : Azure.Storage.Blobs.BlobContainerClient * string * string * string * Azure.Messaging.EventHubs.EventProcessorClientOptions -> Azure.Messaging.EventHubs.EventProcessorClient

Public Sub New (checkpointStore As BlobContainerClient, consumerGroup As String, connectionString As String, eventHubName As String, clientOptions As EventProcessorClientOptions)

Parameter

checkpointStore

BlobContainerClient

Der Client, der für das Beibehalten von Prüfpunkten und den Prozessorstatus in dauerhaftem Speicher verantwortlich ist. Prozessorinstanzen, die diesen Speicher gemeinsam nutzen, versuchen, die Arbeit zu koordinieren und freizugeben. Es wird erwartet, dass der zugeordnete Container vorhanden ist.

consumerGroup

String

Der Name der Consumergruppe, mit der dieser Prozessor verknüpft ist. Der Prozessor beansprucht exklusiven Lesezugriff auf Partitionen für diese Gruppe.

connectionString

String

Die Verbindungszeichenfolge, die zum Herstellen einer Verbindung mit dem Event Hubs-Namespace verwendet werden soll; Es wird erwartet, dass die Eigenschaften des freigegebenen Schlüssels in dieser Verbindungszeichenfolge enthalten sind, aber nicht der Event Hub-Name.

eventHubName

String

Der Name des spezifischen Event Hubs, dem der Prozessor zugeordnet werden soll.

clientOptions

EventProcessorClientOptions

Der Satz von Optionen, die für diesen Prozessor verwendet werden sollen.

Hinweise

Der container, der dem checkpointStore zugeordnet ist, wird erwartet, dass er vorhanden ist. der EventProcessorClient geht nicht von der Möglichkeit aus, das Speicherkonto zu verwalten, und kann nur mit Lese-/Schreibberechtigungen für Blobs im Container ausgeführt werden. Es wird empfohlen, dass dieser Container für die vom Prozessor verwendete Event Hub- und Consumergruppe eindeutig ist und keine anderen Blobs miteinander verknüpft.

Wenn die Verbindungszeichenfolge aus dem Event Hub selbst kopiert wird, enthält sie den Namen des gewünschten Event Hubs und kann direkt verwendet werden, ohne das eventHubNamezu übergeben. Der Name des Event Hubs sollte nur einmal übergeben werden, entweder als Teil der Verbindungszeichenfolge oder separat.

EventProcessorClient(BlobContainerClient, String, String, String, AzureNamedKeyCredential, EventProcessorClientOptions)

Initialisiert eine neue Instanz der EventProcessorClient-Klasse.

public EventProcessorClient (Azure.Storage.Blobs.BlobContainerClient checkpointStore, string consumerGroup, string fullyQualifiedNamespace, string eventHubName, Azure.AzureNamedKeyCredential credential, Azure.Messaging.EventHubs.EventProcessorClientOptions clientOptions = default);

new Azure.Messaging.EventHubs.EventProcessorClient : Azure.Storage.Blobs.BlobContainerClient * string * string * string * Azure.AzureNamedKeyCredential * Azure.Messaging.EventHubs.EventProcessorClientOptions -> Azure.Messaging.EventHubs.EventProcessorClient

Public Sub New (checkpointStore As BlobContainerClient, consumerGroup As String, fullyQualifiedNamespace As String, eventHubName As String, credential As AzureNamedKeyCredential, Optional clientOptions As EventProcessorClientOptions = Nothing)

Parameter

checkpointStore

BlobContainerClient

Der Client, der für das Beibehalten von Prüfpunkten und den Prozessorstatus in dauerhaftem Speicher verantwortlich ist. Prozessorinstanzen, die diesen Speicher gemeinsam nutzen, versuchen, die Arbeit zu koordinieren und freizugeben. Es wird erwartet, dass der zugeordnete Container vorhanden ist.

consumerGroup

String

Der Name der Consumergruppe, mit der dieser Prozessor verknüpft ist. Der Prozessor beansprucht exklusiven Lesezugriff auf Partitionen für diese Gruppe.

fullyQualifiedNamespace

String

Der vollqualifizierte Event Hubs-Namespace, mit dem eine Verbindung hergestellt werden soll. Dies ist wahrscheinlich ähnlich wie .{yournamespace}.servicebus.windows.net

eventHubName

String

Der Name des spezifischen Event Hubs, dem der Prozessor zugeordnet werden soll.

credential

AzureNamedKeyCredential

Die Anmeldeinformationen für den freigegebenen Zugriffsschlüssel, die für die Autorisierung verwendet werden sollen. Zugriffssteuerungen können je nach Azure-Konfiguration vom Event Hubs-Namespace oder vom angeforderten Event Hub angegeben werden.

clientOptions

EventProcessorClientOptions

Der Satz von Optionen, die für diesen Prozessor verwendet werden sollen.

Hinweise

Der container, der dem checkpointStore zugeordnet ist, wird erwartet, dass er vorhanden ist. der EventProcessorClient geht nicht von der Möglichkeit aus, das Speicherkonto zu verwalten, und kann nur mit Lese-/Schreibberechtigungen für Blobs im Container ausgeführt werden. Es wird empfohlen, dass dieser Container für die vom Prozessor verwendete Event Hub- und Consumergruppe eindeutig ist und keine anderen Blobs miteinander verknüpft.

EventProcessorClient(BlobContainerClient, String, String, String, AzureSasCredential, EventProcessorClientOptions)

Initialisiert eine neue Instanz der EventProcessorClient-Klasse.

public EventProcessorClient (Azure.Storage.Blobs.BlobContainerClient checkpointStore, string consumerGroup, string fullyQualifiedNamespace, string eventHubName, Azure.AzureSasCredential credential, Azure.Messaging.EventHubs.EventProcessorClientOptions clientOptions = default);

new Azure.Messaging.EventHubs.EventProcessorClient : Azure.Storage.Blobs.BlobContainerClient * string * string * string * Azure.AzureSasCredential * Azure.Messaging.EventHubs.EventProcessorClientOptions -> Azure.Messaging.EventHubs.EventProcessorClient

Public Sub New (checkpointStore As BlobContainerClient, consumerGroup As String, fullyQualifiedNamespace As String, eventHubName As String, credential As AzureSasCredential, Optional clientOptions As EventProcessorClientOptions = Nothing)

Parameter

checkpointStore

BlobContainerClient

Der Client, der für das Beibehalten von Prüfpunkten und den Prozessorstatus in dauerhaftem Speicher verantwortlich ist. Prozessorinstanzen, die diesen Speicher gemeinsam nutzen, versuchen, die Arbeit zu koordinieren und freizugeben. Es wird erwartet, dass der zugeordnete Container vorhanden ist.

consumerGroup

String

Der Name der Consumergruppe, mit der dieser Prozessor verknüpft ist. Der Prozessor beansprucht exklusiven Lesezugriff auf Partitionen für diese Gruppe.

fullyQualifiedNamespace

String

Der vollqualifizierte Event Hubs-Namespace, mit dem eine Verbindung hergestellt werden soll. Dies ist wahrscheinlich ähnlich wie .{yournamespace}.servicebus.windows.net

eventHubName

String

Der Name des spezifischen Event Hubs, dem der Prozessor zugeordnet werden soll.

credential

AzureSasCredential

Die Anmeldeinformationen der Shared Access Signature, die für die Autorisierung verwendet werden sollen. Zugriffssteuerungen können je nach Azure-Konfiguration vom Event Hubs-Namespace oder vom angeforderten Event Hub angegeben werden.

clientOptions

EventProcessorClientOptions

Der Satz von Optionen, die für diesen Prozessor verwendet werden sollen.

Hinweise

Der container, der dem checkpointStore zugeordnet ist, wird erwartet, dass er vorhanden ist. der EventProcessorClient geht nicht von der Möglichkeit aus, das Speicherkonto zu verwalten, und kann nur mit Lese-/Schreibberechtigungen für Blobs im Container ausgeführt werden. Es wird empfohlen, dass dieser Container für die vom Prozessor verwendete Event Hub- und Consumergruppe eindeutig ist und keine anderen Blobs miteinander verknüpft.

EventProcessorClient(BlobContainerClient, String, String, String, TokenCredential, EventProcessorClientOptions)

Initialisiert eine neue Instanz der EventProcessorClient-Klasse.

public EventProcessorClient (Azure.Storage.Blobs.BlobContainerClient checkpointStore, string consumerGroup, string fullyQualifiedNamespace, string eventHubName, Azure.Core.TokenCredential credential, Azure.Messaging.EventHubs.EventProcessorClientOptions clientOptions = default);

new Azure.Messaging.EventHubs.EventProcessorClient : Azure.Storage.Blobs.BlobContainerClient * string * string * string * Azure.Core.TokenCredential * Azure.Messaging.EventHubs.EventProcessorClientOptions -> Azure.Messaging.EventHubs.EventProcessorClient

Public Sub New (checkpointStore As BlobContainerClient, consumerGroup As String, fullyQualifiedNamespace As String, eventHubName As String, credential As TokenCredential, Optional clientOptions As EventProcessorClientOptions = Nothing)

Parameter

checkpointStore

BlobContainerClient

Der Client, der für das Beibehalten von Prüfpunkten und den Prozessorstatus in dauerhaftem Speicher verantwortlich ist. Prozessorinstanzen, die diesen Speicher gemeinsam nutzen, versuchen, die Arbeit zu koordinieren und freizugeben. Es wird erwartet, dass der zugeordnete Container vorhanden ist.

consumerGroup

String

Der Name der Consumergruppe, mit der dieser Prozessor verknüpft ist. Der Prozessor beansprucht exklusiven Lesezugriff auf Partitionen für diese Gruppe.

fullyQualifiedNamespace

String

Der vollqualifizierte Event Hubs-Namespace, mit dem eine Verbindung hergestellt werden soll. Dies ist wahrscheinlich ähnlich wie .{yournamespace}.servicebus.windows.net

eventHubName

String

Der Name des spezifischen Event Hubs, dem der Prozessor zugeordnet werden soll.

credential

TokenCredential

Die Anmeldeinformationen der Azure-Identität, die für die Autorisierung verwendet werden sollen. Zugriffssteuerungen können je nach Azure-Konfiguration vom Event Hubs-Namespace oder vom angeforderten Event Hub angegeben werden.

clientOptions

EventProcessorClientOptions

Der Satz von Optionen, die für diesen Prozessor verwendet werden sollen.

Hinweise

Der container, der dem checkpointStore zugeordnet ist, wird erwartet, dass er vorhanden ist. der EventProcessorClient geht nicht von der Möglichkeit aus, das Speicherkonto zu verwalten, und kann nur mit Lese-/Schreibberechtigungen für Blobs im Container ausgeführt werden. Es wird empfohlen, dass dieser Container für die vom Prozessor verwendete Event Hub- und Consumergruppe eindeutig ist und keine anderen Blobs miteinander verknüpft.