EventProcessorHost Konstruktoren
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
EventProcessorHost(String, String, String, String, String) |
Erstellen Sie einen neuen Host, um Ereignisse von einem Event Hub zu verarbeiten. Da Event Hubs häufig für Szenarien mit hohem Horizontalskalieren mit hohem Datenverkehr verwendet werden, gibt es in der Regel nur einen Host pro Prozess, und die Prozesse werden auf separaten Computern ausgeführt. Es wird jedoch unterstützt, mehrere Hosts auf einem Computer oder sogar innerhalb eines Prozesses auszuführen, wenn der Durchsatz kein Problem ist. Diese Überladung des Konstruktors verwendet die standardmäßigen, integrierten Lease- und Prüfpunkt-Manager. Das durch den parameter storageConnectionString angegebene Azure Storage-Konto wird von den integrierten Managern verwendet, um Leases und Prüfpunkte aufzuzeichnen. |
EventProcessorHost(String, String, String, String, ICheckpointManager, ILeaseManager) |
Erstellen Sie einen neuen Host, um Ereignisse von einem Event Hub zu verarbeiten. Diese Überladung des Konstruktors ermöglicht maximale Flexibilität. Dadurch kann der Aufrufer auch den Namen des Prozessorhosts angeben. Die Überladung ermöglicht es dem Aufrufer auch, eigene Lease- und Prüfpunkt-Manager bereitzustellen, um die integrierten auf Azure Storage basierenden zu ersetzen. |
EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String) |
Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt TokenProvider |
EventProcessorHost(String, String, String, String, String, String, String) |
Erstellen Sie einen neuen Host, um Ereignisse von einem Event Hub zu verarbeiten. Diese Überladung des Konstruktors verwendet die standardmäßigen, integrierten Lease- und Prüfpunkt-Manager. |
EventProcessorHost(String, Uri, String, String, ITokenProvider, ICheckpointManager, ILeaseManager, Nullable<TimeSpan>, TransportType) |
Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt TokenProvider |
EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType) |
Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt TokenProvider |
EventProcessorHost(String, Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType) |
Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt TokenProvider |
EventProcessorHost(String, String, String, String, String)
- Quelle:
- EventProcessorHost.cs
Erstellen Sie einen neuen Host, um Ereignisse von einem Event Hub zu verarbeiten.
Da Event Hubs häufig für Szenarien mit hohem Horizontalskalieren mit hohem Datenverkehr verwendet werden, gibt es in der Regel nur einen Host pro Prozess, und die Prozesse werden auf separaten Computern ausgeführt. Es wird jedoch unterstützt, mehrere Hosts auf einem Computer oder sogar innerhalb eines Prozesses auszuführen, wenn der Durchsatz kein Problem ist.
Diese Überladung des Konstruktors verwendet die standardmäßigen, integrierten Lease- und Prüfpunkt-Manager. Das durch den parameter storageConnectionString angegebene Azure Storage-Konto wird von den integrierten Managern verwendet, um Leases und Prüfpunkte aufzuzeichnen.
public EventProcessorHost (string eventHubPath, string consumerGroupName, string eventHubConnectionString, string storageConnectionString, string leaseContainerName);
new Microsoft.Azure.EventHubs.Processor.EventProcessorHost : string * string * string * string * string -> Microsoft.Azure.EventHubs.Processor.EventProcessorHost
Public Sub New (eventHubPath As String, consumerGroupName As String, eventHubConnectionString As String, storageConnectionString As String, leaseContainerName As String)
Parameter
- eventHubPath
- String
Der Name des EventHub.
- consumerGroupName
- String
Der Name der Consumergruppe im Event Hub.
- eventHubConnectionString
- String
Verbindungszeichenfolge für den Event Hub, von dem empfangen werden soll.
- storageConnectionString
- String
Verbindungszeichenfolge mit dem Azure Storage-Konto, das für Leases und Prüfpunkte verwendet wird.
- leaseContainerName
- String
Azure Storage-Containername zur Verwendung durch integrierte Lease und Prüfpunkt-Manager.
Gilt für:
EventProcessorHost(String, String, String, String, ICheckpointManager, ILeaseManager)
- Quelle:
- EventProcessorHost.cs
Erstellen Sie einen neuen Host, um Ereignisse von einem Event Hub zu verarbeiten.
Diese Überladung des Konstruktors ermöglicht maximale Flexibilität. Dadurch kann der Aufrufer auch den Namen des Prozessorhosts angeben. Die Überladung ermöglicht es dem Aufrufer auch, eigene Lease- und Prüfpunkt-Manager bereitzustellen, um die integrierten auf Azure Storage basierenden zu ersetzen.
public EventProcessorHost (string hostName, string eventHubPath, string consumerGroupName, string eventHubConnectionString, Microsoft.Azure.EventHubs.Processor.ICheckpointManager checkpointManager, Microsoft.Azure.EventHubs.Processor.ILeaseManager leaseManager);
new Microsoft.Azure.EventHubs.Processor.EventProcessorHost : string * string * string * string * Microsoft.Azure.EventHubs.Processor.ICheckpointManager * Microsoft.Azure.EventHubs.Processor.ILeaseManager -> Microsoft.Azure.EventHubs.Processor.EventProcessorHost
Public Sub New (hostName As String, eventHubPath As String, consumerGroupName As String, eventHubConnectionString As String, checkpointManager As ICheckpointManager, leaseManager As ILeaseManager)
Parameter
- hostName
- String
Name des Prozessorhosts. MUSS EINDEUTIG SEIN. Es wird dringend empfohlen, eine GUID einzuschlehen, um die Eindeutigkeit sicherzustellen.
- eventHubPath
- String
Der Name des EventHub.
- consumerGroupName
- String
Der Name der Consumergruppe im Event Hub.
- eventHubConnectionString
- String
Verbindungszeichenfolge für den Event Hub, von dem empfangen werden soll.
- checkpointManager
- ICheckpointManager
Objekt, das ICheckpointManager implementiert, das partitionsprüfpunkting verarbeitet.
- leaseManager
- ILeaseManager
Objekt, das ILeaseManager implementiert, das Leases für Partitionen verarbeitet.
Gilt für:
EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String)
- Quelle:
- EventProcessorHost.cs
Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt TokenProvider
public EventProcessorHost (Uri endpointAddress, string eventHubPath, string consumerGroupName, Microsoft.Azure.EventHubs.ITokenProvider tokenProvider, Microsoft.Azure.Storage.CloudStorageAccount cloudStorageAccount, string leaseContainerName);
new Microsoft.Azure.EventHubs.Processor.EventProcessorHost : Uri * string * string * Microsoft.Azure.EventHubs.ITokenProvider * Microsoft.Azure.Storage.CloudStorageAccount * string -> Microsoft.Azure.EventHubs.Processor.EventProcessorHost
Public Sub New (endpointAddress As Uri, eventHubPath As String, consumerGroupName As String, tokenProvider As ITokenProvider, cloudStorageAccount As CloudStorageAccount, leaseContainerName As String)
Parameter
- endpointAddress
- Uri
Vollqualifizierter Domänenname für Event Hubs. Höchstwahrscheinlich{yournamespace}.servicebus.windows.net
- eventHubPath
- String
Der Name des EventHub.
- consumerGroupName
- String
Der Name der Consumergruppe im Event Hub.
- tokenProvider
- ITokenProvider
Tokenanbieter, der Sicherheitstoken für die Autorisierung generiert.
- cloudStorageAccount
- CloudStorageAccount
Azure Storage-Konto, das für Leases und Prüfpunkte verwendet wird.
- leaseContainerName
- String
Azure Storage-Containername zur Verwendung durch integrierte Lease und Prüfpunkt-Manager.
Gilt für:
EventProcessorHost(String, String, String, String, String, String, String)
- Quelle:
- EventProcessorHost.cs
Erstellen Sie einen neuen Host, um Ereignisse von einem Event Hub zu verarbeiten.
Diese Überladung des Konstruktors verwendet die standardmäßigen, integrierten Lease- und Prüfpunkt-Manager.
public EventProcessorHost (string hostName, string eventHubPath, string consumerGroupName, string eventHubConnectionString, string storageConnectionString, string leaseContainerName, string storageBlobPrefix = default);
new Microsoft.Azure.EventHubs.Processor.EventProcessorHost : string * string * string * string * string * string * string -> Microsoft.Azure.EventHubs.Processor.EventProcessorHost
Public Sub New (hostName As String, eventHubPath As String, consumerGroupName As String, eventHubConnectionString As String, storageConnectionString As String, leaseContainerName As String, Optional storageBlobPrefix As String = Nothing)
Parameter
- hostName
- String
Name des Prozessorhosts. MUSS EINDEUTIG SEIN. Es wird dringend empfohlen, eine GUID einzuschlehen, um die Eindeutigkeit sicherzustellen.
- eventHubPath
- String
Der Name des EventHub.
- consumerGroupName
- String
Der Name der Consumergruppe im Event Hub.
- eventHubConnectionString
- String
Verbindungszeichenfolge für den Event Hub, von dem empfangen werden soll.
- storageConnectionString
- String
Verbindungszeichenfolge mit dem Azure Storage-Konto, das für Leases und Prüfpunkte verwendet wird.
- leaseContainerName
- String
Azure Storage-Containername zur Verwendung durch integrierte Lease und Prüfpunkt-Manager.
- storageBlobPrefix
- String
Präfix, das beim Benennen von Blobs innerhalb des Speichercontainers verwendet wird.
Gilt für:
EventProcessorHost(String, Uri, String, String, ITokenProvider, ICheckpointManager, ILeaseManager, Nullable<TimeSpan>, TransportType)
- Quelle:
- EventProcessorHost.cs
Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt TokenProvider
public EventProcessorHost (string hostName, Uri endpointAddress, string eventHubPath, string consumerGroupName, Microsoft.Azure.EventHubs.ITokenProvider tokenProvider, Microsoft.Azure.EventHubs.Processor.ICheckpointManager checkpointManager, Microsoft.Azure.EventHubs.Processor.ILeaseManager leaseManager, TimeSpan? operationTimeout = default, Microsoft.Azure.EventHubs.TransportType transportType = Microsoft.Azure.EventHubs.TransportType.Amqp);
new Microsoft.Azure.EventHubs.Processor.EventProcessorHost : string * Uri * string * string * Microsoft.Azure.EventHubs.ITokenProvider * Microsoft.Azure.EventHubs.Processor.ICheckpointManager * Microsoft.Azure.EventHubs.Processor.ILeaseManager * Nullable<TimeSpan> * Microsoft.Azure.EventHubs.TransportType -> Microsoft.Azure.EventHubs.Processor.EventProcessorHost
Public Sub New (hostName As String, endpointAddress As Uri, eventHubPath As String, consumerGroupName As String, tokenProvider As ITokenProvider, checkpointManager As ICheckpointManager, leaseManager As ILeaseManager, Optional operationTimeout As Nullable(Of TimeSpan) = Nothing, Optional transportType As TransportType = Microsoft.Azure.EventHubs.TransportType.Amqp)
Parameter
- hostName
- String
Name des Prozessorhosts. MUSS EINDEUTIG SEIN. Es wird dringend empfohlen, eine GUID einzuschlehen, um die Eindeutigkeit sicherzustellen.
- endpointAddress
- Uri
Vollqualifizierter Domänenname für Event Hubs. Höchstwahrscheinlich{yournamespace}.servicebus.windows.net
- eventHubPath
- String
Der Name des EventHub.
- consumerGroupName
- String
Der Name der Consumergruppe im Event Hub.
- tokenProvider
- ITokenProvider
Tokenanbieter, der Sicherheitstoken für die Autorisierung generiert.
- checkpointManager
- ICheckpointManager
Objekt, das ICheckpointManager implementiert, das partitionsprüfpunkting verarbeitet.
- leaseManager
- ILeaseManager
Objekt, das ILeaseManager implementiert, das Leases für Partitionen verarbeitet.
- transportType
- TransportType
Transporttyp bei Verbindung.
Gilt für:
EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType)
- Quelle:
- EventProcessorHost.cs
Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt TokenProvider
public EventProcessorHost (Uri endpointAddress, string eventHubPath, string consumerGroupName, Microsoft.Azure.EventHubs.ITokenProvider tokenProvider, Microsoft.Azure.Storage.CloudStorageAccount cloudStorageAccount, string leaseContainerName, string storageBlobPrefix = default, TimeSpan? operationTimeout = default, Microsoft.Azure.EventHubs.TransportType transportType = Microsoft.Azure.EventHubs.TransportType.Amqp);
new Microsoft.Azure.EventHubs.Processor.EventProcessorHost : Uri * string * string * Microsoft.Azure.EventHubs.ITokenProvider * Microsoft.Azure.Storage.CloudStorageAccount * string * string * Nullable<TimeSpan> * Microsoft.Azure.EventHubs.TransportType -> Microsoft.Azure.EventHubs.Processor.EventProcessorHost
Public Sub New (endpointAddress As Uri, eventHubPath As String, consumerGroupName As String, tokenProvider As ITokenProvider, cloudStorageAccount As CloudStorageAccount, leaseContainerName As String, Optional storageBlobPrefix As String = Nothing, Optional operationTimeout As Nullable(Of TimeSpan) = Nothing, Optional transportType As TransportType = Microsoft.Azure.EventHubs.TransportType.Amqp)
Parameter
- endpointAddress
- Uri
Vollqualifizierter Domänenname für Event Hubs. Höchstwahrscheinlich{yournamespace}.servicebus.windows.net
- eventHubPath
- String
Der Name des EventHub.
- consumerGroupName
- String
Der Name der Consumergruppe im Event Hub.
- tokenProvider
- ITokenProvider
Tokenanbieter, der Sicherheitstoken für die Autorisierung generiert.
- cloudStorageAccount
- CloudStorageAccount
Azure Storage-Konto, das für Leases und Prüfpunkte verwendet wird.
- leaseContainerName
- String
Azure Storage-Containername zur Verwendung durch integrierte Lease und Prüfpunkt-Manager.
- storageBlobPrefix
- String
Präfix, das beim Benennen von Blobs innerhalb des Speichercontainers verwendet wird.
- transportType
- TransportType
Transporttyp bei Verbindung.
Gilt für:
EventProcessorHost(String, Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType)
- Quelle:
- EventProcessorHost.cs
Erstellen eines neuen Hosts zum Verarbeiten von Ereignissen aus einem Event Hub mit bereitgestellt TokenProvider
public EventProcessorHost (string hostName, Uri endpointAddress, string eventHubPath, string consumerGroupName, Microsoft.Azure.EventHubs.ITokenProvider tokenProvider, Microsoft.Azure.Storage.CloudStorageAccount cloudStorageAccount, string leaseContainerName, string storageBlobPrefix = default, TimeSpan? operationTimeout = default, Microsoft.Azure.EventHubs.TransportType transportType = Microsoft.Azure.EventHubs.TransportType.Amqp);
new Microsoft.Azure.EventHubs.Processor.EventProcessorHost : string * Uri * string * string * Microsoft.Azure.EventHubs.ITokenProvider * Microsoft.Azure.Storage.CloudStorageAccount * string * string * Nullable<TimeSpan> * Microsoft.Azure.EventHubs.TransportType -> Microsoft.Azure.EventHubs.Processor.EventProcessorHost
Public Sub New (hostName As String, endpointAddress As Uri, eventHubPath As String, consumerGroupName As String, tokenProvider As ITokenProvider, cloudStorageAccount As CloudStorageAccount, leaseContainerName As String, Optional storageBlobPrefix As String = Nothing, Optional operationTimeout As Nullable(Of TimeSpan) = Nothing, Optional transportType As TransportType = Microsoft.Azure.EventHubs.TransportType.Amqp)
Parameter
- hostName
- String
Name des Prozessorhosts. MUSS EINDEUTIG SEIN. Es wird dringend empfohlen, eine GUID einzuschlehen, um die Eindeutigkeit sicherzustellen.
- endpointAddress
- Uri
Vollqualifizierter Domänenname für Event Hubs. Höchstwahrscheinlich{yournamespace}.servicebus.windows.net
- eventHubPath
- String
Der Name des EventHub.
- consumerGroupName
- String
Der Name der Consumergruppe im Event Hub.
- tokenProvider
- ITokenProvider
Tokenanbieter, der Sicherheitstoken für die Autorisierung generiert.
- cloudStorageAccount
- CloudStorageAccount
Azure Storage-Konto, das für Leases und Prüfpunkte verwendet wird.
- leaseContainerName
- String
Azure Storage-Containername zur Verwendung durch integrierte Lease und Prüfpunkt-Manager.
- storageBlobPrefix
- String
Präfix, das beim Benennen von Blobs innerhalb des Speichercontainers verwendet wird.
- transportType
- TransportType
Transporttyp bei Verbindung.
Gilt für:
Azure SDK for .NET