日志接入

# log_data
[LogDataInput] 
type = "LogstreamerInput"
# 设置日志监听目录
log_directory = "/opt/matrixapp/matrix/tmp" 
# 日志文件匹配规则，也可以是具体文件名称：file_match = '2.log'
file_match = '(?P<FileName>[^/]+).log'
splitter = "LogDataSplitter"
differentiator = ["FileName"] 
priority = ["FileName"]

# 设置Splitter的名字
[LogDataSplitter]      
type = "TokenSplitter"
# 设置批量发送日志的上限条数
count = 300        
deliver_incomplete_final = true
# 设置批量发送日志的上限时间
interval = "15s"   

# 名字+Output
[LogDataOutput] 
type = "NatsOutput"
is_streaming = true
# 必要设置
subject = "matrix.rules.test.itmlog" 
reconnect = true
message_matcher = "Logger == 'LogDataInput'"
encoder = "PayloadEncoder"
use_buffering = false
use_protocol = true
# 必要设置，规则中会用到
bitlog_id = "linux:node3" 

[LogDataOutput.attr]

[!NOTE]

注意count和interval任何一个满足条件，则进行日志的批量发送

配置文件支持存放在ETCD上，也支持存放在操作系统的文件系统里