StandardProtobufReader

描述

将 Protocol Buffers 消息从二进制格式解析为 NiFi 记录。支持多种架构访问策略,包括内联架构文本、架构注册表查询和架构参考阅读器。Protobuf 读取器需要知道 Proto 架构消息的名称,才能正确地反序列化二进制有效负载。此消息的名称可以使用 'Message Name' 属性静态确定,也可以使用消息名称解析器服务动态确定。

标签

parser、protobuf、reader、record

属性

下表列出了各项属性,其中带星号 (*) 的为必需属性。其他属性视为可选属性。该表还指出了所有默认值以及属性是否支持 NiFi 表达式语言。

显示名称

API 名称

默认值

允许值

描述

消息名称 *

消息名称

协议缓冲区消息的完全限定名称,包括其软件包(例如 mypackage.MyMessage)。

消息名称解析策略 *

消息名称解析策略

MESSAGE_NAME_PROPERTY

  • 消息名称属性

  • 消息名称解析器

确定用于处理的协议缓冲区消息名称的策略

消息名称解析器 *

消息名称解析器

根据 FlowFile 内容或属性动态解析协议缓冲区消息名称的服务

架构访问策略 *

schema-access-strategy

schema-name

  • 使用“架构名称”属性

  • 使用“架构文本”属性

  • 架构参考读取器

指定如何获取用于解读数据的架构。

架构分支

schema-branch

指定在“架构注册表”属性中查找架构时使用的分支名称。如果所选架构注册表不支持分支,则该值将被忽略。

架构名称

schema-name

${schema.name}

指定要在架构注册表属性中查找的架构的名称。

架构参考读取器 *

schema-reference-reader

服务实现,负责读取 FlowFile 属性或内容以确定架构参考标识符

架构注册表

schema-registry

指定用于架构注册表的控制器服务

架构文本 *

schema-text

${proto.schema}

Proto 3 格式架构的文本

架构版本

schema-version

指定要在架构注册表中查找的架构版本。如果未指定,则将检索架构的最新版本。

状态管理

此组件不存储状态。

受限

此组件不受限制。

系统资源注意事项

此组件未指定系统资源注意事项。

语言: 中文