1

你好堆栈溢出社区!

我需要一些帮助来找出在 nodejs 中使用 express cassandra orm 模型为我的多 dc(总 dc =2)cassandra 设置建立连接的正确方法。

我们目前仅使用 1 个 dc 和 express cassandra,因此我们只需提供 2 个种子节点 IP 地址作为 express cassandra 的联系点,如下所示

models.setDirectory(__dirname + '/models').bind(
  {
    clientOptions: {
      contactPoints: cassandraContactPoints,
      protocolOptions: { port: 9042 },
      keyspace: 'keyspace_name',
      queryOptions: { consistency: models.consistencies.one }
    },
    ormOptions: {
      defaultReplicationStrategy: {
        class: 'NetworkTopologyStrategy',
        replication_factor: 2,
      },
      createKeyspace: false,  
      dropTableOnSchemaChange: false
    }
  },
  function (err) {
    if (err) {
      throw err;
    } else {
      console.log('connection established');
      postDBConnection(models, 'keyspace name again');
    }
  }

这里要注意的是,我们将 cassandraContactPoints 指定为仅包含现有 dc 的 2 个节点的数组。

由于我们正在使用单独的 DC 进行分析,我想知道我们是否应该在同一个数组中提供新 DC 的 IP 地址,即 cassandraContactPoints ?我们计划使用 LOCAL_QUORAM 并希望我们的分析应用程序仅使用分析 dc 进行所有读取和写入。

我已尝试阅读 express cassandra 和“cassandra 驱动程序”模块的源代码,但我无法找出解决方案>

这里的任何帮助将不胜感激!

4

1 回答 1

2

从另一个 DC 提供联系点绝不是一个好主意- 大多数驱动程序(不记得有关 Node.js 驱动程序)正在执行联系点的洗牌,因此它可能首先联系另一个 DC 中的节点,并提取 DC 名称从该节点的信息中,会认为该 DC 是应用程序本地的,因此 LOCAL_QUORUM 查询将针对分析 DC 执行,这将导致问题。

如果您为您的应用程序显式设置本地 DC 名称,而不是从接触点隐式检测它,您可以使您的代码更加防弹。详见驱动文档(4.0版本,开发者必须指定本地DC的名称!)

于 2019-03-30T12:44:50.103 回答