如何在应用程序端记录cassandra查询？

ca1c2owp 于 2021-06-14 发布在 Cassandra

关注(0)|答案(2)|浏览(346)

我在应用程序中使用gocql驱动程序。驱动程序是否有办法在控制台上记录查询？如何配置记录器以打印完整的查询（以及数据绑定）

package main
import (
    "fmt"
    "github.com/gocql/gocql"
)
var Session *gocql.Session
type Emp struct {
    id        string
    firstName string
    lastName  string
    age       int
}
func init() {
    var err error
    cluster := gocql.NewCluster("localhost")
    cluster.Keyspace = "cms"
    Session, err = cluster.CreateSession()
    if err != nil {
        panic(err)
    }
    fmt.Println("cassandra init done")
}
func main() {
    e := Emp{
        id:        "1",
        firstName: "John",
        lastName:  "DOe",
        age:       88,
    }
    createEmp(e)
}
func createEmp(emp Emp) {
    fmt.Println("****Creating new emp****\n", emp)
    if err := Session.Query("INSERT INTO emps(empid, first_name, last_name, age) VALUES(?, ?, ?, ?)",
        emp.id, emp.firstName, emp.lastName, emp.age).Exec(); err != nil {
        fmt.Println("Error while inserting Emp")
        fmt.Println(err)
    }
}

cassandra go gocql

来源：https://stackoverflow.com/questions/58075690/how-log-cassandra-queries-on-application-side

2条答案

按热度按时间

jc3wubiy1#

go驱动程序有一个queryobserver，您可以实现它来执行时间查询：https://github.com/gocql/gocql/blob/master/session.go#l1891-1926年
它将由您检查执行时间是否超过阈值，然后根据需要打印，但它似乎让您可以访问语句对象、主机和计时，这是调试所需的全部内容。
下面是一些示例代码，显示了queryobserver在为推测性执行的影响计时的上下文中的操作：https://github.com/instaclustr/sample-gocql-speculative-execution/blob/master/spectest.go
以上示例来自以下关于推测执行的博客文章：https://www.instaclustr.com/speculative-query-executions-gocql/
（如果存在尾部延迟问题，可能应该考虑使用客户端推测执行，但这是另一个主题：）
此外，树中还有一个使用queryobserver进行验证的测试用例：https://github.com/gocql/gocql/blob/16cf9ea1b3e28090d416d36528f304e4553e6b56/cassandra_test.go#l140
可能是一个好地方开始玩它。

赞(0）回复(0）举报 2021-06-14

bf1o4zei2#

这就是我们在java中的实现方式。我们定义了一个定制的latencytracker：

private LatencyTracker getLatencyTracker() {
    return new LatencyTracker() {
        @Override
        public void update(Host host, Statement statement, Exception e, long l) {
            LOGGER.info(statement.toString());
        }
        @Override
        public void onRegister(Cluster cluster1) {
        }
        @Override
        public void onUnregister(Cluster cluster1) {
        }
    };
}

然后在群集中注册：

cluster.register(getLatencyTracker());

展开查看全部

赞(0）回复(0）举报 2021-06-14

我来回答

如何在应用程序端记录cassandra查询？

2条答案

相关问题

热门标签

最新问答