Cassandra一致性-行集
Cassandra是一个高度可扩展的分布式数据库系统，它采用了分布式、去中心化的架构，具有高可用性和高性能的特点。一致性-行集（Consistency-Level）是Cassandra中用于控制数据一致性的概念。
一致性-行集定义了在分布式环境下，读写操作对数据一致性的要求程度。Cassandra提供了多个一致性级别供用户选择，以满足不同应用场景下的需求。
Cassandra的一致性级别包括：
- ONE：表示只需要在一个节点上进行读写操作即可，不需要等待其他节点的确认。这种级别下的读写操作延迟较低，但可能会导致数据不一致。
- QUORUM：表示需要在大多数节点上进行读写操作，确保数据的一致性。这种级别下的读写操作延迟较高，但可以提供更高的数据一致性。
- ALL：表示需要在所有节点上进行读写操作，确保数据的强一致性。这种级别下的读写操作延迟最高，但可以提供最高的数据一致性。
- LOCAL_ONE：表示只需要在本地数据中心的一个节点上进行读写操作即可，不需要等待其他数据中心的确认。这种级别适用于多数据中心的场景，可以提供较低的延迟和较高的一致性。
- LOCAL_QUORUM：表示需要在本地数据中心的大多数节点上进行读写操作，确保本地数据中心的数据一致性。
- EACH_QUORUM：表示需要在所有数据中心的大多数节点上进行读写操作，确保所有数据中心的数据一致性。
Cassandra的一致性-行集级别的选择需要根据应用场景的需求来确定。如果对数据一致性要求较低，可以选择较低的一致性级别以提高读写操作的性能；如果对数据一致性要求较高，可以选择较高的一致性级别以保证数据的一致性。
腾讯云提供了Cassandra数据库服务，名为TencentDB for Cassandra，它是基于Cassandra开源项目构建的云数据库服务，提供了高可用、高性能、高扩展性的分布式数据库解决方案。您可以通过以下链接了解更多关于TencentDB for Cassandra的信息：https://cloud.tencent.com/product/tcassandra
相关·内容
1回答
Cassandra集群密钥用法
、、、、
我对此很感兴趣，但坦率地说，我的大脑不会明白--至少看起来是这样。
我有一个专栏家庭，为相当多的演员提供工作。它是一个中央作业管理和调度表，必须分布在整个集群中并可用，甚至可能在不久的将来跨越数据中心的障碍。
每个作业执行器执行元系统，即实际执行作业的执行元系统，都安装在一个Cassandra节点旁边-即，在同一个节点上。实际上，当然有一位大师级的演员，他拉出作业，并将它们分发给演员代理，但这与我的问题无关。
还有一些参与者系统可以在中央作业表中创建作业，由其他参与者甚至参与者系统执行，但通常作业是通过web界面批量加载或手动加载的。
执行作业的执行元总是只查询它的本地cassandra节点。
浏览 1提问于2015-03-14得票数 2
1回答
根据卡桑德拉的原子性是：
在Cassandra中，写在分区级别是原子的，这意味着在行中插入或更新列被视为一个写操作。
而根据，卡桑德拉的原子性是：
在Cassandra中，写操作在分区级别是原子的，这意味着在同一个分区中插入或更新()两行或多行是作为一个写操作来处理的。
，我的困惑是，原子性是在单行基础上看到的，还是可以在分区级别包含表的多个行？。
根据我们在Cassandra中执行的查询类型，我猜想这两者的结合。
例如， :
如果我有一个insert查询，它总是在分区中插入一行。因此，Cassandra确保在分区级别成功插入该行。
但是，如果有update查询，其where子
浏览 0提问于2018-10-11得票数 2
回答已采纳
据我所知，cassandra表中的一行是一组键-值对(对应于每一列)
在insert期间，我注意到一个奇怪的问题，值不会持久保存在两个列中，尽管我相当确信它在insert之前就有值。
它偶尔会发生，如果我们稍后重试，它会成功。我们怀疑某些类型的竞争条件或db连接中断等。
有没有可能在cassandra表的一行中只保存关键字的一个子集？cassandra在保存期间是保证全部还是不保证(行级一致性)
Cassandra版本: 2.1.8
Datastax cassandra-驱动程序-核心: 3.1.0
浏览 12提问于2017-01-31得票数 2
回答已采纳
2回答
我有一个cassandra集群，它的行数相当少(大约200万行，我希望这对于cassandra来说是“小”的)。每一行都有一个惟一的UUID，每一行大约有200列(或多或少)。总而言之，这些都是非常小的行，没有二进制数据或大量的文本。只是一些短的字符串。
我刚刚完成了从旧数据库到cassandra集群的初始导入。我已经在每台机器上调好了cassandra的地狱。有数亿次写入，但没有读取。现在是时候使用这个东西了，我发现它的读取速度绝对令人沮丧。我正在使用pycassa做一个多目标，一次处理500到10000行。即使在500行的情况下，性能有时也很糟糕，只需要30+几秒钟。
什么会导致这种类型的
浏览 1提问于2011-04-22得票数 3
回答已采纳
1回答
卡桑德拉更新失败
、、
解决了I在3个节点上测试更新的问题，其中一个节点的时间落后1秒，所以当更新一行时，写入时间总是在时间戳之后，cassandra不会更新行。我同步所有节点的时间，并解决问题。
编辑：I双重检查结果，所有插入都成功，部分更新失败。没有错误/异常消息
我有一个cassandra集群(Cassandra 2.0.13)，它包含5个节点。使用python(2.6.6) cassandra driver(2.6.0c2)将数据插入数据库。我的服务器系统是Centos6.X
下面的代码是我如何连接cassandra并获取会话的。我提供了最多2个节点的ip地址，并选择密钥空间。
def get_cassand
浏览 3提问于2015-07-06得票数 2
回答已采纳
我更新了以下代码行以支持spring-data-cassandra-2.0.7.RELEASE：
CassandraOperations cOps = new CassandraTemplate(session);
发自：
Insert insertStatement = (Insert)statement;
CqlTemplate.addWriteOptions(insertStatement, queryWriteOptions);
cOps.execute(insertStatement);
至：
Insert insertStatement = (Insert)statement;
浏览 51提问于2018-06-14得票数 0
我有一个单一的数据节点cassandra版本3.11.2和一个cassandra c++驱动程序版本2.7。具有500 000行的单个数据节点集群。我读取异步数据，然后将数据推送到队列中，调度程序在队列中使用cassandra c++驱动程序编写异步数据。我有10个应用程序线程，10个io线程和10个调度线程。我有38000的TPS。
但是，我对“两个数据节点”cassandra集群所做的相同的活动都位于同一个Rack上，并且试图以一致的级别“2”进行读写。我的TPS降到12000。为什么我的性能下降如此之大，即使所有的配置和客户端二进制是相同的？只需将读一致性更改为2，将写入一致性更改为2。
浏览 0提问于2018-05-11得票数 0
回答已采纳
1回答
在我的cassandra用例中，写入之后是读取，我们观察到来自cassandra的陈旧读取。我知道在cassandra中很难实现读的一致性，但是什么是可选的，我们如何知道读是过时的？只要我知道读是过时的，写还在跟上，我就应该做得很好，我不能承受的是返回过时的数据。
寻找基于spring boot和spring data cassandra的解决方案
浏览 5提问于2021-10-03得票数 1
我正在使用火花-sql-2.4.1，火花-卡桑德拉-连接器_2.11-2.4.1与java8.
我正在执行下面的简单查询，以获得C*表行计数。
JavaSparkContext sc = new JavaSparkContext(spark.sparkContext());
long recCount = javaFunctions(sc).cassandraTable(keyspace, columnFamilyName).cassandraCount();
但是，它是通过以下错误超时的。
java.io.IOException: Exception during execution
浏览 0提问于2019-08-28得票数 0
当我查看关于batches ()的Cassandra文档时，我注意到了下面这句话：
When the rows in the batch have been successfully written and persisted (or hinted)
the batchlog data is removed.
这是否意味着，在批量更新的上下文中，向副本节点写入一行或在协调节点上写入提示切换对于Cassandra来说是相同的事情？
如果这是真的，当一个不可用节点活着返回时，在提示传递过程中出现延迟的情况下，这可能导致最终的一致性，即使批处理中的语句具有一致性ALL？
浏览 3提问于2014-12-25得票数 1
我正在编写一个连接到Microsoft Azure CosmosDB中的Cassandra数据库的Java应用程序。根据上的文档页面，cosmosdb有一个选项来设置读取操作的一致性级别。但是，在使用SQL API for cassandra时，我找不到如何做到这一点的示例。我在上扩展了微软提供的示例。该示例使用datastax驱动程序cassandra。
是否可以使用此驱动程序设置一致性级别？
浏览 4提问于2019-06-17得票数 0
我在卡桑德拉有一个只有2列16行的表。当我做一个
select * from <table name>
我只能看到15排。当我做一个
select count(*) from <table name>
如果我用cqlsh编写这些查询，就会有一行丢失，但是如果我执行了select * from where appname = '‘的操作，就会得到该行。
当我使用nodejs casandra驱动程序进行搜索时，我得到了正确的结果，即16。这里的问题是什么。我也做了nodetool刷新，但结果相同，我使用了cassandra 2.18
浏览 3提问于2015-10-16得票数 2
回答已采纳
我不确定是否使用Cassandra在nodejs中设置策略'DowngradingRetryPolicy‘。
policies : { loadBalancing : new cassandra.policies.loadBalancing.RoundRobinPolicy,
retry: new cassandra.policies.retry.IdempotenceAwareRetryPolicy(new cassandra.policies.retry.RetryPolicy()
浏览 5提问于2017-12-29得票数 1
回答已采纳
1回答
我使用dsbulk 1.6.0从cassandra 3.11.3卸载数据。
每次卸载都会导致行数大不相同。以下是三个卸载调用的结果，它们位于同一个集群上，连接到同一个cassandra主机。正在卸载的表只会追加，数据永远不会被删除，因此不应该出现卸载行的减少。集群中有3个cassandra数据库，复制因子为3，因此所有数据都应该显示在所选主机上。此外，这些都是快速执行的，增加的行数将是数百行(如果有的话)，而不是数万行。
运行1：
│总计\x{e76f}
│10,937 -7/ 97 -97- 15,935.46 - 20,937.97 - 20,937.97
│操作卸载20201024-0
浏览 2提问于2020-10-26得票数 1
回答已采纳
我们有一个运行在3个节点上的cassandra集群，复制因子为2 ->，也许我们应该从一开始就选择3，但事实并非如此。
因此，我们的法定人数是= 2/2 +1=2
假设我们失去了一个节点，所以现在只有两个cassandra节点在线。
如果我们将一致性级别设置为"ONE“，然后读取->，则仍然有可能从集群中读取，因此这不是问题。
我不明白的是以下几点。
我们仍然有两个节点在运行，那么为什么不能在密钥空间中执行串行(轻量级事务)插入呢？我们有两个节点，所以在尝试插入时不应该获得2的仲裁量吗？
是因为一行的一行已经放在缺失的节点上了吗？
浏览 5提问于2017-03-09得票数 4
回答已采纳
cassandra规范中的段落告诉我们，先读后写对cassandra性能有一点影响。但告诉我们，cassandra本身避免了先读后写的情况。
在我的例子中，我需要在它上面读取行"see“，并根据条件将其写回。那么总而言之，cassandra对于这些场景是不是合适的解决方案？
浏览 2提问于2015-08-06得票数 2
我正在所有三个节点上运行一个查询。其中一个查询的结果是显示10行，而相同的查询在另外两行上显示两行。
复制因子设置为3：
keyspace_name | durable_writes | replication
--------------------+----------------+-------------------------------------------------------------------------------------
table name | True | {'class': 'org.apache.
浏览 3提问于2019-09-30得票数 0
回答已采纳
2回答
我们的Cassandra集群在亚马逊EC2上运行，环中有4个节点。我们面临着数据不一致的问题。我们在使用"cqlsh“shell时更改了一致性级别2，解决了数据不一致的问题。
但是我们不知道“如何在Cassandra集群上设置一致性级别？”
浏览 0提问于2016-10-14得票数 0
3回答
我们正在运行DataStaxEnterprise4.0.1，当将行插入Cassandra，然后查询COUNT(1)时，会遇到一个非常奇怪的问题。
设置: DSE 4.0.01，Cassandra 2.0，Hive，全新集群。在Cassandra中插入10 000行，然后：
cqlsh:pageviews> select count(1) from pageviews_v1 limit 100000;
count
-------
10000
(1 rows)
cqlsh:pageviews>
但从蜂巢：
hive> select count(1) from pagev
浏览 5提问于2014-03-27得票数 1
回答已采纳
5回答
我是学习分布式系统的新手，我读过CAP定理，我对像Cassandra这样的AP系统很感兴趣。 我的问题是，在什么情况下，你实际上可以牺牲一致性？实际上，我所说的是牺牲一致性意味着服务 数据不准确。 那么在什么情况下，您实际上会使用像Cassandra这样的AP数据存储呢？我想不出任何情况下我不希望我的读数是一致的。
浏览 81提问于2019-05-12得票数 1
回答已采纳
Cassandra 3.1 NodeJS驱动程序: cassandra-driver 3.0.0
使用以下语句创建密钥空间：
使用REPLICATION ={ 'class‘：'SimpleStrategy'，'replication_factor’：2 }；
尽管复制因子为2，但出于开发目的，我仅运行一个实例，并将一致性级别设置为1。这就是当我尝试插入带有IF NOT EXISTS子句的任何记录时的问题，我得到了一致性级别错误。但是不带IF NOT EXISTS的语句可以很好地工作。下面是cqlsh的日志：
cqlsh:xxxxxx> CONSISTEN
浏览 10提问于2016-01-02得票数 4
卡桑德拉版本:apache- cassandra -2.1.8
我最近配置了两个节点集群，将Authenticator设置为PasswordAuthenticator。当其中一个节点关闭时，我无法登录到Cqlsh并获得以下错误
Connection error: ('Unable to connect to any servers',
{'192.168.0.45': AuthenticationFailed(u'Failed to authenticate to 192.168.0.45: code=0100 [Bad credentials]
m
浏览 9提问于2015-07-26得票数 7
回答已采纳
在MongoDB文档中，已经提到即使在大多数readConcern的副本集中，我们也可以实现最终的一致性。我想知道这是怎么可能的，当我们在读和写中都有多数，这导致在我们的分布式系统中的仲裁(R+W>N)？我希望在这种情况下有一个强大的一致的系统。这也是Cassandra为了实现强一致性而使用的技术。
有人能帮我澄清一下吗？
浏览 5提问于2016-06-25得票数 4
我们最近开始在生产中使用Cassandra数据库。我们有一个single cross colo cluster of 24 nodes，意思是12 nodes in PHX和12 nodes in SLC colo。我们有一个replication factor of 4，意思是2 copies will be there in each datacenter。
下面是我们的keyspace和column families通过Production DBA's创建的方式。
使用'org.apache.cassandra.locator.NetworkTopologyStrate
浏览 4提问于2013-05-13得票数 6
Cassandra 语句的目标是在单个操作(所有通过或失败)中在一个分区上执行语句。
这与的工作方式非常相似。
在我看来，主要的区别似乎是，对于一个SQL事务，您在它的末尾得到一个，这并不一定是通过Cassandra语句得到的。
我的问题是：，Cassandra中的批处理语句和SQL?中的事务有什么相似之处？
浏览 0提问于2017-06-10得票数 2
回答已采纳
我刚刚在Kubernetes文档中读到了部署带有状态集的Cassandra主题。部署过程: 1.创建StorageClass 2.创建PersistentVolume (在我的例子中是4 PersistentVolume)。在1) storageClassName 3中创建。创建Cassandra无头服务4。使用StatefulSet来创建在StatefulSet yml定义的storageClassName中创建的Cassandra环设置。
因此，有4个荚: Cassandra-0，Cassandra-1，Cassandra-2，Cassandra-4，安装到2)卷(pv-0，pv-1，pv
浏览 0提问于2019-07-14得票数 1
5回答
当单个集群中的节点不包含相同数据的副本，但数据分布在节点之间时，Cassandra中的最终一致性意味着什么。现在，由于单个数据记录在单个位置(节点)。为什么Cassandra不从那个记录的位置返回最近的值呢？在这种情况下，如何产生多个副本？
浏览 1提问于2011-01-03得票数 13
回答已采纳
4回答
有一个关于用在Cassandra中模拟分区问题的。
我的问题是，对于Cassandra，您主要关注CAP定理的划分部分，还是一致性是您需要管理的一个因素？
浏览 2提问于2013-11-25得票数 20
回答已采纳
卡桑德拉文件的以下陈述是我怀疑的原因。
例如，如果使用仲裁的写入一致性级别(复制因子为3 )，Cassandra将复制对集群中所有节点的写入，并等待来自两个节点的确认。如果写入在其中一个节点上失败，而在另一个节点上成功，则Cassandra报告在该节点上复制写入失败。但是，在另一个节点上成功的复制写入不会自动回滚。
参考文献：
那么，Cassandra是否会写入节点(这是向上的)，即使无法满足一致性？
浏览 1提问于2015-05-27得票数 3
回答已采纳
1回答
在很少有人成功地把数据吞进卡桑德拉和斯帕克之后，
每当我尝试使用Spark (几分钟或立即)摄取数据时，都会返回一个错误：
Caused by: com.datastax.oss.driver.api.core.AllNodesFailedException: Could not reach any contact point, make sure you've provided valid addresses
我使用简单的CQLSH (不是火花)进行了检查，并且确实返回了类似的错误(4个节点中的2个节点)：
Connection error: ('Unable to conn
浏览 1提问于2021-09-21得票数 2
回答已采纳
根据文档，Cassandra有不同的一致性级别，其中两个称为SERIAL和LOCAL_SERIAL。除了这两个级别之外，我理解了所有的一致性级别。它说它与轻量级事务有关，但我也不明白。
如果有人能向我解释这些水平就太好了。
浏览 5提问于2022-10-21得票数 0
回答已采纳
我需要运行一些阴性测试，应用程序连接到Cassandra。我想测试的是，当数据在多个Cassandra节点之间不一致时，应用程序是如何工作的。下面是我尝试过的几件事。注意，我使用复制因子作为2，集群中的Cassandra节点数为3，而且读写一致性保持为1。
在几个节点上关闭Cassandra服务
拔出卡桑德拉节点之一的网络电缆，插入数据
进入其他卡桑德拉节点并放回网络电缆。
当测试正在进行时，重载Cassandra节点。
在所有情况下，复制都足够快。一旦出现下线节点或网络电缆插入重播，另一个节点上就有数据可用。
任何试图复制数据不一致的建议都会有帮助。请注意，我使用了嵌入式
浏览 6提问于2017-05-29得票数 1
2回答
我成功地将所谓的COMPANY表加载到Cassandra中。(company.csv)加载后，我收到消息"394行在1.999秒内导入“。
当我使用"SELECT COUNT(*) FROM COMPANY;“计算它们时，我只得到了2行。
我已经尝试删除这些表并重新创建。甚至删除了整个Keyspace &重新创建，但问题仍然存在。有什么解决方案吗？
浏览 1提问于2014-08-04得票数 1
当我尝试为cassandra设置用户身份验证时，我遇到了以下问题。
首先，我使用以下命令更新了cassandra.yaml：
authenticator: PasswordAuthenticator
然后使用replication_factor 3创建system_auth密钥空间，如下所示：
CREATE KEYSPACE system_auth WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 3};
然后使用以下命令重新运行cassandra：
浏览 0提问于2014-03-06得票数 4
回答已采纳
我使用Cassandra作为我公司的生产数据库，我有一个读取一致性问题。每天的记录应该是1440，在第一次读取时，它显示600-700多条记录，第二次读取时，它显示1440+记录。我在集群中有3个节点，3个二级索引，请帮助我。我使用了下面的cassandra版本和配置来进行写和读。
Cassandra Version:
1.1.4
Thrift Version:
070
Consistency level
for Read - ALL
for Write - ANY
我已经做了几次尝试，包括增加超时时间，也检查了在每个节点上运行的Nodetool修复仍然没有任何一致性的变化。
浏览 1提问于2012-08-30得票数 1
回答已采纳
2回答
我使用elasticsearch和cassandra来存储我的数据，ES用于搜索，cassandra作为主要数据库。为了删除旧文档，我使用了带TTL的插入，它可以确保文档在特定时间后被删除。Cassandra做得很好，但对我来说，这只是完成了一半的工作，因为我必须删除ES上相同的doucument，以确保ES和C*之间的同步。
我想知道当cassandra根据文档的TTL值删除文档时是否会发送某种类型的事件。在这种情况下，我在Elasticsearch中直接强制删除。
浏览 13提问于2019-10-04得票数 0
我有带有表和物化视图的cassandra。物化视图最终与表一致，开发人员必须格外小心地实现针对cassandra的算法，以避免遇到诸如刚添加的项似乎不在那里等问题。
我想要的是能够创建测试环境，其中物化视图的最终一致性是非常高的-比如说5/10ms。这样，如果我的集成测试没有遇到问题，它们就不存在了，这样我就很容易了。现在我的集成测试运行在非常小的集群上，看起来这一切都做得非常快，并且我在对几乎生产规模的集群进行了几个小时的摄取之后才发现了一些问题，这是非常昂贵的。
我的问题是:如何降低cassandra物化视图与表的同步速度。
浏览 0提问于2017-02-10得票数 3
我试图在Django rest应用程序中使用Cassandra数据库。当我使用SQLite数据库时，迁移工作正常。但是，当我将数据库更改为使用cassandra时，我将得到以下错误。
TypeError: Unknown option(s) for sync_cassandra command:
app_label, fake, fake_initial, interactive, migration_name, run_syncdb.
Valid options are database, help, no_color, pythonpath, settings, skip_che
浏览 4提问于2019-01-06得票数 1
1回答
我有一个由3个Cassandra节点组成的集群: Cassandra_1、Cassandra_2、Cassandra_3。在集群中，选择Cassandra_1作为种子提供者。所有Cassandra实例都位于同一个数据中心。读/写一致性级别设置为1，复制因子设置为3。
我的问题是: 1.启动卡桑德拉事件的顺序重要吗？例如，如果我启动Cassandra_2，Cassandra_3，以及在Cassandra_1的末尾。
种子提供者对集群的所有节点之间的数据一致性有任何影响吗？
浏览 4提问于2015-05-06得票数 1
要使用主键messageId (类型：UUID)在Cassandra列族中插入消息，我正在使用Spring data Cassandra CrudRepository保存方法。当我们运行每秒数千个请求(2k-3k)、消息体大小为40kb的加载时，save方法不会抛出任何异常。但在获取它们时，我观察到数据库中缺少一些消息！
注意:当我们使用小消息体(100字节)时，我们不会观察到这样的问题。
请建议我如何解决这个问题？我不应该使用CrudRepository保存方法吗？
或者我只是想知道如何知道保存是否成功？
浏览 1提问于2015-10-25得票数 1
NoSQL、Cassandra和Cloud数据库使用不同的方法来保证事务的有效性。
不同方法的例子有哪些?
浏览 3提问于2020-07-23得票数 0
1回答
我的理解是，DynamoDB的行为就像一个巨大的表，您必须指定哈希键和范围键。
的核心概念是基于实体的(比如Cassandra)，它更灵活，可以使用超过一个索引。
但还有更深层次的比较吗？
浏览 2提问于2013-11-03得票数 5
是否有人可以帮助我了解此问题并进行故障排除？我不知道是什么原因导致Hector在尝试连接到Cassandra集群时失败。
我如何才能找出问题所在？
0 [main] INFO me.prettyprint.cassandra.connection.CassandraHostRetryService - Downed Host Retry service started with queue size 10 and retry delay 30s
168 [main] INFO me.prettyprint.cassandra.service.JmxMonitor - R
浏览 3提问于2014-01-27得票数 0
我正在使用spark cassandra连接器(Python)向cassandra写入3000000行8列的数据，当我读回时，我只得到了50000行。当我检查cqlsh中的行数时，也有50000中的行数，我的数据去哪里了，spark -cassandra连接器有问题吗？ 这是我的spark配置 spark = SparkSession.builder.appName("das_archive").config(
"spark.driver.memory", "25g").config('spark.cassandra.connectio
浏览 10提问于2020-06-21得票数 1
回答已采纳
我已经将集群中连接的两个节点的复制因子设置为2。我使用node1作为集群的接触点。我启动了将行写入数据库的应用程序，在写入几行之后，我在node2上停止了Cassandra，这会导致行被写入node1 (并且没有行被写入到node2，尽管在几次行写入期间它是up的，但是在节点重新启动后，DB仍然是空的，但是为什么呢？)无论如何，我尝试通过运行nodetool the来sych DB，但是在运行该命令之后，两个节点DB都显示为空。如何同步节点？
浏览 2提问于2018-08-28得票数 0
1回答
我正在使用Spark Cassandra连接器和python中的数据帧制作一个小的Spark应用程序，但我的写入速度非常慢。当我查看应用程序日志时，它显示：
17/03/28 20:04:05 INFO TableWriter: Wrote 315514 rows to movies.moviescores in 662.134 s.
这大约是每秒474行。
我正在从Cassandra读取一些数据到一个表中，然后对它们进行一些操作(这也会使集合变得更大)。然后我将结果写回cassandra (大约5000万行)：
result.write.format("org.apache.
浏览 1提问于2017-03-29得票数 4
我有一个具有密钥空间的3节点Cassandra集群，其复制因子为3：
CREATE KEYSPACE demo
WITH REPLICATION = {
'class':'SimpleStrategy',
'replication_factor':3
};
(仅部署在一个数据中心)
在进行失败测试时(即删除一个节点)，当尝试对我的密钥空间进行查询时，我会得到这些异常：
Caused by: org.apache.cassandra.exceptions.UnavailableException: Cannot achie
浏览 0提问于2018-03-06得票数 8
我有一个带有单一复制的cassandra 2数据中心对，每个数据中心包含一个节点，每个数据中心位于网络上不同的物理服务器上。如果一个数据中心崩溃，另一个数据中心将继续可供读取和写入。我在第三个服务器上启动了我的java应用程序，它的一切运行正常。它正在对cassandra进行读写。
接下来，我断开了连接，从网络中拔出了第二台数据中心服务器的网线。我希望应用程序能够继续运行，没有任何异常发生在第一个数据中心，但事实并非如此。
应用程序中开始出现以下异常：
me.prettyprint.hector.api.exceptions.HUnavailableException: : May not b
浏览 1提问于2013-08-20得票数 2
假设的话，我计划建立一个以cassandra为数据库的分布式系统。系统将运行在多个服务器上，例如服务器A、B、C、D、E等。每个服务器都有Cassandra实例，所有服务器都将形成一个集群。
在我假设的分布式系统中，服务器总数中的X号应该处理用户请求。3台服务器A，B，C，D，E应该处理来自用户uA的请求。每个应用程序都应该用确切的数据副本更新它的Cassandra实例。例如，如果用户uA向用户uB发送消息，则每个应用程序都应该更新其数据库，其中包含发送的消息的确切副本，以及卡桑德拉应该接任的人和预期的人，以确保所有节点都是最新的。
如何配置Cassandra以确保Cassandra在更新所有
浏览 0提问于2017-10-26得票数 0
2回答
现在，我有一个运行Cassandra的ec2实例和一个简单的websocket服务器。我想知道这是否是制作“实时”聊天应用程序的正确方法。我是不是漏掉了什么？
客户端连接到websocket，插入一条消息，该消息被存储到数据库中，如果记录到数据库成功，则将该消息发送给用户。
const cassandra = require('cassandra-driver');
const client = new cassandra.Client({ contactPoints: ['127.0.0.1'],
localDataCenter: 'datacent
浏览 3提问于2019-09-22得票数 7
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
