我正在开发一个带有聚类列的时间序列数据模型,即
CREATE TABLE events (
id text,
time timestamp,
type text,
val double,
PRIMARY KEY (id, time)
) WITH CLUSTERING ORDER BY (time DESC)
我希望对分区列“id”和集群列“time”执行选择。例如id:='1',时间戳:='2017-10-09'
query := "SELECT id, time, type, val FROM events WHERE id=? AND time>=?"
iterable := Cassandra.Session.Query(query, id, timestamp).Consistency(gocql.One).Iter()
for iterable.MapScan(m) {
found = true
event = Event{
ID: m["id"].(string),
Time: m["time"].(time.Time),
Type: m["type"].(string),
Val: m["val"].(float64),
}
}
检查 iterable.Close() 上的 err 后,发现编组错误
{“错误”:[“无法将字符串编组到时间戳中”]}
我该如何解决这个问题?