Cassandra Demo--Python操作cassandra，,==========

Cassandra Demo--Python操作cassandra，,==========

================================================================

创建keyspace和table

CREATE KEYSPACE exps  WITH REPLICATION = { ‘class‘ : ‘NetworkTopologyStrategy‘, ‘DC1‘ : 2 };create table exps_user(user_id int primary key,user_name varchar,user_info text);create index idx_user_name on exps_user(user_name);

================================================================

需要安装python依赖包cassandra-driver：

from cassandra.cluster import Clusterfrom cassandra.policies import DCAwareRoundRobinPolicyfrom cassandra import ConsistencyLevelcluster_instances = [‘192.168.199.171‘, ‘192.168.199.172‘, ‘192.168.199.173‘]cluster = Cluster(    cluster_instances,    load_balancing_policy=DCAwareRoundRobinPolicy(local_dc=‘DC1‘),    port=9042)session = cluster.connect("exps")for user_id in range(1, 50000):    try:        sql_script = ("insert into exps_user(user_id,user_name,user_info)"                      "VALUES({0},‘U{0}‘,‘THIS IS TEST‘);").format(user_id)        user_lookup_stmt = session.prepare(sql_script)        user_lookup_stmt.consistency_level = ConsistencyLevel.LOCAL_ONE        user1 = session.execute(user_lookup_stmt, [])    except Exception as ex:        print(str(ex))

Cassandra Demo--Python操作cassandra