StandardProtobufReader Controller Service
描述
将 Protocol Buffers 消息从二进制格式解析为 Lynxus Records。 支持多种 schema 访问策略,包括内联 schema 文本、schema registry 查找, 以及 schema 引用读取器。 Protobuf reader 需要知道 Proto schema 消息名称,才能正确反序列化二进制负载。 此消息的名称可以使用 'Message Name' 属性静态确定, 或使用 Message Name Resolver 服务动态确定。
标签
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| Schema Access Strategy | schema-name |
| 指定如何获取用于解释数据的架构。 |
| Schema Registry | | 控制器服务 API:SchemaRegistrycn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 指定用于架构Registry的Controller Service |
| Schema Name | ${schema.name} | 指定要在架构Registry属性中查找的架构名称 支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值) | |
| Schema Version | | 指定在 Schema Registry 中查找 Schema 的版本。如果未指定,则检索 Schema 的最新版本。 支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值) | |
| Schema Branch | | 指定在 Schema Registry 属性中查找 Schema 时使用的分支名称。如果选择的 Schema Registry 不支持分支,则此值将被忽略。 支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值) | |
| Schema Text | ${proto.schema} | Proto 3 格式的架构文本 支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值) | |
| Schema Reference Reader | | 控制器服务 API:SchemaReferenceReadercn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 服务实现负责读取 FlowFile 属性或内容以确定架构参考标识符 |
| Message Name Resolution Strategy | MESSAGE_NAME_PROPERTY |
| 确定要处理的 Protocol Buffers 消息名称的策略 |
| Message Name Resolver | | 控制器服务 API:MessageNameResolvercn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 从 FlowFile 内容或属性动态解析 Protocol Buffer 消息名称的服务 |
| Message Name | | Protocol Buffers 消息的完全限定名称,包括其包(例如 mypackage.MyMessage)。 支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值) |
状态管理
该组件不存储状态。
受限 (Restricted)
该组件不受限。
提供的 Service API
RecordReaderFactory