Apachi Nifi问题,仅读取并保存选定列到文件。
创始人
2024-09-06 20:00:31
0

要仅读取和保存选定列到文件,您可以使用Apache Nifi的ExecuteScript处理器与Groovy脚本来实现。以下是一个示例代码片段:

import org.apache.commons.io.IOUtils
import org.apache.nifi.processor.io.OutputStreamCallback

// 获取输入流中的数据
def flowFile = session.get()
if (!flowFile) return

session.read(flowFile, { inputStream ->
    def inputText = IOUtils.toString(inputStream, 'UTF-8')

    // 选择您要提取的列
    def selectedColumns = [0, 2, 4] // 示例选择第1、第3和第5列

    // 提取选定列的数据
    def outputText = inputText.split('\n').collect { line ->
        def columns = line.split(',')
        selectedColumns.collect { columns[it] }.join(',')
    }.join('\n')

    // 将提取的数据写入输出流
    flowFile = session.write(flowFile, { outputStream ->
        outputStream.write(outputText.getBytes('UTF-8'))
    } as OutputStreamCallback)
})

session.transfer(flowFile, REL_SUCCESS)

将此代码片段放入ExecuteScript处理器的Script Body中,并将Script Language设置为Groovy。然后,您可以配置适当的输入和输出关系,以及其他处理器以及其他处理器来处理数据流。

此脚本将从输入流中读取数据,提取选定的列,并将提取的数据写入输出流,以便保存到文件中。您可以通过修改selectedColumns数组来选择不同的列。请记住,数组是从零开始的索引。

请注意,此示例假设输入数据是以逗号分隔的文本格式,并且每行都具有相同的列数。如果您的数据格式不同,请根据您的情况进行修改。

相关内容

热门资讯

让我来分享经验!hhpoker... 让我来分享经验!hhpoker是真的吗,如何下载wpk透视版,其实是有挂(存在有挂)1、完成有辅助插...
我来教教大家!xpoker辅助... 我来教教大家!xpoker辅助器,aapoker插件下载,总是真的有挂(有挂透视)1、全新机制【ai...
总算了解!wpk辅助器,soh... 总算了解!wpk辅助器,sohoo poker辅助,切实真的有挂(有挂方式)1、起透看视 辅助软件价...
指导大家!来玩app 德州 辅... 指导大家!来玩app 德州 辅助,wepoker好友助力码,都是是真的有挂(有挂分析)1、这是跨平台...
玩家必看攻略!wepoker轻... 玩家必看攻略!wepoker轻量版透视系统,wepoker高级辅助,真是存在有挂(有挂实锤)辅助器是...
一分钟快速了解!wepoker... 一分钟快速了解!wepoker透视最简单三个步骤,购买的wpk辅助在哪里下载,其实有挂(有挂教学)1...
玩家爆料!wepoker辅助器... 玩家爆料!wepoker辅助器安装包,wepoker辅助器安装包,总是是真的有挂(有挂规律)1、we...
最新技巧!hhpoker有后台... 最新技巧!hhpoker有后台操作吗,pokemmo手机版脚本,竟然存在有挂(有挂教学)1、透视辅助...
带你了解!德普之星有辅助软件吗... 带你了解!德普之星有辅助软件吗,红龙poker有辅助吗,竟然真的有挂(详细教程)1、进入游戏-大厅左...
分享给玩家!wejoker内置... 分享给玩家!wejoker内置辅助,约局吧德州透视,果然存在有挂(今日头条)1)有没有挂:进一步探索...