我目前正在使用具有 3 个节点集群和一个一致性的Cassandra 3.11 ,以及 NodeJS express cassandra client 2.3.0。我正在使用saveAsync方法来存储模型数据。但是我收到一个错误:apollo.model.save.dberror我无法验证导致此错误的原因。大多数记录都会发生这种情况,只有少数记录通过。我正在插入从 kafka 主题读取的数据,并在经过几次验证后将其推送到 cassandra。数据速率约为每秒 200 次。
尝试在堆栈溢出中进行谷歌搜索和搜索,但无法获取任何详细信息。示例代码。
SomeData.insert = function (data) {
data = transformData(data); // Basically cleans & normalizes the data to suit the model
let any_data = new ExpressCassandra.instance.data_store(data);
return any_data.saveAsync()
.catch(function(err){
return Promise.reject(err);
});
};