Return-Path: Delivered-To: apmail-avro-user-archive@www.apache.org Received: (qmail 58575 invoked from network); 27 Jan 2011 14:27:59 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 27 Jan 2011 14:27:59 -0000 Received: (qmail 81222 invoked by uid 500); 27 Jan 2011 14:27:59 -0000 Delivered-To: apmail-avro-user-archive@avro.apache.org Received: (qmail 79571 invoked by uid 500); 27 Jan 2011 14:27:56 -0000 Mailing-List: contact user-help@avro.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@avro.apache.org Delivered-To: mailing list user@avro.apache.org Received: (qmail 78750 invoked by uid 99); 27 Jan 2011 14:27:55 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Jan 2011 14:27:55 +0000 X-ASF-Spam-Status: No, hits=0.7 required=10.0 tests=SPF_NEUTRAL X-Spam-Check-By: apache.org Received-SPF: neutral (athena.apache.org: local policy) Received: from [64.78.22.16] (HELO EXHUB017-1.exch017.msoutlookonline.net) (64.78.22.16) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Jan 2011 14:27:50 +0000 Received: from EXVMBX017-1.exch017.msoutlookonline.net ([64.78.22.47]) by EXHUB017-1.exch017.msoutlookonline.net ([64.78.22.16]) with mapi; Thu, 27 Jan 2011 06:27:29 -0800 From: Anand Padmanaban To: "user@avro.apache.org" Date: Thu, 27 Jan 2011 06:27:33 -0800 Subject: RE: writing to socket in python Thread-Topic: writing to socket in python Thread-Index: Acu91FpzL+W7ateSQS+5ctBjWiuZXAAWNtag Message-ID: <79A1E64A36D5D64A86E9A06BC82806800197E46310@EXVMBX017-1.exch017.msoutlookonline.net> References: <79A1E64A36D5D64A86E9A06BC82806800197E461F8@EXVMBX017-1.exch017.msoutlookonline.net> <20110127034255.GF5888@kiwi.local> In-Reply-To: <20110127034255.GF5888@kiwi.local> Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: acceptlanguage: en-US Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 That wouldn't work for me. The avroSource that flume will be listening on = does not take http. Thanks, Anand. > -----Original Message----- > From: R. Tyler Croy [mailto:tyler@monkeypox.org] > Sent: Wednesday, January 26, 2011 7:43 PM > To: user@avro.apache.org > Subject: Re: writing to socket in python >=20 >=20 > On Wed, 26 Jan 2011, Anand Padmanaban wrote: >=20 > > Writing avro to a file is easy in python, just use avro.datafile.DataFi= leWriter. Is there an equivalent to write over the wire? > Specifically flume will be listening on the other end. >=20 > IIRC DataFileWriter won't work over a socket because it needs .seek(). >=20 > You should look into Avro RPC support with Python, which uses HTTP as a > transport, for writing messages over a wire. >=20 > I've got some code on doing so with eventlet here: > >=20 >=20 > - R. Tyler Croy > -------------------------------------- > Code: http://github.com/rtyler > Chatter: http://twitter.com/agentdero > http://identi.ca/dero