StandardProtobufReader¶
描述¶
将 Protocol Buffers 消息从二进制格式解析为 NiFi 记录。支持多种架构访问策略,包括内联架构文本、架构注册表查询和架构参考阅读器。Protobuf 读取器需要知道 Proto 架构消息的名称,才能正确地反序列化二进制有效负载。此消息的名称可以使用 'Message Name' 属性静态确定,也可以使用消息名称解析器服务动态确定。
属性¶
下表列出了各项属性,其中带星号 (*) 的为必需属性。其他属性视为可选属性。该表还指出了所有默认值以及属性是否支持 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 |
指定要在架构注册表中查找的架构版本。如果未指定,则将检索架构的最新版本。 |
状态管理¶
此组件不存储状态。
受限¶
此组件不受限制。
系统资源注意事项¶
此组件未指定系统资源注意事项。