如何在cassandra python中传递参数中的表名

当您使用 %s placeholder,那么查询还没有准备好,Cassandra每次解析查询都会得到额外的开销。如果使用类似这样的方法,最好避免这种情况发生——定义一个将保存准备好的查询的映射,并在代码中使用将准备不在此缓存中的查询的函数。代码如下(未测试):

queries = {}
def get_query(session, stmt):
    global queries
    query = queries.get(stmt)
    if query is None:
       query = session.prepare(stmt)
       queries[stmt]=query
    return query

然后在代码中:

 stmt = "select  * from %s.%s where id =?".format(ks, table)
 query = get_query(stmt)
 session.execute(query, [params])

见 documentation 了解更多详细信息。