I'd like to help you, but you probably know considerably more about
Logstash configuration and how it works than I do. Plus, while there is
a great deal of similarity and overlap, Logstash and Heka approach
certain things a bit differently, and there isn't a 1:1 correspondence
with features.
It would be more useful for me if you could describe what you're hoping
to accomplish with the Heka config that you pasted below, and what,
exactly, isn't working like you want it to. Given that I can hopefully
help you debug.
Thanks!
-r
On 06/25/2014 06:17 AM, Thomas Alrin wrote:
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
_______________________________________________
Heka mailing list
[email protected]
https://mail.mozilla.org/listinfo/heka