酷客网Cassandra是一套开源分布式NoSQL数据库系统。它最初由Facebook开发，用于储存收件箱等简单格式的数据，集GoogleBigTable的数据模型与Amazon Dynamo的完全分布式架构于一身。Facebook于2008将 Cassandra开源，此后，由于Cassandra良好的可扩展性，被Digg、Twitter等知名Web 2.0网站所采用，成为一种流行的分布式结构化数据存储方案。
在安装Cassandra数据库后，如果想在Python程序中使用Cassandra数据库，需要先通过如下命令安装Cluster模块。
pip install Cluster
如图所示：
然后通过如下命令安装cassandra-driver模块。
pip install cassandra-driver
如图所示：
下面的实例文件cassandra01.py演示了使用cassandra-driver连接Cassandra数据库并创建、插入数据的过程。
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)
print(rows)
row = rows[0]
print(row.id)
print(row.name)
print(row.count(1))
print(row.count('I loving fish!'))
print(row.count('I loving fish??'))
print(cluster.is_shutdown)
cluster.shutdown()
print(cluster.is_shutdown)
执行后会输出：
[Row(id=1, name=u'I loving fish!'), Row(id=2, name=u'Zhang zhipeng')]
1
[Row(id=1, name=u'I loving fish!'), Row(id=2, name=u'Zhang zhipeng')]
1
1
0
False
True
酷客网相关文章：
评论前必须登录！
注册