Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- from cassandra.cluster import Cluster
- from cassandra import ConsistencyLevel
- from random import randint
- cluster = Cluster(['127.0.0.1'])
- session = cluster.connect("demo")
- user_lookup_stmt = session.prepare("SELECT * FROM t1 WHERE ise=?")
- user_lookup_stmt.consistency_level = ConsistencyLevel.ONE
- # these will both use QUORUM
- for i in range(1, 10):
- user = session.execute(user_lookup_stmt, ['user{}'.format(randint(1, 2))])[0]
- print "user ", user
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement