你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

EventProcessor<TPartition> 构造函数

定义

重载

EventProcessor<TPartition>()

初始化 EventProcessor<TPartition> 类的新实例。

EventProcessor<TPartition>(Int32, String, String, EventProcessorOptions)

初始化 EventProcessor<TPartition> 类的新实例。

EventProcessor<TPartition>(Int32, String, String, String, EventProcessorOptions)

初始化 EventProcessor<TPartition> 类的新实例。

EventProcessor<TPartition>(Int32, String, String, String, AzureNamedKeyCredential, EventProcessorOptions)

初始化 EventProcessor<TPartition> 类的新实例。

EventProcessor<TPartition>(Int32, String, String, String, AzureSasCredential, EventProcessorOptions)

初始化 EventProcessor<TPartition> 类的新实例。

EventProcessor<TPartition>(Int32, String, String, String, TokenCredential, EventProcessorOptions)

初始化 EventProcessor<TPartition> 类的新实例。

EventProcessor<TPartition>()

Source:
EventProcessor.cs
Source:
EventProcessor.cs

初始化 EventProcessor<TPartition> 类的新实例。

protected EventProcessor ();
Protected Sub New ()

适用于

EventProcessor<TPartition>(Int32, String, String, EventProcessorOptions)

Source:
EventProcessor.cs
Source:
EventProcessor.cs

初始化 EventProcessor<TPartition> 类的新实例。

protected EventProcessor (int eventBatchMaximumCount, string consumerGroup, string connectionString, Azure.Messaging.EventHubs.Primitives.EventProcessorOptions options = default);
new Azure.Messaging.EventHubs.Primitives.EventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))> : int * string * string * Azure.Messaging.EventHubs.Primitives.EventProcessorOptions -> Azure.Messaging.EventHubs.Primitives.EventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))>
Protected Sub New (eventBatchMaximumCount As Integer, consumerGroup As String, connectionString As String, Optional options As EventProcessorOptions = Nothing)

参数

eventBatchMaximumCount
Int32

要包含在要处理的批处理中的所需事件数。 此大小是批中的最大计数;实际计数可能较小,具体取决于事件中心是否可用。

consumerGroup
String

与此处理器关联的使用者组的名称。 处理器将断言对此组的分区的独占读取访问权限。

connectionString
String

用于连接到事件中心命名空间的连接字符串;此连接字符串中应包含事件中心名称和共享密钥属性。

options
EventProcessorOptions

要用于处理器的选项集。

例外

当请求 eventBatchMaximumCount 的小于 1 时发生。

注解

如果连接字符串是从事件中心命名空间复制的,则它可能不会包含所需事件中心的名称,这是必需的。 在这种情况下,可以通过添加“;手动添加名称EntityPath=[[ EVENT HUB NAME ]]“ 到连接字符串的末尾。 例如,“;EntityPath=telemetry-hub”。

如果已直接在事件中心本身上定义共享访问策略,则从该事件中心复制连接字符串将导致包含该名称的连接字符串。

适用于

EventProcessor<TPartition>(Int32, String, String, String, EventProcessorOptions)

Source:
EventProcessor.cs
Source:
EventProcessor.cs

初始化 EventProcessor<TPartition> 类的新实例。

protected EventProcessor (int eventBatchMaximumCount, string consumerGroup, string connectionString, string eventHubName, Azure.Messaging.EventHubs.Primitives.EventProcessorOptions options = default);
new Azure.Messaging.EventHubs.Primitives.EventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))> : int * string * string * string * Azure.Messaging.EventHubs.Primitives.EventProcessorOptions -> Azure.Messaging.EventHubs.Primitives.EventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))>
Protected Sub New (eventBatchMaximumCount As Integer, consumerGroup As String, connectionString As String, eventHubName As String, Optional options As EventProcessorOptions = Nothing)

参数

eventBatchMaximumCount
Int32

要包含在要处理的批处理中的所需事件数。 此大小是批中的最大计数;实际计数可能较小,具体取决于事件中心是否可用。

consumerGroup
String

与此处理器关联的使用者组的名称。 处理器将断言对此组的分区的独占读取访问权限。

connectionString
String

用于连接到事件中心命名空间的连接字符串;共享密钥属性应包含在此连接字符串中,但不包含事件中心名称。

eventHubName
String

要与之关联的特定事件中心的名称。

options
EventProcessorOptions

要用于处理器的选项集。

例外

当请求 eventBatchMaximumCount 的小于 1 时发生。

注解

如果连接字符串是从事件中心本身复制的,它将包含所需事件中心的名称,并且可以直接使用,而无需传递 eventHubName。 事件中心的名称应仅传递一次,可以是连接字符串的一部分,也可以单独传递。

适用于

EventProcessor<TPartition>(Int32, String, String, String, AzureNamedKeyCredential, EventProcessorOptions)

Source:
EventProcessor.cs
Source:
EventProcessor.cs

初始化 EventProcessor<TPartition> 类的新实例。

protected EventProcessor (int eventBatchMaximumCount, string consumerGroup, string fullyQualifiedNamespace, string eventHubName, Azure.AzureNamedKeyCredential credential, Azure.Messaging.EventHubs.Primitives.EventProcessorOptions options = default);
new Azure.Messaging.EventHubs.Primitives.EventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))> : int * string * string * string * Azure.AzureNamedKeyCredential * Azure.Messaging.EventHubs.Primitives.EventProcessorOptions -> Azure.Messaging.EventHubs.Primitives.EventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))>
Protected Sub New (eventBatchMaximumCount As Integer, consumerGroup As String, fullyQualifiedNamespace As String, eventHubName As String, credential As AzureNamedKeyCredential, Optional options As EventProcessorOptions = Nothing)

参数

eventBatchMaximumCount
Int32

要包含在要处理的批处理中的所需事件数。 此大小是批中的最大计数;实际计数可能较小,具体取决于事件中心是否可用。

consumerGroup
String

与此处理器关联的使用者组的名称。 处理器将断言对此组的分区的独占读取访问权限。

fullyQualifiedNamespace
String

要连接到的完全限定的事件中心命名空间。 这可能类似于 {yournamespace}.servicebus.windows.net

eventHubName
String

要与之关联的特定事件中心的名称。

credential
AzureNamedKeyCredential

用于授权的共享访问密钥凭据。 访问控制可能由事件中心命名空间或请求的事件中心指定,具体取决于 Azure 配置。

options
EventProcessorOptions

要用于处理器的选项集。

例外

当请求 eventBatchMaximumCount 的小于 1 时发生。

适用于

EventProcessor<TPartition>(Int32, String, String, String, AzureSasCredential, EventProcessorOptions)

Source:
EventProcessor.cs
Source:
EventProcessor.cs

初始化 EventProcessor<TPartition> 类的新实例。

protected EventProcessor (int eventBatchMaximumCount, string consumerGroup, string fullyQualifiedNamespace, string eventHubName, Azure.AzureSasCredential credential, Azure.Messaging.EventHubs.Primitives.EventProcessorOptions options = default);
new Azure.Messaging.EventHubs.Primitives.EventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))> : int * string * string * string * Azure.AzureSasCredential * Azure.Messaging.EventHubs.Primitives.EventProcessorOptions -> Azure.Messaging.EventHubs.Primitives.EventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))>
Protected Sub New (eventBatchMaximumCount As Integer, consumerGroup As String, fullyQualifiedNamespace As String, eventHubName As String, credential As AzureSasCredential, Optional options As EventProcessorOptions = Nothing)

参数

eventBatchMaximumCount
Int32

要包含在要处理的批处理中的所需事件数。 此大小是批中的最大计数;实际计数可能较小,具体取决于事件中心是否可用。

consumerGroup
String

与此处理器关联的使用者组的名称。 处理器将断言对此组的分区的独占读取访问权限。

fullyQualifiedNamespace
String

要连接到的完全限定的事件中心命名空间。 这可能类似于 {yournamespace}.servicebus.windows.net

eventHubName
String

要与之关联的特定事件中心的名称。

credential
AzureSasCredential

用于授权的共享签名凭据。 访问控制可能由事件中心命名空间或请求的事件中心指定,具体取决于 Azure 配置。

options
EventProcessorOptions

要用于处理器的选项集。

例外

当请求 eventBatchMaximumCount 的小于 1 时发生。

适用于

EventProcessor<TPartition>(Int32, String, String, String, TokenCredential, EventProcessorOptions)

Source:
EventProcessor.cs
Source:
EventProcessor.cs

初始化 EventProcessor<TPartition> 类的新实例。

protected EventProcessor (int eventBatchMaximumCount, string consumerGroup, string fullyQualifiedNamespace, string eventHubName, Azure.Core.TokenCredential credential, Azure.Messaging.EventHubs.Primitives.EventProcessorOptions options = default);
new Azure.Messaging.EventHubs.Primitives.EventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))> : int * string * string * string * Azure.Core.TokenCredential * Azure.Messaging.EventHubs.Primitives.EventProcessorOptions -> Azure.Messaging.EventHubs.Primitives.EventProcessor<'Partition (requires 'Partition :> Azure.Messaging.EventHubs.Primitives.EventProcessorPartition and 'Partition : (new : unit -> 'Partition))>
Protected Sub New (eventBatchMaximumCount As Integer, consumerGroup As String, fullyQualifiedNamespace As String, eventHubName As String, credential As TokenCredential, Optional options As EventProcessorOptions = Nothing)

参数

eventBatchMaximumCount
Int32

要包含在要处理的批处理中的所需事件数。 此大小是批中的最大计数;实际计数可能较小,具体取决于事件中心是否可用。

consumerGroup
String

与此处理器关联的使用者组的名称。 处理器将断言对此组的分区的独占读取访问权限。

fullyQualifiedNamespace
String

要连接到的完全限定的事件中心命名空间。 这可能类似于 {yournamespace}.servicebus.windows.net

eventHubName
String

要与之关联的特定事件中心的名称。

credential
TokenCredential

用于授权的 Azure 托管标识凭据。 访问控制可能由事件中心命名空间或请求的事件中心指定,具体取决于 Azure 配置。

options
EventProcessorOptions

要用于处理器的选项集。

例外

当请求 eventBatchMaximumCount 的小于 1 时发生。

适用于