Cassandra :如何在单个客户端请求中发送多个读/写请求？

Question

我正在处理一个应用程序，其中我需要向cassandra服务器发送多个请求。单个请求是一种写/读请求，执行间隔很短。我观察到往返时间的一个主要瓶颈。

我是否可以像Redis中的流水线一样，将请求流水线传输到cassandra以避免RTT。

Answer 1

如果您使用的是Cassandra1.2或更高版本，则可以使用BATCH来包装多个INSERT / UPDATE语句。

例如：

BEGIN BATCH
  INSERT INTO users (userid, password, name)
      VALUES ('user2', 'ch@ngem3b', 'second user');
  UPDATE users SET password = 'ps22dhds' WHERE userid = 'user3';
  INSERT INTO users (userid, password) VALUES ('user4', 'ch@ngem3c');
  DELETE name FROM users WHERE userid = 'user1';
APPLY BATCH;

See CQL3 Batch documentation。