“中止”读取 cassandra 结果

Question

我有一个 cql，我需要使用 node.js driver 执行和流式传输结果。但是，如果满足某个条件，我需要中止流式传输。

类似这样的：

                client.eachRow(cql, [], {
                    autoPage: true
                }, function(n, row) {
                    if(applySomeFilterLogic(row) === 'some val') {
                        //abort streaming
                    } else {
                        rows.push(row);
                    }
                }, function(err, result) {
                    logger.error("server responded with error : %s", err);
                });

数据无法通过过滤逻辑进行预处理并保存在 cassandra 中。它需要在运行时根据数据持久化时未知的许多标准进行计算。

一般来说，有没有办法通过 node.js 驱动程序或 cassandra 优雅地实现这一点？

Answer 1

您应该改用manual paging：

const options = { prepare : true };
client.eachRow(query, parameters, options, function (n, row) { 
     // Invoked per each row in all the pages
  }, function (err, result) {
     // Called once the page has been fully retrieved.
     if (yourCondition && result.nextPage) {
       // Retrieve the following pages based on your condition:
       // the same row handler from above will be used
       result.nextPage();
     }
  }
);

您可以阅读有关驱动程序文档的更多信息：http://datastax.github.io/nodejs-driver/features/paging/