例如，这些尝试是否会被记录为system_traces.sessions或system_traces.events中跟踪会话的一部分？ 编辑:我使用的驱动程序名为gocql
浏览 16提问于2020-07-20得票数 1
回答已采纳
我建立了一个具有多个协调节点的Cassandra集群。
有时，协调器节点中的一个变为unavailable...my代码，使用重试策略处理这个问题，该策略移到下一个节点，问题就解决了。但是，问题节点似乎仍然接收流量，即使驱动程序一直抛出OperationTimedOutException...it也是很费时的，因为这个节点无用。进一步的详细信息: Cassandra驱动程序-我使用Cassandra驱动程序版本3.1
浏览 29提问于2022-07-28得票数 0
我需要使用Datastax Java驱动程序批量写入Cassandra，这是我第一次尝试将批处理与datastax java驱动程序一起使用，所以我有一些困惑。下面是我的代码，我试图在其中创建一个Statement对象，并将其添加到批处理中，并将ConsistencyLevel设置为QUORUM。setLastModifiedDate(Date lastModifiedDate) { }现在我的问题是-我使用B
浏览 4提问于2014-10-09得票数 6
回答已采纳
1回答
我目前正在实现一个spring启动微服务，它将数据持久化到单个Cassandra数据库节点。如果与数据库的连接丢失了，那么我需要能够设置重试次数，以及微服务配置文件中重试之间的毫秒数。我使用的是“spring版本1.5.6”和spring cassandra版本1.5.6“。通过创建CassandraCqlClusterFactoryBean类型的集群并在cluster.setReconnectionPolicy()方法中传递自定义重连接策略<
浏览 1提问于2017-10-26得票数 2
我正在通过实现datastax 来自定义重试策略。我注意到，当触发时，重试策略在datastax框架创建的新线程中执行。因此，我正在丢失上下文，并且无法在原始查询执行和当前重试执行之间进行链接(我的相关上下文数据存储在上)。是否有一种方法可以将数据注册/传递到重试策略中，以便能够利用原始查询中的信息？我的最终目标是能够从原始查询
浏览 11提问于2019-03-28得票数 0
1回答
我们在我们的系统上使用Cassandra 3.0。对于在数据库中的插入，我们使用Datastax C#驱动程序。即使存在超时，我们如何知道插入的实际状态？如果抛出了超时，插入怎么可能提前完成呢？无论插入是否成功，或者是否应用了一些默认的重试</
浏览 2提问于2018-02-04得票数 2
我是Spring批处理的新手，使用spring引导，我阅读了几乎所有可用的文章，但没有找到用于用例的确切场景/片段，如下所示。(对所有5个项目按顺序排列)
我创建了跳过策略，它跳过了异常，给了我预期的行为，但无法开始重
浏览 0提问于2018-10-29得票数 0
我有一个40列RDBMS表，我正在移植到Cassandra。我创建了一个带有列名、数据类型、列大小等的excel表。当实际数据只有192个字节时，每个RDBMS行的Cassandra特定开销高达1KB。
由于管理费用与列数成正比，所以我认为，如果只为不属于主键的字段创建一个UDT，情况会好得多。另外，我不打算在UDT的内部字段上运行查询。即使我想这样做，Cassandra也有非常有限的查询<
浏览 2提问于2015-10-20得票数 2
回答已采纳
我们有一个工作者角色，根据查询的结果处理记录并根据需要发送Azure服务总线消息，这基本上是一个队列处理服务。作为使用SQL的最佳实践的一部分，我们已经使用重试策略包装了所有查询语句(这将检测瞬态错误，并将根据定义的策略重试)。请注意，我们实际上是从using语句中发送消息的，因此db变量没有“泄漏”。在using语句中，ReSharper会发出‘访问已释放<em
浏览 4提问于2013-03-22得票数 2
回答已采纳
我使用的是Polly版本7.1.1 })我有一个尝试连接到PostgreSQL数据库并使用上述策略运行查询的方法：
us
浏览 0提问于2020-09-30得票数 1
回答已采纳
1回答
我有一个3台机器的Cassandra集群，使用机架无感知放置策略，复制因子为2。= CounterColumnType;对副本1的查询：=> (counter=downloads, value=1013)
=> (counte
浏览 0提问于2011-08-08得票数 1
回答已采纳
当客户端发出查询时，orientdb如何决定选择哪个master？如果选择本地master，那么如果本地master中的数据不是最新的，即查询到来时没有完成从其他master同步，该怎么办？客户端是否应该稍后重试？
此外，如果相同的记录同时写入不同的位置，如何确定最终数据？根据LWW (last write win)或其他策略？
浏览 0提问于2018-11-09得票数 0
我正在运行一个查询，获取数百万行(5.000.000左右)。我的节点似乎很忙，因为协调器返回一个com.datastax.driver.core.exceptions.ReadTimeoutException: Cassandra timeout during到目前为止，我已经尝试在每个Cassandra节点上设置一个更高的read_request_timeout_in_millis，并执行如下查询
new SimpleStatement("SELECT *我
浏览 10提问于2016-08-17得票数 2
回答已采纳
我有一个cassandra表，它有一个复合主键：(school_id, student_id)。假设我想删除这个表中属于一所学校的所有记录。使用cassandra驱动程序，我尝试只绑定school_id，如下所示：
val query = QueryBuilder.delete().all().from(session.loggedKeyspacecom.datastax.driver.core.exceptions.InvalidQueryException: Missing mand
浏览 2提问于2018-01-30得票数 4
现在，我已经设法让我的代码在相对较小的数据集上为我的问题场景工作。基本上，我要查询的列族有100万条记录，每条记录有28列。在这里，我在一个ubuntu虚拟机器上运行一个2节点的cassandra集群，系统配置为
RAM: 3
浏览 8提问于2014-02-06得票数 1
我正在尝试从cassandra中的一个表中删除，我想删除基于附加的where子句，该子句不是主键的一部分，但我也可以传递主键。场景是，我想从搜索表中删除一条记录，该记录的目标表id在附加列中。, other_data text)create table emails(email text primary key, id text)
现在我想从电子邮件表中删除，只有当一个电子邮件属于一个特定的</e
浏览 4提问于2019-11-13得票数 0
回答已采纳
下面是发送批处理消息的代码，下面是创建服务总线客户端时重试策略的设置。在测试涉及瞬态网络故障的场景时，我们看到发送任务有故障的日志，但是在服务总线中可以看到分配给批处理消息的消息id。即使在进入错误之后，重试是否仍会在后台继续发生？我的理解是，只有在SDK完成重试过程之后，故障才会发生。对吗？
浏览 10提问于2022-03-17得票数 0
回答已采纳
7回答
卡桑德拉全文搜索
、、
我试图在卡桑德拉进行全文搜索，但经过一些研究后，我发现可能没有一个“简单”的方法。我说，也许是因为谷歌的第一页并没有说太多的话。
所以我现在试着去理解，这里最好的方法是什么。这种方式让我根据我到目前为止所了解的关于Cassandra的知识，根据这两个原则来设计我自己的假设；( a)根据查询而不是数据来设计表；( b)更多--数据是一件好事，只要它被正确地使用。话虽如此，我已经想出了几个解决方案，我想和大家分享，并问如果有人有更好的想法
浏览 0提问于2014-07-21得票数 17
回答已采纳
我使用来处理一个流，其中一个螺栓是写给cassandra的。cassandra session.execute()命令可以抛出一个异常，我想知道如何将其捕获为“失败”元组，以便重新尝试。IRichBolt的文档不会抛出任何东西，所以我想知道异常情况是如何处理的。
主要问题:我是应该尝试/抓住卡桑德拉呼叫，还是风暴会帮我处理这个案子？
浏览 0提问于2015-05-27得票数 3
回答已采纳
2回答
在医生1中，有人说of 3, Cassandra willIf the write fails onwrite failure但是由于最终的一致性，所有的节点最终都会收到更新。有什么策略吗？
浏览 1提问于2013-04-15得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
