我正在开发一个带有聚类列的时间序列数据模型,即
CREATE TABLE events (
id text,
time timestamp,
type text,
val double,
PRIMARY KEY (id, time)
) WITH CLUSTERING ORDER BY (time DESC)
我希望对分区列“id”和聚类列“时间”执行选择。例如,id:='1',timestamp:='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 后,发现编组错误
{“错误”:[“无法将字符串编组到时间戳”]}
我该如何解决这个问题?