尽管没有看到任何错误,但尝试使该插入正常工作,并且只插入一条记录。如果我拼出字段,它通常会正常工作,但是用JSON文字来完成它要容易得多。
在stdin的循环中这样做:
batch = BatchStatement(consistency_level=ConsistencyLevel.QUORUM)
stmt = cassy_session.prepare("INSERT INTO social_objects JSON ?;")
batch.add(stmt, (json.dumps(so_record),))
stmt = cassy_session.prepare("INSERT INTO social_users JSON ?;")
batch.add(stmt, (json.dumps(user_record),))
cassy_session.execute(batch)也尝试过这样做:
cassy_session.execute(stmt, [json.dumps(user_record)])发布于 2015-11-19 17:06:56
我相信你看到的是卡桑德拉-10631,它会影响准备好的INSERT JSON语句。这一点应在Cassandra 2.2.4中加以修正。
https://stackoverflow.com/questions/33793255
复制相似问题