0

我目前正在使用具有 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);
    });
};
4

0 回答 0