我目前正在学习 apache cassandra 和 im nosql 数据建模的新手。目前,我正在尝试构建一个具有以下字段的系统:
latitude | time_forecast | longitude | forecast_request | rh | swflx | temp
----------+---------------------+------------+------------------+--------------------+--------------------+--------------------
41.45 | 2016-04-26 17:00:00 | -8.6166667 | 2016-04-26_0000 | 0.6161368489265442 | 397.4789733886719 | 290.44512939453125
41.45 | 2016-04-26 18:00:00 | -8.6166667 | 2016-04-26_0000 | 0.673031210899353 | 261.1000061035156 | 289.3315734863281
41.45 | 2016-04-26 19:00:00 | -8.6166667 | 2016-04-26_0000 | 0.8489508032798767 | 27.700000762939453 | 286.8634948730469
41.25 | 2016-04-26 17:00:00 | -8.6166667 | 2016-04-26_0000 | 0.6555368900299072 | 395.1789855957031 | 289.8011169433594
41.25 | 2016-04-26 18:00:00 | -8.6166667 | 2016-04-26_0000 | 0.7271312475204468 | 203.39999389648438 | 288.5975646972656
41.25 | 2016-04-26 19:00:00 | -8.6166667 | 2016-04-26_0000 | 0.8572507500648499 | 30.989999771118164 | 286.7254943847656
41.456 | 2016-04-26 17:00:00 | -8.6166667 | 2016-04-26_0000 | 0.6161368489265442 | 397.4789733886719 | 290.44512939453125
41.456 | 2016-04-26 18:00:00 | -8.6166667 | 2016-04-26_0000 | 0.673031210899353 | 261.1000061035156 | 289.3315734863281
41.456 | 2016-04-26 19:00:00 | -8.6166667 | 2016-04-26_0000 | 0.8489508032798767 | 27.700000762939453 | 286.8634948730469
这是我创建表的方式:
create table if not exists forecast
(
latitude varchar,
longitude varchar,
time_forecast varchar,
forecast_request varchar,
swflx varchar,
temp varchar,
rh varchar,
PRIMARY KEY(latitude, time_forecast, longitude)
)
WITH CLUSTERING ORDER BY (time_forecast ASC);
使用这个模型,time_forecast
不能成为我的主键,因为它不是唯一的。
这是我可以在不制作更新插入的情况下插入数据的唯一方法,但是我现在面临的问题是我不能仅通过time_forecast
查询数据库。
在此示例中,对于每个坐标(纬度和经度),我都会对接下来的 3 小时进行预测,并且我无法避免使用复合键。
您将如何以仅从time_forecast
值范围内检索坐标和变量的方式对数据库进行建模?
您将如何以仅从time_forecast值范围内检索坐标和变量的方式对数据库进行建模?
create table if not exists forecast
(
location text,
latitude varchar,
longitude varchar,
time_forecast varchar,
forecast_request varchar,
swflx varchar,
temp varchar,
rh varchar,
PRIMARY KEY((location), time_forecast)
) WITH CLUSTERING ORDER BY (time_forecast ASC);
然后,您可以按time_forecast范围进行查询:
SELECT * FROM forecast
WHERE location = 'California'
AND time_forecast >= 'xxx'
AND time_forecast <= 'yyy';