【原创】Cassandra python 基本操…

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' ,)})
>>>