Not to hijack your thread or anything, but I just pushed to Github a lager 
backend for sending stuff to AMQP. You could have a subscriber in Java or 
whatever that fed those messages directly into HDFS and wouldn't have to worry 
about Thrift directly in the backend...

https://github.com/jbrisbin/lager_amqp_backend

Thanks!

Jon Brisbin
http//jbrisbin.com

----- Original Message -----

> From: "Bip Thelin" <bip.the...@evolope.se>
> To: riak-users@lists.basho.com
> Sent: Thursday, November 17, 2011 9:52:58 AM
> Subject: Lager and Scribe

> Hi,

> I've been thinking about using lager to push logs to our Big Data
> Hadoop backend for later analysis using Scribe. Looking at the
> lager_syslog backend it looks fairly simple to create such a
> backend. But thrift works kind of different and some implementation
> questions occur when going through the lager code.

> The way thrift works is that you create a connection:
> {ok, Client} = thrift_client_util:new()

> then you can use the Client to do subsequent calls like
> {Client2, _Result} = thrift_client:call(Client, ...)

> {Client3, _Result} = thrift_client:call(Client2, ...)
> [...]

> The problem is that you get a new Client descriptor every time and as
> I've understood it you shouldn't use the same Client twice but
> instead use the new one with each call. One could of course create a
> client and do the call within each handle_event() and pay that
> penalty hit but there must be a smarter way. I was going through the
> lager_file_backend and saw that you use a FD that get's passed
> around, is that a good approach to use something similar for a
> Scribe backend?

> --
> Bip Thelin

> Evolope AB | Lugnets Allé 1 | 120 33 Stockholm
> Tel 08-533 335 37 | Mob 0735-18 18 90
> www. evolope.se

> _______________________________________________
> riak-users mailing list
> riak-users@lists.basho.com
> http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com
_______________________________________________
riak-users mailing list
riak-users@lists.basho.com
http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com

Reply via email to