`

NiFi 读取Processor中的FlowFile

    博客分类:
  • NiFi
阅读更多
在Processor的onTrigger方法中,可以从ProcessSession参数中获取FlowFile中的内容,参考网上的一些写法,如
session.read(flowFile, new InputStreamCallback() {

			@Override
			public void process(final InputStream in) throws IOException {
				
				final InputStream bin = new  BufferedInputStream(in);
				System.out.println(bin);
			}
		});


读出来的内容总是空的。

想要读取到内容,可以采取一下方法
System.out.println(IOUtils.toString(in,Charset.defaultCharset()));


不过想要引入apache的common-io包
        <dependency>
            <groupId>commons-io</groupId>
            <artifactId>commons-io</artifactId>
        </dependency>
分享到:
评论

相关推荐

    nifi自定义processor简单案例

    nifi平台自定义processor的简单案例,代码实现,readme中有详细代码解读。

    nifi-processor-bundle-archetype:帮助定制处理器开发的原型

    注意:截至 2015 年 1 月 23 日,此原型已贡献给 Apache NiFi,请... mvn archetype:generate -DarchetypeGroupId=org.apache.nifi -DarchetypeArtifactId=nifi-processor-bundle-archetype -DarchetypeVersion=0.0.

    Apache Nifi 概念介绍、源码解析、开发指南(中文)

    NiFi 的基本概念包括 FlowFile、FlowFile Processor、Connection 和 Flow Controller。FlowFile 表示在系统中移动的每个对象,FlowFile 由两部分组成:content 内容和 attributes 属性。FlowFile Processor 负责对...

    apache NIFI 自定义grpc processor 源码

    5. **数据转换**:NiFi数据模型是基于FlowFile的,因此你可能需要将gRPC消息转换为FlowFile内容,或者反之。 6. **测试和打包**:编写单元测试以确保处理器按预期工作,并使用Maven或Gradle等构建工具将其打包成...

    Nifi模板-PostGreSqlToMySql数据分页实时采集-带分页.zip

    使用大数据处理工具NIFI,进行数据从Postgresql中导入到MySql中,实现数据的同步处理,处理的时候,是带有分页的,因为作者正在做相关的项目,而,用nifi同步数据好说,如何,进行数据的分页同步不好弄,这里,主要是,采用...

    nifi-processor-tester:一个用于外部测试NiFi处理器的项目

    java -cp nifi-processor-tester--all.jar [options] script_file 选项可能包括: -content Output flow file contents. Defaults to false -attrs Output flow file attributes. Defaults to false -all Output ...

    nifi-flowfile-utility:用于与Apache NiFi FlowFile捆绑包打交道的简单实用程序

    nifi-flowfile-utility 用于处理 Apache NiFi FlowFile 包的简单实用程序 让我们通过配置文件制作 FlowFile 包/包,用于测试等。 Todo:命令行实用程序,可根据一些简单的标准(如 id 等)提取流文件的属性和有效...

    NIFI用户手册(中英文对照).pdf

    3. 报问题:如果您在使用 NiFi 过程中遇到问题,应当报告给Apache NiFi。 NiFi 是一个功能强大且可扩展的数据流系统,支持多种数据路由、数据转换和系统媒介逻辑。 NiFi 提供了一个基于Web的用户界面,用于设计、...

    appache nifi 源码

    源码中,`org.apache.nifi.flowfile`包下的类定义了FlowFile的生命周期和操作,如`FlowFileRepository`用于存储FlowFile的元数据,`FlowFileQueue`则管理Processor之间的FlowFile传递。 NiFi的数据流模型基于...

    nifi-get-a-tag-processor

    2. **自定义Processor**: 在NiFi中,Processor是最基本的工作单元,负责执行特定任务。自定义Processor允许开发者根据需求扩展NiFi的功能。"nifi-get-a-tag-processor"就是一个这样的自定义Processor,专门用于解析...

    NiFi实时离线数据采集工具

    FlowFile 是NiFi 中的基本数据单位,包含了属性(Attribute)和内容(Content)。Processor 是处理数据的核心模块,负责接收、发送、转换和路由FlowFile。连接器则用于在Processor之间传递FlowFile,维持数据流动。 ...

    数据集成工具:Apache Nifi:Nifi脚本处理器与自定义开发.docx

    数据集成工具:Apache Nifi:Nifi脚本处理器与自定义开发.docx

    5、NiFi FileFlow示例和NIFI模板示例

    FlowFile在NiFi中代表数据包,它包含了数据内容和元数据。`GenerateFlowFile`处理器是用于生成FlowFile的一个基本工具,可以生成包含随机或自定义内容的流文件,通常用于测试和模拟数据源。你可以配置其属性如生成...

    nifi操作文档-官方

    系统属性(System Properties)部分描述了Nifi的系统级配置,包括核心属性(Core Properties)、状态管理(State Management)、H2设置(H2Settings)、FlowFile仓库(FlowFileRepository)和交换管理...

    apache nifi使用指南

    - **定义**:NiFi 用来追踪当前处于流程中的 FlowFile 的状态信息。 - **实现**:默认采用持久化的写入前端日志来实现,但也可以根据需要选择其他的实现方式。 ##### 3.5 内容存储库 - **定义**:存储 FlowFile 的...

    Nifi-JsonProcessor:使用Scala语言的自定义apache nifi处理器的示例项目开发

    例如,你可以读取FlowFile中的JSON数据,解析成Scala对象,然后根据业务逻辑进行转换,最后将结果写回FlowFile。 五、部署和使用自定义处理器 1. **部署NAR**:将编译好的NAR文件放入NiFi的`lib`目录下,重启NiFi...

    nifi配置超级用户_nifi_nifi配置超级用户_

    在Apache NiFi中,配置超级用户是确保系统安全和管理权限的重要步骤。NiFi是一个强大的数据处理和自动化工具,它支持复杂的数据路由、转换和系统集成。为了保护数据并限制不同用户对系统的访问权限,我们需要为管理...

    nifi使用笔记

    3. **FlowFileRepository**:NiFi 跟踪当前在流中活动的给定 FlowFile 状态的地方。这里存储了关于数据流的信息,包括但不限于元数据和状态信息。 4. **ContentRepository**:存储给定 FlowFile 实际内容字节的位置...

    apache nifi使用指南1.docx

    1. FlowFile:这是NiFi中表示数据流动的基本单位,包含了数据流的基本属性。 2. Processor(处理器):负责实际的数据处理工作。 3. Connection(连接线):作为数据的有界缓冲区,连接不同的处理器。 4. Flow ...

    9、NIFI综合应用场景-通过NIFI配置kafka的数据同步

    在Nifi与Kafka的集成中,Nifi可以作为数据的生产者将数据发送到Kafka,同时也可以作为消费者从Kafka中消费数据,实现了高效的数据同步。 **1、处理器说明** 在Nifi中,有两个关键的处理器涉及到与Kafka的交互: -...

Global site tag (gtag.js) - Google Analytics