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数组来选择不同的列。请记住,数组是从零开始的索引。

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

相关内容

热门资讯

透视黑科技!wepoker有没... 透视黑科技!wepoker有没有挂,wepoker私人局透视教程(切实存在有挂);1.wepoker...
透视安卓版!wepoker游戏... 透视安卓版!wepoker游戏下载,wepoker代打辅助(原来真的有挂)该软件可以轻松地帮助玩家将...
透视透视!有没有人wepoke... 透视透视!有没有人wepoker,WePoKer辅助器(原来真的有挂);1、让任何用户在无需有没有人...
透视攻略!we-poker有人... 透视攻略!we-poker有人玩吗,wepoker辅助透视软件(本来是有挂)1、不需要AI权限,帮助...
透视有挂!wepoker怎么设... 透视有挂!wepoker怎么设置房间,wepoker免费透视脚本(果然真的是有挂)1、打开软件启动之...
透视总结!wepoker辅助器... 透视总结!wepoker辅助器,wepoker有没有挂(真是真的是有挂)1、每一步都需要思考,不同水...
透视教程!wepoker看底牌... 透视教程!wepoker看底牌,wepoker怎么设置透视(果然是真的有挂)1、进入到wepoker...
透视黑科技!wepoker透视... 透视黑科技!wepoker透视底牌,wepoker私人局透视(总是有挂)1、wepoker私人局透视...
透视软件!wepoker有辅助... 透视软件!wepoker有辅助工具吗,wepoker辅助真的假的(原来是真的有挂);1、每一步都需要...
透视系统!wepoker挂,W... 透视系统!wepoker挂,We poker辅助器下载(切实存在有挂);1、We poker辅助器下...