无需使用AttributesToJSON处理器，如何将FlowFile属性写入其内容？

Absolutely! You don't have to rely on the AttributesToJSON processor to write FlowFile attributes into its content. There are several flexible alternatives depending on your use case—let's walk through the most practical ones:

1. Use ExecuteScript for Full Customization #

If you need control over the exact format (not just JSON) or have complex logic, ExecuteScript is your go-to. You can use Groovy, Python, or other supported languages to read attributes and write them directly to the FlowFile content.

Here's a quick Groovy example that converts all attributes to a JSON object:

def flowFile = session.get()
if (!flowFile) return

// Fetch all FlowFile attributes
def attributes = flowFile.getAttributes()

// Format attributes into a JSON string (customize this for CSV, plain text, etc.)
def jsonContent = attributes.collect { key, value -> "\"${key}\": \"${value}\"" }.join(", ")
jsonContent = "{${jsonContent}}"

// Write the formatted content back to the FlowFile
flowFile = session.write(flowFile, { out ->
    out.write(jsonContent.getBytes('UTF-8'))
} as OutputStreamCallback)

session.transfer(flowFile, REL_SUCCESS)

This script gives you full control—you could easily modify it to output attributes as a CSV list, key-value pairs in plain text, or any other format you need.

2. UpdateRecord for Record-Oriented Workflows #

If you're already working with record-based data (or want to leverage NiFi's record processing capabilities), UpdateRecord works great. It's especially useful if you want to inject attributes into existing content or structure the output as a valid record.

Here's how to configure it to write all attributes as a JSON object into an empty FlowFile:

• Record Reader: Use JsonTreeReader and enable the "Allow Empty FlowFiles" setting
• Record Writer: Use JsonRecordSetWriter (adjust the output format to "JSON Lines" or "Wrapped JSON" based on your needs)
• UpdateRecord Properties: Add a property where the key is / (targeting the root of the JSON structure) and the value is ${allAttributes()}. This will map all FlowFile attributes into the root of the JSON record.

You can also target individual attributes by setting properties like /myAttribute with a value of ${myAttribute} if you don't need all attributes.

3. ReplaceText for Quick, Simple JSON Output #

For the simplest use case (writing all attributes as JSON into an empty FlowFile), ReplaceText is the fastest option—no scripting required.

Configure it like this:

• Search Value: ^$ (this matches an empty FlowFile content)
• Replacement Value: ${json(${allAttributes()})}
• Replacement Strategy: "Replace Entire Text"

NiFi's expression language does the heavy lifting here: allAttributes() returns a map of all FlowFile attributes, and json() converts that map into a valid JSON string. This will directly replace empty content with your attributes formatted as JSON.

内容的提问来源于stack exchange，提问作者B. Pesevski