Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-03-03 16:09:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

NIFI-12304 Added FlowFileV3 Unpacking to ListenHTTP as a documented UseCase (#9369)

Browse Source 
Signed-off-by: David Handermann <exceptionfactory@apache.org>
This commit is contained in:
Michael Moser 2024-10-11 17:12:15 -04:00 committed by GitHub
parent 4c243bd877
commit 1bfdf3c107
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenHTTP.java
View File

@ -23,6 +23,7 @@ import org.apache.nifi.annotation.behavior.InputRequirement;
import org.apache.nifi.annotation.behavior.InputRequirement.Requirement;
import org.apache.nifi.annotation.documentation.CapabilityDescription;
import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.annotation.documentation.UseCase;
import org.apache.nifi.annotation.lifecycle.OnScheduled;
import org.apache.nifi.annotation.lifecycle.OnStopped;
import org.apache.nifi.annotation.notification.OnPrimaryNodeStateChange;
@ -88,6 +89,20 @@ import java.util.regex.Pattern;
+ "For details see the documentation of the \"Listening Port for health check requests\" property."
+ "A Record Reader and Record Writer property can be enabled on the processor to process incoming requests as records. "
+ "Record processing is not allowed for multipart requests and request in FlowFileV3 format (minifi).")
@UseCase(
description = "Unpack FlowFileV3 content received in a POST",
keywords = {"flowfile", "flowfilev3", "unpack"},
notes = """
POST requests with "Content-Type: application/flowfile-v3" will have their payload interpreted as FlowFileV3 format
and will be automatically unpacked. This will output the original FlowFile(s) from within the FlowFileV3 format and
will not require a separate UnpackContent processor.
""",
configuration = """
This feature of ListenHTTP is always on, no configuration required.
The MergeContent and PackageFlowFile processors can generate FlowFileV3 formatted data.
"""
)
public class ListenHTTP extends AbstractSessionFactoryProcessor {
private static final String MATCH_ALL = ".*";