Python操作cassandra，pythoncassandra

安装：

[python] view plain copy

1. pip install pycassa  

创建一个可操作CF的连接:

[python] view plain copy

1. import pycassa  
2.   
3.     pool = pycassa.ConnectionPool(keyspace=ks_name, server_list=server_list, prefill=False)  
4.     cf = pycassa.ColumnFamily(pool, cf_name)  

几个核心的方法:

[python] view plain copy

1. cf.insert('rowkey', {'column1': 'val'})  
2. cf.get('rowkey')  
3.   
4. cf.multiget(['key1', 'key2']) #查询多个rowkey  
5.   
6. cf.remove('key')  
7. cf.remove('key', columns=['column1'])  
8.   
9. rows={'key1':{'column1': 'val'},'key2':{'column1': 'val2'},'key3':{'column1': 'val3'}}  
10. cf.batch_insert(rows)  

cassandra 的cql 是用类似sql的语句来操作 cassandra python也提供了 cql的客户端~  http://code.google.com/a/apache-extras.org/p/cassandra-dbapi2/

源码包下载地址：

http://code.google.com/a/apache-extras.org/p/cassandra-dbapi2/downloads/list

[python] view plain copy

1. import cql  
2. connection = cql.connect(host, port, keyspace)  
3. cursor = connection.cursor()  
4. cursor.execute("CQL QUERY", dict(kw='Foo', kw2='Bar', etc...))  
5. for row in cursor:  # Iteration is equivalent to lots of fetchone() calls  
6.     doRowMagic(row)  
7.   
8. cursor.close()  
9. connection.close()  

cql 的详细用法

http://www.datastax.com/docs/1.1/references/cql/index