【原创】Cassandrapython基本操…，cassandra

【原创】Cassandrapython基本操…，cassandra

python操作cassandra数据库。 首先安装python cassandra 库：easy_install cassandra_driver python中用法如下： >>> from cassandra.cluster import Cluster >>> cluster = Cluster(['127.0.0.1']) >>> session = cluster.connect() >>> session.execute("create KEYSPACE test_cassandra WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 2};") >>> session.execute("use test_cassandra") >>> session.execute("create table users(id int, name text, primary key(id));") >>> session.execute("insert into users(id, name) values(1, 'I loving fish!');") >>> session.execute("insert into users(id, name) values(2, 'Zhang zhipeng');") >>> >>> session = cluster.connect("test_cassandra") >>> rows = session.execute("select * from users;") >>> type(rows) >>> rows [Row(id=1, name=u'I loving fish!'), Row(id=2, name=u'Zhang zhipeng')] >>> row = rows[0] >>> row.id 1 >>> print row.name I loving fish! >>> row.count(1) 1 >>> row.count('I loving fish!') 1 >>> row.count('I loving fish??') 0 >>> cluster.is_shutdown False >>> cluster.shutdown() >>> cluster.is_shutdown True >>> rows = session.execute("select * from users;") Traceback (most recent call last):   File "", line 1, in   File "build\bdist.win-amd64\egg\cassandra\cluster.py", line 1341, in execute   File "build\bdist.win-amd64\egg\cassandra\cluster.py", line 2856, in result cassandra.cluster.NoHostAvailable: ('Unable to complete the operation against any hosts', {: ConnectionException('Pool is shutdown' ,)}) >>>