ListenHTTP 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-standard-nar
描述¶
启动 HTTP 服务器并监听给定的基本路径以将传入的请求转换为 FlowFiles。该服务的默认 URI 为 http:/ (http:/)/{hostname}:{port}/contentListener。仅支持 HEAD 和 POST 请求。GET、PUT、DELETE、OPTIONS 和 TRACE 将导致错误和 HTTP 响应状态码 405;CONNECT 还将导致错误和 HTTP 响应状态码 400。<service_URI>/healthcheck 上支持 GET。如果该服务可用,它将返回“200 OK”,其内容为“OK”。可以将运行状况检查功能配置为可通过其他端口访问。有关详细信息,请参阅“用于运行状况检查请求的监听端口”属性的文档。可以在处理器上启用“记录读取器”和“记录写入器”属性,以便将传入的请求作为记录进行处理。不允许对多部分请求和采用 FlowFileV3 格式的请求 (minifi) 进行记录处理。
输入要求¶
FORBIDDEN
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
---|---|
授权的 DN 模式 |
适用于传入连接的主体可分辨名称的正则表达式。如果模式与主题 DN 不匹配,则处理器将以 HTTP 403 禁用状态进行响应。 |
基本路径 |
传入连接的基本路径 |
作为属性接收的 HTTP 标头(正则表达式) |
指定用于确定应作为 FlowFile 属性传递的 HTTP 标头名称的正则表达式 |
HTTP 协议 |
支持与 HTTP 进行应用程序层协议协商的 TLS 协议 |
监听端口 |
监听传入连接的端口 |
未确认的最大 FlowFile 时间 |
等待确认 FlowFile 后将其从缓存中移除的最大时间 |
请求标头最大大小 |
发送到该处理器的请求中支持的最大 HTTP 标头大小 |
返回码 |
每次 HTTP 调用后返回的 HTTP 返回码 |
SSL Context Service |
SSL Context Service 支持 HTTPS |
authorized-issuer-dn-pattern |
适用于传入连接的发行者可分辨名称的正则表达式。如果模式与发行者 DN 不匹配,则处理器将以 HTTP 403 禁用状态进行响应。 |
client-authentication |
TLS 连接的客户端身份验证策略。配置 SSL Context Service 时为必填项。 |
health-check-port |
监听传入的运行状况检查请求的端口。如果已设置,则它必须与监听端口不同。如果处理器设置为使用双向 SSL 且使用的负载均衡器不支持运行状况检查请求的客户端身份验证,请配置此端口。只有 /<base_path>/healthcheck 服务可通过此端口使用,并且仅支持 GET 和 HEAD 请求。如果将处理器设置为不使用 SSL,则也不会在此端口上使用 SSL。如果处理器设置为使用单向 SSL,则将在此端口上使用单向 SSL。如果处理器设置为使用双向 SSL,则将在此端口上使用单向 SSL(不需要客户端身份验证)。 |
max-thread-pool-size |
嵌入式 Jetty 服务器使用的最大线程数。该值可以设置在 8 到 1000 之间。此属性的值会影响流程和操作系统的性能,因此只能在合理的情况下更改默认值。如果只有少量 HTTP 客户端连接到服务器,则小于默认值的值可能合适。如果预计有大量 HTTP 客户端同时向服务器发出请求,则可能需要更大的值。 |
multipart-read-buffer-size |
传入文件的内容将写入磁盘的阈值大小。仅适用于具有 Content-Type: multipart/form-data 的请求。用于防止拒绝服务类型的攻击,防止堆或磁盘空间被填满。 |
multipart-request-max-size |
请求的最大大小。仅适用于具有 Content-Type: multipart/form-data 的请求,用于防止拒绝服务类型的攻击,防止堆或磁盘空间被填满 |
record-reader |
用于将传入 FlowFile 解析到记录的记录读取器 |
record-writer |
记录写入器,用于在记录转换后对其进行序列化 |
关系¶
名称 |
描述 |
---|---|
success |
成功接收的 FlowFiles 的关系 |
用例¶
解压 POST 中收到的 FlowFileV3 内容 |
涉及其他组件的用例¶
限制接受的日期流速率 |