GetAzureEventHub 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-azure-nar
描述¶
在不进行可靠的检查点跟踪的情况下接收来自 Microsoft Azure 事件中心的消息。在集群环境中，GetAzureEventHub 处理器实例独立工作，所有集群节点处理所有消息（除非处理器以“Primary Only”模式运行）。ConsumeAzureEventHub 提供从 Azure 事件中心接收消息的推荐方法。该处理器为 Azure 事件中心连接创建线程池。
输入要求¶
FORBIDDEN
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
事件中心使用者组 |
提取事件时使用的使用者组的名称 |
事件中心消息排队时间 |
格式化为 YYYY-MM-DDThhmmss.sssZ (2016-01-01T01:01:01.000Z) 的时间戳 (ISO-8601 Instant)，消息应该已经加入事件中心队列以开始读取 |
事件中心名称 |
Azure 事件中心源的名称 |
事件中心命名空间 |
以服务总线端点域为前缀的 Azure 事件中心的命名空间 |
分区接收器超时（毫秒） |
分区接收器在返回前等待接收 Fetch Size 的时长（以毫秒为单位）。默认值为 60000 |
分区接收器提取大小 |
接收器在返回之前应从事件中心分区提取的事件数。默认值为 100 |
服务总线端点 |
用于支持非默认 windows.net 域的命名空间。 |
共享访问策略名称 |
共享访问策略的名称。此策略必须拥有 Listen 权限。 |
共享的访问策略主键 |
共享访问策略的键。可以使用主键或辅助键。 |
传输类型 |
用于与 Azure 事件中心通信的高级消息队列协议传输类型 |
proxy-configuration-service |
指定代理配置控制器服务来代理网络请求。 |
use-managed-identity |
选择是否使用 Azure VM/VMSS 的托管身份 |
关系¶
名称 |
描述 |
|---|---|
success |
从事件中心成功收到的任何 FlowFile 都将转移到此关系。 |
写入属性¶
名称 |
描述 |
|---|---|
eventhub.enqueued.timestamp |
消息在事件中心排队的时间（以纪元以来的毫秒为单位，UTC） |
eventhub.offset |
存储消息的分区的偏移量 |
eventhub.sequence |
与消息关联的 Azure 序列号 |
eventhub.name |
从中提取消息的事件中心的名称 |
eventhub.partition |
从中提取消息的事件中心分区的名称 |
eventhub.property.* |
此消息的应用程序属性。IE：“application”将表示为“属性” |