You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by Apache Wiki <wi...@apache.org> on 2010/02/05 15:30:56 UTC
[Cassandra Wiki] Update of "ClientExamples" by BaptisteLepilleur
Dear Wiki user,
You have subscribed to a wiki page or wiki category on "Cassandra Wiki" for change notification.
The "ClientExamples" page has been changed by BaptisteLepilleur.
The comment on this change is: Fixed formatting of the python example.
http://wiki.apache.org/cassandra/ClientExamples?action=diff&rev1=47&rev2=48
--------------------------------------------------
`shell> thrift --gen rb:new_style cassandra.thrift`
+ {{{
- {{{#!/usr/bin/env ruby require './cassandra' require './cassandra_constants' require './cassandra_types' require 'pp'
+ #!/usr/bin/env ruby require './cassandra' require './cassandra_constants' require './cassandra_types' require 'pp'
transport = Thrift::BufferedTransport.new(Thrift::Socket.new("localhost", "9160")) transport.open
@@ -335, +336 @@
. puts "Key not found."
- end }}}
+ end
+ }}}
== Python ==
- {{{#!/usr/bin/env python # encoding: utf-8 """ Sample Cassandra Client
+ {{{
+ #!/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.TBinaryProtocol import TBinaryProtocolAccelerated from cassandra import Cassandra from cassandra.ttypes import * import time, pprint
+ 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.TBinaryProtocol
+ import TBinaryProtocolAccelerated from cassandra
+ import Cassandra from cassandra.ttypes
+ import * import time, pprint
def main():
-
- . socket = TSocket.TSocket("localhost", 9160) transport = TTransport.TBufferedTransport(socket) protocol = TBinaryProtocol.TBinaryProtocolAccelerated(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:
+ socket = TSocket.TSocket("localhost", 9160)
+ transport = TTransport.TBufferedTransport(socket)
+ protocol = TBinaryProtocol.TBinaryProtocolAccelerated(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()
- . transport.open() """ Insert the data into Keyspace 1 """
+ """ 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)
+ 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:
+ except Thrift.TException, tx:
- . print 'Thrift: %s' % tx.message
+ print 'Thrift: %s' % tx.message
- finally:
+ finally:
- . transport.close()
+ transport.close()
if __name__ == '__main__':
-
- . main()
+ main()
}}}