AzureEventHubRecordSink - ACAL Lynxus 组件文档

AzureEventHubRecordSink Controller Service

类型全限定名：cn.org.acal.lynxus.services.azure.eventhub.AzureEventHubRecordSink

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

描述

格式化记录并将其发送到 Azure 事件中心

标签

azurerecordsink

属性

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

名称	默认值	可选值	描述
Service Bus Endpoint	`.servicebus.windows.net`	Azure — 默认 Service Bus 端点 Azure 中国 — 中国 Service Bus 端点 Azure 德国 — 德国 Service Bus 端点 Azure 美国政府 — 美国政府 Service Bus 端点	提供用于连接到 Azure 事件中心的域
Event Hub Namespace			提供用于连接到 Azure 事件中心的主机
Event Hub Name			提供连接的事件中心名称
Transport Type	`Amqp`	AMQP — 通过 TCP 在端口 5671 和 5672 上使用 AMQP AMQP_WEB_SOCKETS — 通过 HTTPS 使用 WebSockets 在端口 443 上使用 AMQP	用于与 Azure 事件中心通信的高级消息队列协议传输类型
Record Writer		控制器服务 API： `RecordSetWriterFactory` cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8	指定用于写出记录的Controller Service。
Authentication Strategy	`DEFAULT_AZURE_CREDENTIAL`	Shared Access Key — Azure Event Hub 共享访问密钥 Default Azure Credential — Default Azure Credential 将从标准环境变量读取凭据，并且在 Microsoft Azure 环境中运行时，还会尝试读取 Managed Identity 凭据	向 Azure 事件中心进行身份验证的策略
Shared Access Policy			共享访问策略的名称。此保单必须包含发送索赔
Shared Access Policy Key			共享访问策略的主键或辅助键敏感属性：是
Partition Key			Azure 事件中心消息代理如何跨一个或多个分区分发消息的提示支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

提供的 Service API

RecordSinkService (cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8)