StandardProtobufReader

文档中心 › 组件索引 › StandardProtobufReader

StandardProtobufReader Controller Service

类型全限定名:cn.org.acal.lynxus.services.protobuf.StandardProtobufReader

所属 Bundle:cn.org.acal.lynxus:lynxus-protobuf-services-nar:2.11.8

描述

将 Protocol Buffers 消息从二进制格式解析为 Lynxus Records。 支持多种 schema 访问策略,包括内联 schema 文本、schema registry 查找, 以及 schema 引用读取器。 Protobuf reader 需要知道 Proto schema 消息名称,才能正确反序列化二进制负载。 此消息的名称可以使用 'Message Name' 属性静态确定, 或使用 Message Name Resolver 服务动态确定。

标签

protobufrecordreaderparser

属性

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

名称默认值可选值描述
Schema Access Strategyschema-name
  • 使用 'Schema Name' 属性 — 要使用的 Schema 名称由 'Schema Name' 属性指定。此属性的值用于在配置的 Schema Registry 服务中查找 Schema。
  • 使用 'Schema Text' 属性 — Schema 本身的文本由 'Schema Text' 属性指定。此属性的值必须是有效的 Avro Schema。如果使用表达式语言,则 'Schema Text' 属性的值在替换表达式后必须有效。
  • Schema 引用读取器 — Schema 引用信息将通过配置的 Schema 引用读取器服务实现提供。
指定如何获取用于解释数据的架构。
Schema Registry控制器服务 API:
SchemaRegistry
cn.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:
SchemaReferenceReader
cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8
服务实现负责读取 FlowFile 属性或内容以确定架构参考标识符
Message Name Resolution StrategyMESSAGE_NAME_PROPERTY
  • Message Name Property — 使用 'Message Name' 属性值来确定消息名称
  • Message Name Resolver — 使用“消息名称解析器”服务动态确定消息名称
确定要处理的 Protocol Buffers 消息名称的策略
Message Name Resolver控制器服务 API:
MessageNameResolver
cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8
从 FlowFile 内容或属性动态解析 Protocol Buffer 消息名称的服务
Message NameProtocol Buffers 消息的完全限定名称,包括其包(例如 mypackage.MyMessage)。
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

提供的 Service API

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