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

Reply via email to