在NiFi中，您可以通过以下代码使用ExecuteGroovyScrip

def flowFile = session.get()
if (flowFile != null) {

    def inputFlow = flowFile.read().getText("UTF-8").readLines()

    def search = inputFlow.findAll { it.contains('"CC" :') }
    def searchStr = search.toString()
    flowFile = session.putAttribute(flowFile, 'search', searchStr)
    session.transfer(flowFile, REL_SUCCESS)
}

现在你有了一个属性搜索，行为CC，或者你也可以在这个代码中添加Base64解码

享受

我参考他们的答案来解决我的问题，如下所示。

我必须解析文本，因为解码后的字符串也是Json字符串。

如果我不解析已解码的字符串，结果将包含“\”字符，因为它只是字符串，而不是Json字符串

谢谢大家！

import groovy.json.JsonBuilder
import groovy.json.JsonSlurper
import groovy.json.JsonOutput; 
import org.apache.nifi.processor.io.StreamCallback

import java.nio.charset.StandardCharsets

def flowFile = session.get();
if (flowFile == null) {
    return;
}

flowFile = session.write(flowFile, { inputStream, outputStream ->

    def content = inputStream.getText("UTF-8")

    def data = new JsonSlurper().parseText(content)    

    data.A.each{obj ->

         def decodedString = new String(obj["CC"].decodeBase64())
         def decodedJsonObject = new JsonSlurper().parseText(decodedString)
         obj["CC"] = decodedJsonObject
    }

    outputStream.write(JsonOutput.toJson(data).getBytes(StandardCharsets.UTF_8))
} as StreamCallback)

session.transfer(flowFile, REL_SUCCESS)