go - 在 Cassandra 中插入返回空指针错误

Question

如下使用Cassandra插入数据，我担心IntializeCassandra中初始化的东西不在了？

var csession gocql.Session 

func IntializeCassandra(){
    fmt.Println("Intializing Cassandra")
    cluster := gocql.NewCluster("10.0.0.60")
    cluster.Keyspace = "tickdata"
    cluster.Consistency = gocql.Quorum
    csession, _ := cluster.CreateSession()
    defer csession.Close()
}

func main() {
    IntializeCassandra()
}

稍后在函数回调中，当我尝试将数据插入 cassandra 时，出现空指针错误

func msgHandler(src *net.UDPAddr, n int, b []byte) {
    t := time.Now().UTC()
    tformat := t.Format("2006-01-02 15:04:05")
    md := &MarketData.MD{}
    proto.Unmarshal(b[:n], md)
    log.Printf("%d %d %d %d %s %.5f %.5f", md.Firm, md.Symbol, md.Expiry, md.Id, tformat, md.Bid, md.Ask)
    if err := csession.Query(`INSERT INTO timeseries (firm, symbol, expiry, quote_id, time, bid, ask) VALUES (?, ?, ?, ?, ?, ?, ?)`,
         md.Firm, md.Symbol, md.Expiry, md.Id, tformat, md.Bid, md.Ask).Exec(); err != nil {
         log.Fatal(err)
    }


panic: runtime error: invalid memory address or nil pointer dereference
[signal 0xb code=0x1 addr=0x0 pc=0x594687]

Answer 1

代码有两个问题: 你应该在这里检查错误。如果失败，则不要继续

csession, err := cluster.CreateSession()
if err != nil {
     log.Fatal(err)
}

您也不需要 defer session.Close() 或 session.Close() 因为它会使您的连接失效并关闭。在将 session 从 IntializeCassandra 返回到 main() 后，在 main 中写入 defer session.Close() 。此外，您应该有一个名为 Csession 的全局变量，它可以在任何地方使用