是否有一个命令指向cassandra中cql表中存在的所有行,如sql中的那些行？
delete from TABLE
通过文档,我没有找到任何方法在没有where条件的情况下执行删除操作.
DELETE col1 FROM SomeTable WHERE userID = 'some_key_value';
我读过的三种类型的NoSQL数据库是键值,面向列和面向文档.
键值非常简单 - 具有普通价值的键.
我已经看到面向文档的数据库被描述为键值,但值可以是一个结构,就像一个JSON对象.每个"文档"可以包含全部,一些或不具有与另一个相同的键.
面向列似乎非常像文档导向,因为您没有指定结构.
那么这两者之间有什么区别,为什么你会使用另一个呢？
我特意看了MongoDB和Cassandra.我基本上需要一个可以改变的动态结构,但不会影响其他值.同时,我需要能够搜索/过滤特定密钥并运行报告.有了CAP,AP对我来说是最重要的.只要没有冲突或数据丢失,数据就可以"最终"跨节点同步.每个用户都会得到他们自己的"桌子".
我正在看两个项目,我真的看不出差异
Cassandra是一个高度可扩展,最终一致,分布式,结构化的键值存储...... Cassandra最终是一致的.与BigTable一样,Cassandra提供了比典型的键/值系统更丰富的基于ColumnFamily的数据模型.
Apache CouchDB是一个分布式,容错且无架构的面向文档的数据库,可通过RESTful HTTP/JSON API访问.
也就是说,我看到每个项目之间的具体差异如下:访问方法,书面语言等等,但是当你谈到SOLR或Sphinx时,你知道两者都是差异很大的索引器,但最后是索引器.
我可以在这里说Cassandra和CouchDB是非关系数据库,在某些情况下可以替换另一个吗？
Merkle Trees在几个分布式复制键/值存储中用作反熵机制:
毫无疑问,反熵机制是一件好事 - 在生产过程中,瞬间失败就会发生.我只是不确定我理解为什么Merkle Trees是最流行的方法.
将完整的Merkle树发送给对等体涉及将本地密钥空间与每个键值的散列一起发送到该对等体,存储在树的最低级别中.
区分从同伴发送的Merkle树需要拥有自己的Merkle树.
由于两个对等体必须已经有一个已排序的键/值 - 哈希空间,为什么不进行线性合并以检测差异？
我只是不相信树结构在考虑维护成本时会提供任何节约,而且已经完成线性遍历树叶的事实只是为了在线上序列化表示.
为了解决这个问题,一个稻草人替代方案可能是让节点交换散列摘要数组,这些散列摘要通过模数环位置逐步更新和删除.
我错过了什么？
我们正在开发一个非常大的项目,我想知道是否有人可以给我一些关于我们应该选择什么数据库后端的建议.
我们的系统由1100个电子设备组成,它们向中央服务器发送信号,然后服务器存储信号信息(信号长约35个字节).这些设备每分钟每分钟发送大约3个信号,所以如果我们做数字,那么数据库上每天将有4.752.000个新记录,每月新记录总数为142.560.000.
我们需要一个快速可靠的数据库后端.当然,我们需要在该DB上进行一些复杂的数据挖掘.我们正在对MongoDB/Cassandra/Redis/CouchDB进行一些研究,但文档网站仍处于早期阶段.
有帮助吗？想法？
非常感谢!
还有哪些陷阱需要避免？你有什么优惠吗？例如,我听说导出/导入Cassandra数据非常困难,让我想知道这是否会妨碍生产数据与开发环境的同步.
顺便说一句,很难找到关于Cassandra的优秀教程,我唯一的http://hab.me/code/wtf-is-a-supercolumn-cassandra-data-model仍然非常基础.
谢谢.
我正在为cassandra(比如sqlDeveloper)寻找一些gui客户端来调用一些基本方法,并运行cql查询
对于一些背景知识 - 这个问题涉及在单个小型EC2实例上运行的项目,并且即将迁移到中型项目.主要组件是Django,MySQL和大量用python和java编写的自定义分析工具,这些工具都是繁重的工作.同一台机器也在运行Apache.
数据模型如下所示 - 大量实时数据来自各种网络传感器,理想情况下,我想建立一个长轮询方法,而不是每15分钟进行一次当前轮询(限制为计算统计数据并写入数据库本身).一旦数据进入,我将原始版本存储在MySQL中,让分析工具在这些数据上松散,并将统计信息存储在另外几个表中.所有这些都是使用Django呈现的.
我需要的关系功能 -
我的主要问题是数据读取非常慢(并且写入也不是很热).我现在不想在它上面投入大量资金和硬件,而且我更喜欢随着时间的推移可以轻松扩展的东西.在这种意义上(或便宜),纵向扩展MySQL并非易事.
所以基本上,在阅读了很多关于NOSQL并尝试了像MongoDB,Cassandra和Voldemort这样的东西之后,我的问题是,
在中等EC2实例上,通过转换到像Cassandra这样的东西,我可以获得读/写的任何好处吗？这篇文章(pdf)肯定似乎暗示了这一点.目前,我会说每分钟几百次写入是常态.对于读取 - 由于数据每5分钟左右更改一次,因此缓存失效必须非常快.在某些时候,它应该能够处理大量并发用户.即使创建了索引,MySQL在大型表上进行某些连接时,应用程序性能也会被杀死 - 大约32k行的内容需要超过一分钟才能呈现.(这可能是EC2虚拟化I/O的工件).表的大小约为4-5百万行,并且大约有5个这样的表.
考虑到CAP定理和最终的一致性,每个人都在谈论在多个节点上使用Cassandra.但是,对于刚刚开始增长的项目,部署单节点cassandra服务器是否有意义？有什么警告吗？例如,它可以取代MySQL作为Django的后端吗？[这是推荐的吗？]
如果我确实转移,我猜我将不得不重写部分应用程序以执行更多"administrivia",因为我必须执行多次查找以获取行.
将MySQL用作关键值存储而不是关系引擎是否有意义,并继续使用它？这样我可以利用大量可用的稳定API,以及稳定的引擎(并根据需要使用关系).(Brett Taylor在Friendfeed上的帖子 - http://bret.appspot.com/entry/how-friendfeed-uses-mysql)
任何转变的人的见解将不胜感激!
谢谢.
我正在尝试Cassandra.
在客户端(使用Hector),我查找了几个这样的键:
ColumnFamilyResult<String, String> result = template.queryColumns(Arrays.asList("key1","key2","key3"));
大部分时间似乎都有效.但有时我在客户端上遇到超时异常:
Caused by: me.prettyprint.hector.api.exceptions.HTimedOutException: TimedOutException()
at me.prettyprint.cassandra.service.ExceptionsTranslatorImpl.translate(ExceptionsTranslatorImpl.java:35)
at me.prettyprint.cassandra.service.template.ThriftColumnFamilyTemplate$1.execute(ThriftColumnFamilyTemplate.java:100)
at me.prettyprint.cassandra.service.template.ThriftColumnFamilyTemplate$1.execute(ThriftColumnFamilyTemplate.java:88)
at me.prettyprint.cassandra.service.Operation.executeAndSetResult(Operation.java:103)
at me.prettyprint.cassandra.connection.HConnectionManager.operateWithFailover(HConnectionManager.java:258)
at me.prettyprint.cassandra.model.ExecutingKeyspace.doExecuteOperation(ExecutingKeyspace.java:97)
at me.prettyprint.cassandra.service.template.ThriftColumnFamilyTemplate.sliceInternal(ThriftColumnFamilyTemplate.java:88)
at me.prettyprint.cassandra.service.template.ThriftColumnFamilyTemplate.doExecuteSlice(ThriftColumnFamilyTemplate.java:46)
at me.prettyprint.cassandra.service.template.ColumnFamilyTemplate.queryColumns(ColumnFamilyTemplate.java:113)
at info.gamlor.experiments.Cassandra.readObjectByKey(ComplexCassandra.java:255)
Caused by: TimedOutException()
at org.apache.cassandra.thrift.Cassandra$get_slice_result.read(Cassandra.java:7772)
at org.apache.cassandra.thrift.Cassandra$Client.recv_get_slice(Cassandra.java:570)
at org.apache.cassandra.thrift.Cassandra$Client.get_slice(Cassandra.java:542)
at me.prettyprint.cassandra.service.template.ThriftColumnFamilyTemplate$1.execute(ThriftColumnFamilyTemplate.java:95)
在服务器上,此异常显示:
ERROR 11:33:55,312 Exception in thread Thread[ReadStage:91,5,main]
java.lang.AssertionError: DecoratedKey(4948402862350542345439897754126541659, 6932) != DecoratedKey(132475956107784875457507977471906551877, 726f6f74) in C:\tem
p\cassandra\lib\cassandra\data\CassandraPolepos\ComplexObjects\CassandraPolepos-ComplexObjects-hd-2-Data.db
at org.apache.cassandra.db.columniterator.SSTableSliceIterator.<init>(SSTableSliceIterator.java:58)
at org.apache.cassandra.db.filter.SliceQueryFilter.getSSTableColumnIterator(SliceQueryFilter.java:66)
at org.apache.cassandra.db.filter.QueryFilter.getSSTableColumnIterator(QueryFilter.java:78)
at org.apache.cassandra.db.CollationController.collectAllData(CollationController.java:256)
at org.apache.cassandra.db.CollationController.getTopLevelColumns(CollationController.java:63)
at org.apache.cassandra.db.ColumnFamilyStore.getTopLevelColumns(ColumnFamilyStore.java:1331)
at org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:1193)
at org.apache.cassandra.db.ColumnFamilyStore.getColumnFamily(ColumnFamilyStore.java:1128)
at org.apache.cassandra.db.Table.getRow(Table.java:378)
at org.apache.cassandra.db.SliceFromReadCommand.getRow(SliceFromReadCommand.java:69)
at …有谁知道两种CQL数据类型text和varcharCassandra 之间的区别？Cassandra文档将这两种类型描述为"UTF-8编码字符串",仅此而已.