Hi all,
I'm new to heka. Before this i use logstash shipper for logstream.
My logstash shipper conf
input {
file {
type => "access-log"
path => [ "/usr/local/share/megamherk/logs/*/*" ]
}
}
filter {
grok {
type => "access-log"
match => [ "@source_path", "(//usr/local/share/megamherk/logs/)(?
<source_key>.+)(//*)" ]
}
}
output {
stdout { debug => true debug_format => "json"}
redis {
key => '%{source_key}'
type => "access-log"
data_type => "channel"
host => "redis.myhost.co"
}
}
Like the above conf i'd like to do the same in heka. can anyone help me?
My hekad.toml file
[accesslog]
type = "LogstreamerInput"
log_directory = "/usr/local/share/megamherk/logs"
file_match = '(?P<DomainName>[^/]+)/access\.log\.?(?P<Seq>\d*)'
[AMQPOutput]
url = "amqp://guest:guest@localhost/"
exchange = DomainName
exchangeType = "fanout"
message_matcher = 'TRUE'
_______________________________________________
Heka mailing list
[email protected]
https://mail.mozilla.org/listinfo/heka
