PutAzureEventHub - ACAL Lynxus 组件文档

PutAzureEventHub Processor

类型全限定名：cn.org.acal.lynxus.processors.azure.eventhub.PutAzureEventHub

所属 Bundle：cn.org.acal.lynxus:lynxus-azure-nar:2.11.8

描述

将 FlowFile 内容发送到 Azure 事件中心

标签

microsoftazurecloudeventhubeventsstreamsstreaming

属性

下表中，加粗的属性为必填项；其余为可选项。表格同时标注默认值、是否支持表达式语言，以及是否为敏感属性（值会被加密）。

名称	默认值	可选值	描述
Event Hub Namespace			以服务总线终结点域为前缀的 Azure 事件中心的Namespace
Event Hub Name			Azure 事件中心目标的名称
Service Bus Endpoint	`.servicebus.windows.net`	Azure — 通用 Service Bus 端点 Azure 中国 — 中国 Service Bus 端点 Azure 德国 — 德国 Service Bus 端点 Azure 美国政府 — 美国政府 Service Bus 端点	支持不在默认 windows.net 域中的Namespace。
Transport Type	`Amqp`	AMQP — 通过 TCP 在端口 5671 和 5672 上使用 AMQP AMQP_WEB_SOCKETS — 通过 HTTPS 使用 WebSockets 在端口 443 上使用 AMQP	用于与 Azure 事件中心通信的高级消息队列协议传输类型
Shared Access Policy Name			共享访问策略的名称。此保单必须有发送索赔。
Shared Access Policy Key			共享访问策略的关键。可以使用主键或辅助键。敏感属性：是
Authentication Strategy	`MANAGED_IDENTITY`	Managed Identity — 使用承载它的 Azure 资源的托管标识（Managed Identity）进行身份验证。 Shared Access Signature — 使用共享访问策略（Shared Access Policy）名称和密钥进行身份验证。 OAuth2 — 使用由 Entra 注册应用程序支持的 OAuth2 访问令牌提供程序（Access Token Provider）进行身份验证。 Identity Federation — 使用与 Azure AD 访问令牌交换的工作负载身份令牌进行身份验证。	指定用于向 Azure 事件中心进行身份验证的策略
Event Hubs Access Token Provider		控制器服务 API： `OAuth2AccessTokenProvider` cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8	Controller Service提供 OAuth2 访问令牌以对 Azure 事件中心进行身份验证
Event Hubs Identity Federation Token Provider		控制器服务 API： `AzureIdentityFederationTokenProvider` cn.org.acal.lynxus-lynxus-azure-services-api-nar-2.11.8	在向 Azure 事件中心进行身份验证时，Controller Service将工作负载身份令牌交换为 Azure AD 访问令牌。
Partitioning Key Attribute Name			如果指定，则此字段命名的参数的值将用作事件中心使用的分区键。
Maximum Batch Size	`100`		每次处理器调用处理的最大 FlowFile 数
Proxy Configuration Service		控制器服务 API： `ProxyConfigurationService` cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8	指定代理配置 Controller Service 来代理网络请求。

关系 (Relationships)

名称	描述	自动终止
`failure`	任何无法发送到事件中心的 FlowFile 将被传输到此关系。	否
`success`	成功发送到事件中心的任何FlowFile都将传输到此关系。	否

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。

系统资源考量

资源	描述
MEMORY	处理器在发送前将 FlowFile 内容缓冲在内存中