cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Apache Wiki <wikidi...@apache.org>
Subject [Cassandra Wiki] Update of "ClientExamples" by Chris Goffinet
Date Thu, 27 Aug 2009 01:09:36 GMT
Dear Wiki user,

You have subscribed to a wiki page or wiki category on "Cassandra Wiki" for change notification.

The following page has been changed by Chris Goffinet:
http://wiki.apache.org/cassandra/ClientExamples

------------------------------------------------------------------------------
  }
  }}}
  
+ == Java ==
+ {{{
+ #!/usr/bin/env python
+ # encoding: utf-8
+ """
+ Sample Cassandra Client
+ 
+ Created by Chris Goffinet on 2009-08-26.
+ """
+ from thrift import Thrift
+ from thrift.transport import TTransport
+ from thrift.transport import TSocket
+ from thrift.protocol import TBinaryProtocol
+ from cassandra import Cassandra
+ from cassandra.ttypes import *
+ import time, pprint
+ 
+ def main():
+     socket = TSocket.TSocket("localhost", 9160)
+     transport = TTransport.TBufferedTransport(socket)
+     protocol = TBinaryProtocol.TBinaryProtocol(transport)
+     client = Cassandra.Client(protocol)
+     pp = pprint.PrettyPrinter(indent = 2)
+ 
+     keyspace = "Keyspace1"
+     column_path = ColumnPath(column_family="Standard1",column="email")
+     key = "1"
+     value = "foobar@example.com"
+     timestamp = time.time()
+     
+     try:
+         transport.open()
+         """ Insert the data into Keyspace 1 """
+         client.insert(keyspace, key, column_path, value, timestamp, ConsistencyLevel.ZERO);
+         
+         """" Query for data """
+         column_parent = ColumnParent(column_family="Standard1")
+         slice_range = SliceRange(start="", finish="")
+         predicate = SlicePredicate(slice_range=slice_range)
+         
+         result = client.get_slice(keyspace, key, column_parent, predicate, ConsistencyLevel.ONE);
+         pp.pprint(result)
+ 
+     except Thrift.TException, tx:
+         print 'Thrift: %s' % tx.message
+     finally:
+         transport.close()
+ 
+ if __name__ == '__main__':
+     main()
+ }}}
+ 

Mime
View raw message