Apache NiFi 2.x处理器:PutSyslog 2.3.0

Apache NiFi 2.x处理器:PutSyslog 2.3.0

经验文章nimo972025-03-14 17:06:497A+A-

org.apache.nifi | nifi-standard-nar

描述

通过TCP或UDP将系统日志(Syslog)消息发送到指定的主机和端口。消息由处理器的 “Message ___” 属性构建而成,这些属性可以使用表达式语言从传入的FlowFile生成消息。这些属性用于构建以下形式的消息:()(VERSION )(TIMESTAMP) (HOSTNAME) (BODY),其中version是可选的。构建的消息会根据RFC5424和RFC3164格式消息的正则表达式进行检查。时间戳可以是RFC5424格式的时间戳,格式为 “yyyy-MM-dd'T'HH:mm:ss.SZ” 或 “yyyy-MM-dd'T'HH:mm:ss.S+hh:mm”,也可以是RFC3164格式的时间戳,格式为 “MMM d HH:mm:ss”。如果构建的消息不符合上述描述的有效系统日志消息格式,则会被路由到无效关系。有效消息会被发送到系统日志服务器,发送成功的消息会被路由到成功关系,发送失败的消息会被路由到失败关系。

标签

logs、put、syslog、tcp、udp

输入要求

必需

是否支持敏感动态属性

属性

  • Batch Size:在处理器的单次执行中要处理的传入FlowFile数量。
    • 显示名称:Batch Size
    • 描述:在处理器的单次执行中要处理的传入FlowFile数量。
    • API名称:Batch Size
    • 默认值:25
    • 表达式语言作用域:在JVM级别定义的环境变量和系统属性
    • 是否敏感:否
    • 是否必需:是
  • Character Set:指定系统日志消息的字符集。请注意,表达式语言不会针对每个FlowFile进行求值。
    • 显示名称:Character Set
    • 描述:指定系统日志消息的字符集。请注意,表达式语言不会针对每个FlowFile进行求值。
    • API名称:Character Set
    • 默认值:UTF-8
    • 表达式语言作用域:在JVM级别定义的环境变量和系统属性
    • 是否敏感:否
    • 是否必需:是
  • Hostname:系统日志服务器的IP地址或主机名。
    • 显示名称:Hostname
    • 描述:系统日志服务器的IP地址或主机名。
    • API名称:Hostname
    • 默认值:localhost
    • 表达式语言作用域:在JVM级别定义的环境变量和系统属性
    • 是否敏感:否
    • 是否必需:是
  • Idle Connection Expiration:连接在未使用的情况下保持打开状态的最长时间,超过该时间将关闭连接。
    • 显示名称:Idle Connection Expiration
    • 描述:连接在未使用的情况下保持打开状态的最长时间,超过该时间将关闭连接。
    • API名称:Idle Connection Expiration
    • 默认值:5秒
    • 表达式语言作用域:在JVM级别定义的环境变量和系统属性
    • 是否敏感:否
    • 是否必需:是
  • Max Size of Socket Send Buffer:应使用的套接字发送缓冲区的最大大小。这是向操作系统提出的建议,指示套接字缓冲区应设置的大小。如果该值设置得过低,缓冲区可能在数据被读取之前就已满,从而导致传入数据丢失。
    • 显示名称:Max Size of Socket Send Buffer
    • 描述:应使用的套接字发送缓冲区的最大大小。这是向操作系统提出的建议,指示套接字缓冲区应设置的大小。如果该值设置得过低,缓冲区可能在数据被读取之前就已满,从而导致传入数据丢失。
    • API名称:Max Size of Socket Send Buffer
    • 默认值:1 MB
    • 表达式语言作用域:在JVM级别定义的环境变量和系统属性
    • 是否敏感:否
    • 是否必需:是
  • Message Body:系统日志消息的正文。
    • 显示名称:Message Body
    • 描述:系统日志消息的正文。
    • API名称:Message Body
    • 表达式语言作用域:环境变量和FlowFile属性
    • 是否敏感:否
    • 是否必需:是
  • Message Hostname:系统日志消息的主机名。
    • 显示名称:Message Hostname
    • 描述:系统日志消息的主机名。
    • API名称:Message Hostname
    • 默认值:${hostname(true)}
    • 表达式语言作用域:环境变量和FlowFile属性
    • 是否敏感:否
    • 是否必需:是
  • Message Priority:系统日志消息的优先级,不包含<>。
    • 显示名称:Message Priority
    • 描述:系统日志消息的优先级,不包含<>。
    • API名称:Message Priority
    • 表达式语言作用域:环境变量和FlowFile属性
    • 是否敏感:否
    • 是否必需:是
  • Message Timestamp:系统日志消息的时间戳。时间戳可以是RFC5424格式的时间戳,格式为 “yyyy-MM-dd'T'HH:mm:ss.SZ” 或 “yyyy-MM-dd'T'HH:mm:ss.S+hh:mm”,也可以是RFC3164格式的时间戳,格式为 “MMM d HH:mm:ss”。
    • 显示名称:Message Timestamp
    • 描述:系统日志消息的时间戳。时间戳可以是RFC5424格式的时间戳,格式为 “yyyy-MM-dd'T'HH:mm:ss.SZ” 或 “yyyy-MM-dd'T'HH:mm:ss.S+hh:mm”,也可以是RFC3164格式的时间戳,格式为 “MMM d HH:mm:ss”。
    • API名称:Message Timestamp
    • 默认值:${now():format('MMM d HH:mm:ss')}
    • 表达式语言作用域:环境变量和FlowFile属性
    • 是否敏感:否
    • 是否必需:是
  • Message Version:系统日志消息的版本。
    • 显示名称:Message Version
    • 描述:系统日志消息的版本。
    • API名称:Message Version
    • 表达式语言作用域:环境变量和FlowFile属性
    • 是否敏感:否
    • 是否必需:否
  • Port:系统日志通信的端口。请注意,表达式语言不会针对每个FlowFile进行求值。
    • 显示名称:Port
    • 描述:系统日志通信的端口。请注意,表达式语言不会针对每个FlowFile进行求值。
    • API名称:Port
    • 表达式语言作用域:在JVM级别定义的环境变量和系统属性
    • 是否敏感:否
    • 是否必需:是
  • Protocol:系统日志通信的协议。
    • 显示名称:Protocol
    • 描述:系统日志通信的协议。
    • API名称:Protocol
    • 默认值:UDP
    • 允许值:TCP、UDP
    • 表达式语言作用域:不支持
    • 是否敏感:否
    • 是否必需:是
  • SSL Context Service:用于获取SSL上下文的控制器服务。如果设置了此属性,系统日志消息将通过安全连接发送。
    • 显示名称:SSL Context Service
    • 描述:用于获取SSL上下文的控制器服务。如果设置了此属性,系统日志消息将通过安全连接发送。
    • API名称:SSL Context Service
    • 服务接口:org.apache.nifi.ssl.SSLContextProviderService
    • 实现类:org.apache.nifi.ssl.PEMEncodedSSLContextProvider、org.apache.nifi.ssl.StandardRestrictedSSLContextService、org.apache.nifi.ssl.StandardSSLContextService
    • 表达式语言作用域:不支持
    • 是否敏感:否
    • 是否必需:否
  • 依赖项:Protocol设置为[TCP]中的任意一个
  • Timeout:连接到系统日志服务器并与之通信的超时时间。不适用于UDP。请注意,表达式语言不会针对每个FlowFile进行求值。
    • 显示名称:Timeout
    • 描述:连接到系统日志服务器并与之通信的超时时间。不适用于UDP。请注意,表达式语言不会针对每个FlowFile进行求值。
    • API名称:Timeout
    • 默认值:10秒
    • 表达式语言作用域:在JVM级别定义的环境变量和系统属性
    • 是否敏感:否
    • 是否必需:否

关系

另请参阅

  • org.apache.nifi.processors.standard.ListenSyslog
  • org.apache.nifi.processors.standard.ParseSyslog
点击这里复制本文地址 以上内容由nimo97整理呈现,请务必在转载分享时注明本文地址!如对内容有疑问,请联系我们,谢谢!
qrcode

尼墨宝库 © All Rights Reserved.  蜀ICP备2024111239号-7