问题标签 [gocql]

在 Cassandra 中插入数据时出现以下错误。我正在gocql为 Cassandra 使用客户端。

{“错误”：“gocql：连接上的查询超时太多”，“状态”：500}

{“错误”：“gocql：在超时时间内没有收到来自cassandra的响应”，“状态”：500}

{"error":"write tcp 172.23.15.226:36954-\u003e172.23.16.15:9042: 使用关闭的网络连接","status":500}

有人可以帮我吗？

我想使用 gocql 客户端创建一个通用函数来执行 cassandra 查询，例如：

}

但是当我将多个参数值传递给它时，它给了我以下错误：

我正在使用这个gocql包。

我试图让这个例子工作。

使用 Cassandra shell，我创建了键空间“example”和表“tweet”，它们都可以正常工作。

但是，当我运行程序时，它给了我这个错误：

由于某种原因，gocql 无法拨打 localhost 连接，并且超时。我不确定如何解决这个问题，到目前为止，stackoverflow 和谷歌搜索还没有帮助。

有任何想法吗？

有时在运行命令时会显示超时 ( gocql: no response received from cassandra within timeout period)，例如：

它显示不一致的输出：

如何使其保持一致？我需要确定命令是否成功完成。或者我应该DROP TABLE/CREATE TABLE手动循环命令吗？

所以我想在我的本地机器上测试一个与 Cassandra 交互的 API。在我的func TestMain(m *testing.M)函数中，我想在运行测试之前清除表格。TestMain函数看起来像这样......

ClearAllTables函数看起来像这样......

出于某种原因，当我尝试 TRUNCATE 表时，Cassandra 超时，我收到错误消息......

这似乎只在我测试程序时发生。我在 main 函数中写了一段代码，效果很好。

我还编写了一段代码，它从数据库中返回一些行，并且在主函数中也可以正常工作。

这是我创建我的 cassandra 会话的方式...

我错过了任何东西，为什么 Cassandra 可以正常工作go run main.go但不能正常工作go test？

使用 GOCQL（Golang、Cassandra），我最多发出 128 个请求，然后一切都挂起。我相信 getTicksForCassandraKey() 函数我正确地发布了查询，但不确定。GOCQL 最多只支持 128 个并发查询，所以我一定是做错了什么。所有查询都是读取。

主要代码是：

getTicksForCassandraKey 的代码是：

如何使用 gocql 驱动程序将字节切片存储为 cassandra blob 类型？

我正在为我的 cassandra 连接使用 DCAwareRoundRobinPolicy。但是我的驱动程序查询所花费的时间比我在 php.ini 中使用相同的连接参数时要长。

php 中的 datastax 驱动使用的函数是一样的：

当最后一个参数设置为 false 时，仅使用本地主机进行查询。但是gocql驱动中没有这个参数设置。我猜这可能导致我面临的问题。如果我错了，请纠正我。

请帮助在这方面可以做些什么。

当集群中只有 1 个节点时，我没有遇到这个问题。

对于节点工具状态：

数据中心：DC1

数据中心：DC3

我正在开发一个带有聚类列的时间序列数据模型，即

我希望对分区列“id”和聚类列“时间”执行选择。例如，id:='1'，timestamp:='2017-10-09'

在 iterable.Close() 上检查 err 后，发现编组错误

{“错误”：[“无法将字符串编组到时间戳”]}

我该如何解决这个问题？

在用于特定查询的 Cassandra 数据库中，我有 8 条记录，并且我正在使用 GoLang relops/cqlc库。

当我使用 limit = 8 进行查询时，它返回 8 条记录，其 PageState 将用作下一组结果的页面标记。我认为它不应该返回那个 PageState。并且正如预期的那样，当我使用该 page_token 和相同的查询参数再次查询时，它不返回任何数据。

如果我将限制再增加一，例如 9，同样的事情不会发生。

其他人是否遇到过类似的问题？关于可能是什么问题的任何提示？