python cassandra 创建space table并写入和查询数据

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了python cassandra 创建space table并写入和查询数据相关的知识,希望对你有一定的参考价值。

 

from cassandra.cluster import Cluster

cluster = Cluster(["10.178.209.161"])
session = cluster.connect()
keyspacename = "demo_space"
session.execute("create keyspace %s with replication = {‘class‘: ‘SimpleStrategy‘, ‘replication_factor‘: 1};" % keyspacename)
# use keyspace; create a sample table
session.set_keyspace(keyspacename)

s = session
try:
    s.execute("CREATE TABLE blobbytes (a ascii PRIMARY KEY, b blob)")
except:
    pass
params = [key1, bytearray(bblob1)]
s.execute("INSERT INTO blobbytes (a, b) VALUES (%s, %s)", params)
results = s.execute("SELECT * FROM blobbytes")
print "********************"
for x in results:
    print x.a, x.b


try:
    s.execute("CREATE TABLE list_test (a ascii PRIMARY KEY, b list<blob>)")
except:
    pass
params = [some key here, [bytearray(bblob1), bytearray(bhello world)]]
s.execute("INSERT INTO list_test (a, b) VALUES (%s, %s)", params)
results = s.execute("SELECT * FROM list_test")
print "********************"
for x in results:
    print x.a, x.b

结果:

********************
key1 blob1
********************
some key here [blob1, hello world]

最后补充:

cassandra的update和mongo的upsert效果一样!如果where的条件不满足,则会insert into!

params2 = [[bytearray(bblob2), bytearray(bhello world2)], "other key"]
s.execute("UPDATE list_test set b = b + %s WHERE a = %s", params2)
# 会直接将other key的东西插入数据库!如果other key不存在的话!

见:http://stackoverflow.com/questions/17348558/does-an-update-become-an-implied-insert

以上是关于python cassandra 创建space table并写入和查询数据的主要内容,如果未能解决你的问题,请参考以下文章

如何从cassandra表值创建python字典?

使用 cassandra 的 python 驱动程序创建新记录时如何设置服务器端时间戳

Cassandra Demo--Python操作cassandra

Spark + cassandra:如何创建键空间?

TypeError:使用一组 UDT 创建 Cassandra Python 驱动程序模型时不可散列的类型 UserType

Cassandra 无法为新主机创建连接池