卡桑德拉（Cassandra）阅读表现的位置

Question

我有一个Cassandra簇，有6个节点，每个节点有96个CPU/800 RAM。

我的性能测试表是：

create table if not exists space.table
(
    id          bigint primary key,
    data        frozen<list<float>>,
    updated_at  timestamp
);

表包含150.000.000行。

当我使用查询测试时：

SELECT * FROM space.table WHERE id = X

我什至无法超载群集，客户端本身被超载，RPS到群集为350.000。

现在，我正在测试第二个测试用例：

SELECT * FROM space.table WHERE id in (X1, X2 ... X3000)

我想根据请求从Cassandra中获取3000行。

在这种情况下，Max RPP 15 RPS 之后，在Cassandra线程池中发生了许多待处理任务，其中包括： native-transport-requests 。 从Cassandra获得大结果集不是最好的主意吗？最好的做法是什么，可以肯定的是，我可以将3000行分开以分开请求，例如30个请求每个请求，每个请求100个ID。 我在哪里可以找到有关它的信息，也许从性能的角度来看，运营不好？

更新：

想分享我的测量结果，以从卡桑德拉（Cassandra）乘以不同的块大小来获得3000行的测量值：

 每个请求使用3000 ID测试

延迟：5秒
Max RPS到Cassandra：20


每个请求使用100个ID测试（总计300个请求按100个IDS）
350 RPS服务的延迟（350 * 30 = 10500请求Cassandra）：170 ms（Q99），95 ms（Q90），75 ms（Q50）
Max RPS到Cassandra：350 * 30 = 10500

每个请求使用20个ID测试（总计150个请求按20个IDS） 
服务的延迟250 RPS服务（250 * 150 = 37500请求Cassandra）：49 MS（Q99），46 MS（Q90），32 MS（Q50）
服务的延迟在600 RPS服务（600 * 150 = 90000请求Cassandra）：190 ms（Q99），180 ms（Q90），148 ms（Q50）
Max RPS到Cassandra：650 * 150 = 97500


每个请求使用10个ID测试（总计300个请求通过10个IDS）
服务延迟250 RPS服务（250 * 300 = 75000请求Cassandra）：48 ms（Q99），31 ms（Q90），11 ms（Q50）
服务的延迟为600 RPS服务（600 * 300 = 180000向Cassandra请求）：159 MS（Q99），95 ms（Q90），75 ms（Q50）
Max RPS到Cassandra：650 * 300 = 195000


每个请求使用5个ID测试（总计600个请求通过5个IDS）
550 RPS的延迟服务（550 * 600 = 330000请求Cassandra）：97 MS（Q99），92 MS（Q90），60 ms（Q50）
Max RPS到Cassandra：550 * 660 = 363000


每个请求使用1个ID测试（总计3000个请求通过1个IDS）
服务的延迟为190 RPS服务（250 * 3000 = 750000请求Cassandra）：49 ms（Q99），43 MS（Q90），30 ms（Q50）
Max RPP到Cassandra：190 * 3000 = 570000
 

Answer 1

中的实际上不建议使用，尤其是对于许多单个分区键。问题在于，当您在中发送：

1. 查询发送到任何节点（协调器节点）时，没有必要的节点，该节点是拥有数据的
2. ，则该节点note coordinator节点标识哪些节点正在为特定分区拥有数据键
3. 查询将发送到确定的节点
4. 协调器节点收集所有节点
5. 结果的结果，并将其发送回来，

这将大量负载放在协调器节点上，并使整个查询的速度与群集中最慢的节点一样慢。

更好的解决方案是使用准备好的查询并为每个分区键发送单独的异步请求，然后在您的应用程序中收集数据。只要考虑到每个连接可能有多少机架查询是有限制的。

PS应该可以通过查看您的值，查找不同的分区键是否在同一令牌范围内，在查询同一令牌范围内的所有键中生成younk offion ps，可以进一步优化。该查询明确设置路由密钥。但这需要更高级的编码。