cassandra

0热度

1回答

我的问题是如何使用数据库表中的新条目更新缓存？我的缓存有我的卡桑德拉表数据假设直到下午3点。直到那时用户已购买3件商品，所以我的缓存中有3件商品与该用户相关联。但过了某段时间（比如说30分钟）如果用户再购买2件商品怎么办？由于我有3条缓存它不会从数据库中查询，如何在计算最终法案时得到这两个新条目。我有一个选择是每15分钟致电cache.loadCache(null, null)？但有些地

0热度

1回答

如何以15位精度存储/显示时间戳和双列？

我想插入实验数据到卡桑德拉，其中每个数据的精度为15位小数。的样本数据集如下： +------------------+-------------------+ | Sampling_Rate | Value1 | +------------------+-------------------+ | 2.48979187011719 | 0.144110783934593 | +---

0热度

1回答

烧瓶post-fork连接到cassandra

我正在开发烧瓶微服务以暴露cassandra数据库中的一些数据。从命令行调用gunicorn。问题在于，我对于在何处以及如何连接数据库感到困惑，尤其是在进行单元测试时考虑如何模拟或绕过数据库的需求。我第一次尝试是在创建应用程序时连接如下 def create_app(): app = Flask(__name__) app.debug = True cluste

0热度

2回答

如何从流卡夫卡到卡桑德拉和增量计数器

我有Apache的访问日志文件，我想每个页面的存储访问数（总/每天/每小时）在卡桑德拉表。我试图通过使用连接卡夫卡从日志文件流的卡夫卡话题做。为了增加Cassandra中的度量指标，我可以再次使用Kafka Connect吗？否则，这里应该使用哪种其他工具，例如kafka流，火花，flink，kafka连接等？

0热度

1回答

如何使用Nifi将Google Analytics数据提取到cassandra？

我想使用Nifi将我的网站的谷歌分析数据提取到cassandra中，有什么办法吗？

1热度

3回答

我们能否在现有的集群更高的复制因子

在卡桑德拉，以更高的复制因子相同的集群中添加新的数据中心将引发错误添加新的数据中心说，一些范围内复制因子1是不以任何来源的数据中心中。我有数据中心与（X- RF = 2），和（Y -RF = 1）。我想添加Datacenter（Z - RF = 3）。我已经添加在数据中心Z上的节点。但在 nodetool重建 - X 它有一个错误 java.lang.IllegalStateExceptio

0热度

1回答

如何使用Gremlin配置Cassandra db进行远程连接？不工作

我在节点Js中使用Cassandra DB，DSE图形，gremlin查询。我能够获得价值并访问本地主机上的数据库。每当我尝试连接到远程服务器（例如http://remoteservercassandra.in）都无法连接。我如何连接到远程服务器？我的代码是 var dse = require('dse-driver'); var client = new dse.Client({

0热度

2回答

数据存储在卡珊德拉

的便捷的方式我是新来卡桑德拉，我想知道的东西我希望存储某些类型的大数据的卡桑德拉（布尔，文字，双击等）。我想知道我应该如何将所有这些数据存储在Cassandra中，一个键空间中的所有指定的数据类型表或一个键空间中的一个数据类型表中？例如Some_Keyspace（boolean_table，text_table ...）或Boolean_Keyspace（boolean_table），Tex

0热度

1回答

Cassandra JDBC INSERT不能始终工作

我已经对cassandra集群执行了1000次插入。但似乎只有5行在表中。这怎么可能？我知道有一种兑现机制，cassandra不会发布插入内容。但我怎么能完成插入 for (int i = 0; i < 1000; i ++) { try { String testIns = "INSERT INTO keyspace.testtable (var1, v

1热度

1回答

Cassandra：Geo冗余性和一致性

考虑在两个数据中心之间部署Cassandra实例以实现地理冗余。是否可以将此群集配置为具有一致性级别，以便我们同时获得地理冗余（即使整个数据中心中的一个宕机并且该实例继续与一个数据中心一起运行也是可用的）并且完全一致读和写。这是否违反CAP定理？