- 浏览: 286358 次
- 性别:
- 来自: 北京
文章分类
最新评论
-
langzhe:
Mac 下用 sudo cpan Template,依然不能 ...
第一次 使用 tsung -
langzhe:
<server host='127.0.0.1' por ...
ejabberd/tsung 做压力测试万万不可忽视测试工具问题 -
dlliwei:
jabberd_register.xml 内容如下(我的ser ...
ejabberd/tsung 做压力测试万万不可忽视测试工具问题 -
dlliwei:
你好,我安装tsung后执行命令: tsung -f jabb ...
ejabberd/tsung 做压力测试万万不可忽视测试工具问题 -
bit1129:
这么复杂的一个东西,一句话说完了?
keepalive
现在search查询还是空
Simon 11:53:44
这数据库太新,不好把握,还是用成熟一点的比较好吧
建完bucket,附带了precommit属性,才会建索引
之前的数据是查不出的
Simon 11:54:59
索引里面没有
建索引的时候不会遍历老数据
Android郎哲<langxianzhe@163.com> 11:55:30
我发你我创建的过程你看看,哪里不对
Android郎哲<langxianzhe@163.com> 11:57:56
第一步
Client:set_bucket(<<"g2">>,[{precommit, [{struct,[{<<"mod">>,<<"riak_search_kv_hook">>},{<<"fun">>,<<"precommit">>}]}]}]).
第二步
f(O0),O0 = riak_object:new(<<"g2">>, <<"mine">>, <<"bread">>).
第三步
(riak@127.0.0.1)108> C:put(O0).
ok
我的理解是以上三步就可以完成了
Android郎哲<langxianzhe@163.com> 11:59:36
以下是执行
search的结果
(riak@127.0.0.1)109> search:search_doc(<<"g2">>, <<"bread">>)
(riak@127.0.0.1)109> .
{1,"0.353553",
[{riak_idx_doc,<<"g2">>,<<"mine">>,
[{<<"value">>,<<"bread">>,[{<<"bread">>,[0]}]}],
[],[],true}]}
(riak@127.0.0.1)110> search:search_doc(<<"g2">>, <<"bre">>)
(riak@127.0.0.1)110> .
{0,"0.0",[]}
(riak@127.0.0.1)111> search:search_doc(<<"g2">>)
(riak@127.0.0.1)111> .
{0,"0.0",[]}
(riak@127.0.0.1)112> search:search(<<"g2">>, <<"bread">>)
(riak@127.0.0.1)112> .
{1,
[{<<"g2">>,<<"mine">>,
[{p,[0]},{score,0.35355339059327373}]}]}
(riak@127.0.0.1)113> search:search(<<"g2">>, "bread")
(riak@127.0.0.1)113> .
{1,
[{<<"g2">>,<<"mine">>,
[{p,[0]},{score,0.35355339059327373}]}]}
(riak@127.0.0.1)114> search:search(<<"g2">>, "bre")
(riak@127.0.0.1)114> .
{0,[]}
(riak@127.0.0.1)115> search:search(<<"g2">>)
(riak@127.0.0.1)115> .
{0,[]}
Android郎哲<langxianzhe@163.com> 12:01:15
为什么 search:search(<<"g2">>)和search:search_doc(<<"g2">>) 返回是空的
Simon 12:01:46
不是已经能查出来了吗
(riak@127.0.0.1)112> search:search(<<"g2">>, <<"bread">>)
(riak@127.0.0.1)112> .
{1,
[{<<"g2">>,<<"mine">>,
[{p,[0]},{score,0.35355339059327373}]}]}
Android郎哲<langxianzhe@163.com> 12:02:44
这个是根据具体的key查出来的,模糊的key还查不出来
Simon 12:03:02
模糊查询?
Android郎哲<langxianzhe@163.com> 12:03:07
对
这个不是全文检索功能吗
Simon 12:03:45
试试<<"bre*">>
Android郎哲<langxianzhe@163.com> 12:04:54
<<"bre*">>
可以查出
<<"*re*">>查不出
Simon 12:05:26
我想起来了,反向索引就是用bread这个值建了一个key
Android郎哲<langxianzhe@163.com> 12:05:41
什么意思请详解
Simon 12:05:54
然后把值为bread的key当成一个列表存起来
底层原理就是这样
Android郎哲<langxianzhe@163.com> 12:07:48
你是说它把存储的value当做key索引存储了一边
Simon 12:07:58
让我哭的就是,你想查出值为bread的所有记录,他只是返回key列表,你还得根据这个列表挨个找出value
是的
Android郎哲<langxianzhe@163.com> 12:09:05
再根据Key查找value也好,
<<*re*>>
查不出来如何解释
Simon 12:12:32
一个桶的底层存储结构是这样:
key value
{key, <<"g2">>, <<"mine">>} <<"bread">>
{key, <<"g2">>, <<"you">>} <<"bread">>
{index, <<"g2">>, <<"bread">>} [<<"mine">>,<<"you">>]
只是示意一下,实际的你得看key的组成规则
Android郎哲<langxianzhe@163.com> 12:15:10
嗯明白
Android郎哲<langxianzhe@163.com> 12:16:24
search:search(<<"g2">>)查询为什么查询不到索引呢, 现在仍然是空
(riak@127.0.0.1)144> search:search(<<"g2">>).
{0,[]}
-----26> riakc_pb_socket:search(Pid,<<"g2">>, list_to_binary("<<\"orange\">>:<<\"bread\">>"),[],5000).
{ok,{search_results,[{<<"g2">>,
[{<<"id">>,<<"mine">>},{<<"value">>,<<"bread">>}]},
{<<"g2">>,
[{<<"id">>,<<"your">>},{<<"value">>,<<"orange">>}]}],
0.07724899798631668,2}}
27>
27> riakc_pb_socket:search(Pid,<<"g2">>, list_to_binary("<<\"orange\">><<\"bread\">>"),[],5000).
{ok,{search_results,[{<<"g2">>,
[{<<"id">>,<<"mine">>},{<<"value">>,<<"bread">>}]},
{<<"g2">>,
[{<<"id">>,<<"your">>},{<<"value">>,<<"orange">>}]}],
0.07724899798631668,2}}
* 2: syntax error before: '.'
35> riakc_pb_socket:search(Pid,<<"g2">>, list_to_binary("orangebread"),[],5000).
{ok,{search_results,[],0.0,0}}
36> riakc_pb_socket:search(Pid,<<"g2">>, list_to_binary("orange\"\"bread"),[],5000).
{ok,{search_results,[{<<"g2">>,
[{<<"id">>,<<"mine">>},{<<"value">>,<<"bread">>}]},
{<<"g2">>,
[{<<"id">>,<<"your">>},{<<"value">>,<<"orange">>}]}],
0.2959290146827698,2}}
53> riakc_pb_socket:search(Pid,<<"g2">>, "br*\"\"or*").
{ok,{search_results,[{<<"g2">>,
[{<<"id">>,<<"mine">>},{<<"value">>,<<"bread">>}]},
{<<"g2">>,
[{<<"id">>,<<"your">>},{<<"value">>,<<"orange">>}]}],
0.0,2}}
54>
73> riakc_pb_socket:search(Pid,<<"g2">>, HerBin).
{ok,{search_results,[{<<"g2">>,
[{<<"id">>,<<"her">>},
{<<"value">>,
<<131,108,0,0,0,2,104,2,107,0,4,110,97,109,101,107,0,
2,...>>}]}],
0.35355299711227417,1}}
74> HerBin.
<<131,108,0,0,0,2,104,2,107,0,4,110,97,109,101,107,0,2,
120,119,104,2,107,0,1,115,107,0,1,...>>
75> binary_to_term(HerBin).
[{"name","xw"},{"s","d"}]
76> riakc_pb_socket:search(Pid,<<"g2">>, HerBin).
{ok,{search_results,[{<<"g2">>,
[{<<"id">>,<<"her">>},
{<<"value">>,
<<131,108,0,0,0,2,104,2,107,0,4,110,97,109,101,107,0,
2,...>>}]}],
0.35355299711227417,1}}
77>
--------------------------------
(riak@127.0.0.1)43> lucene_scan:string("name:jason").
{ok,[{string,1,"name"},{scope,1,":"},{string,1,"jason"}],1}
(riak@127.0.0.1)45> lucene_scan:string("namejason*").
{ok,[{wildcard_glob,1,"namejason*"}],1}
[{'query',[{wildcard_glob,1,"namejason*"}]}, {'filter', []}];
[{'query', QueryOps}, {'filter', FilterOps}];
-----------------------------9> riakc_pb_socket:put(Pid,O).
ok
50> riakc_pb_socket:list_buckets(Pid).
{ok,[<<"user">>]}
51> riakc_pb_socket:set_bucket(Pid, <<"user">>, [{precommit, [{struct,[{<<"mod">>,<<"riak_search_kv_hook">>},{<<"fun">>,<<"precommit">>}]}]}]).
ok
52> riakc_pb_socket:list_buckets(Pid).
{ok,[<<"user">>]}
53> f(O),O=riakc_obj:new(<<"user">>, <<"jason">>, list_to_binary("[{\"name\":\"jason\"},{\"sex\":\"male\"}]"), "application/json").
{riakc_obj,<<"user">>,<<"jason">>,undefined,[],
{dict,1,16,16,8,80,48,
{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],...},
{{[],[],[],[],[],[],[],[],[],[],[[<<...>>|...]],[],[],...}}},
<<"[{\"name\":\"jason\"},{\"sex\":\"male\"}]">>}
54> riakc_pb_socket:put(Pid,O).
ok
55> riakc_pb_socket:list_buckets(Pid).
{ok,[<<"user">>]}
56> riakc_pb_socket:set_bucket(Pid, <<"user">>, [{precommit, [{struct,[{<<"mod">>,<<"riak_search_kv_hook">>},{<<"fun">>,<<"precommit">>}]}]}]).
ok
57> riakc_pb_socket:set_bucket(Pid, <<"users">>, [{precommit, [{struct,[{<<"mod">>,<<"riak_search_kv_hook">>},{<<"fun">>,<<"precommit">>}]}]}]).
ok
58> f(O),O=riakc_obj:new(<<"users">>, <<"jason">>, list_to_binary("[{\"name\":\"jason\"},{\"sex\":\"male\"}]"), "application/json").
{riakc_obj,<<"users">>,<<"jason">>,undefined,[],
{dict,1,16,16,8,80,48,
{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],...},
{{[],[],[],[],[],[],[],[],[],[],[[<<...>>|...]],[],[],...}}},
<<"[{\"name\":\"jason\"},{\"sex\":\"male\"}]">>}
59> riakc_pb_socket:put(Pid,O).
ok
60> f(O),O=riakc_obj:new(<<"user2">>, <<"jason">>, list_to_binary("[{\"name\":\"jason\"},{\"sex\":\"male\"}]"), "application/json").
{riakc_obj,<<"user2">>,<<"jason">>,undefined,[],
{dict,1,16,16,8,80,48,
{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],...},
{{[],[],[],[],[],[],[],[],[],[],[[<<...>>|...]],[],[],...}}},
<<"[{\"name\":\"jason\"},{\"sex\":\"male\"}]">>}
61> riakc_pb_socket:put(Pid,O).
ok
62> riakc_pb_socket:search(Pid, <<"users">>, "sdf").
{ok,{search_results,[],0.0,0}}
63> riakc_pb_socket:search(Pid, <<"users">>, "name:jason").
{ok,{search_results,[],0.0,0}}
64> riakc_pb_socket:search(Pid, <<"users">>, <<"name:jason">>).
{ok,{search_results,[],0.0,0}}
65> riakc_pb_socket:search(Pid, <<"users">>, "\"name\":\"jason\"").
{ok,{search_results,[],0.0,0}}
66> riakc_pb_socket:search(Pid, <<"users">>, list_to_binary("\"name\":\"jason\"")).
{ok,{search_results,[],0.0,0}}
67> riakc_pb_socket:search(Pid, <<"user3">>, list_to_binary("\"name\":\"jason\"")).
{ok,{search_results,[],0.0,0}}
68> riakc_pb_socket:search(Pid, <<"user2">>, list_to_binary("\"name\":\"jason\"")).
{ok,{search_results,[{<<"user2">>,
[{<<"id">>,<<"jason">>},
{<<"name">>,<<"jason">>},
{<<"sex">>,<<"male">>}]}],
0.35355299711227417,1}}
69> riakc_pb_socket:search(Pid, <<"user2">>, list_to_binary("\"sex\":\"male\"")).
{ok,{search_results,[{<<"user2">>,
[{<<"id">>,<<"jason">>},
{<<"name">>,<<"jason">>},
{<<"sex">>,<<"male">>}]}],
0.35355299711227417,1}}
70> riakc_pb_socket:search(Pid, <<"users">>, "\"name\":\"jason\"").
{ok,{search_results,[],0.0,0}}
71> riakc_pb_socket:search(Pid, <<"user2">>, list_to_binary("\"name\":\"jason\"")).
{ok,{search_results,[{<<"user2">>,
[{<<"id">>,<<"jason">>},
{<<"name">>,<<"jason">>},
{<<"sex">>,<<"male">>}]}],
0.35355299711227417,1}}
72> riakc_pb_socket:search(Pid, <<"user2">>, list_to_binary("\"sex\":\"male\"")).
{ok,{search_results,[{<<"user2">>,
[{<<"id">>,<<"jason">>},
{<<"name">>,<<"jason">>},
{<<"sex">>,<<"male">>}]}],
0.35355299711227417,1}}
73> riakc_pb_socket:search(Pid, <<"user2">>, list_to_binary("\"sex\":\"mal*\"")).
{ok,{search_results,[],0.0,0}}
74> riakc_pb_socket:search(Pid, <<"user2">>, list_to_binary("\"sex\":\"male\"")).
{ok,{search_results,[{<<"user2">>,
[{<<"id">>,<<"jason">>},
{<<"name">>,<<"jason">>},
{<<"sex">>,<<"male">>}]}],
0.35355299711227417,1}}
sss
-----------------------------------------------模糊匹配查询-------------------------------------------
(ejabberd@meta)56> riakc_pb_socket:search(Pid, <<"user1">>, list_to_binary("\"name\":\"jaso*\"")).
{ok,{search_results,[],0.0,0}}
(ejabberd@meta)57> riakc_pb_socket:search(Pid, <<"user1">>, list_to_binary("\"name\":jason*")).
{ok,{search_results,[{<<"user1">>,
[{<<"id">>,<<"jason">>},
{<<"name">>,<<"jason">>},
{<<"sex">>,<<"male">>}]}],
0.0,1}}
(ejabberd@meta)58> riakc_pb_socket:search(Pid, <<"user1">>, list_to_binary("\"name\":ja*")).
{ok,{search_results,[{<<"user1">>,
[{<<"id">>,<<"jason">>},
{<<"name">>,<<"jason">>},
{<<"sex">>,<<"male">>}]}],
0.0,1}}
(ejabberd@meta)59> riakc_pb_socket:search(Pid, <<"user1">>, list_to_binary("\"name\":*")).
{ok,{search_results,[],0.0,0}}
(ejabberd@meta)60> riakc_pb_socket:search(Pid, <<"user1">>, list_to_binary("\"name\":j*")).
{ok,{search_results,[],0.0,0}}
(ejabberd@meta)61> riakc_pb_socket:search(Pid, <<"user1">>, list_to_binary("\"name\":ja*")).
{ok,{search_results,[{<<"user1">>,
[{<<"id">>,<<"jason">>},
{<<"name">>,<<"jason">>},
{<<"sex">>,<<"male">>}]}],
0.0,1}}
(ejabberd@meta)62>
发表评论
-
解决更新自定义mapreduce代码 需要riak重启问题
2013-10-23 12:39 1221解决更新自定义代码riak重启问题 1、创建自定 ... -
两个周前挖了一个坑,现在跳了进去<riak mapreduce 分析>,顺便能实现分页功能了
2013-08-08 18:36 825我现在有一个这样的bucket id follow ... -
riak mapreduce worker_limit_reached 错误
2013-07-09 16:10 11131、 =ERROR REPORT==== 9-Jul-2 ... -
riak mapreduce worker_limit_reached 错误
2013-07-09 16:10 01、 =ERROR REPORT==== 9-Jul-2 ... -
riak second index 组合键
2012-11-13 14:17 717(ejabberd@meta)51> eja ... -
Riak failed to start within 15 seconds
2012-11-01 15:02 1158兄弟反应riak无法启动,一开始没仔细看,后来网上 ... -
riak erlanl client search 新特性
2012-10-11 15:27 656新特性,返回结果:可以指定需要的列,并返回记录数。 C ... -
[MapReduce] in state wait_for_input terminated with reason: processing_error
2012-09-26 15:25 734解决方法:添加riak_kv_util:is_x_delete ... -
根据 Second Index和 mapred查询数据
2012-07-27 18:17 724application 查询方法 get_last_i ... -
The "modfun" input type is not widely used outside of Riak
2012-07-20 16:00 663Hi, Jason. The "modfun&quo ... -
riak MapReduce 中的 {index, bucket(), Index::binary(), key()} 使用方法
2012-07-16 20:16 786----------这是客户端测试代码--------- ... -
MapReduce riak
2012-07-05 18:18 7181、今天看了一下riak的mapred/3/4/5方法,以下几 ... -
Secondary Indexes in nosql of riak
2012-07-04 17:26 875官方文档 http://wiki.basho.com/Sec ... -
riak C:get() 后台跑出异常 > in state waiting_vnode_r terminated with re
2011-12-06 11:24 836(riaktest@127.0.0.1)6> O0 ...
相关推荐
5. 查询语言:虽然主要为键值存储,但Riak还支持查询语言 Riak Search 和 Riak KV MapReduce,允许用户执行更复杂的查询操作。 安装Riak和Erlang在Linux上通常涉及以下步骤: 1. 安装依赖:确保系统安装了必要的...
注意:为了支持 YCSB 的扫描操作,您必须在集群中的每个节点上启用 Riak Search。 有关启用搜索的说明,请参阅: : 如何实现 Riak 客户端以下说明将帮助您开始使用 YCCB 项目和 Riak 客户端对 Riak 进行基准测试。 ...
横纲Yokozuna-水平绳。 相扑中通常排名最高的冠军,通常被翻译成总冠军。... Yokozuna是Riak Search在Apache Solr之上构建的新实现。 下载尝试Yokozuna。 有关更多信息,请参见。建立状态掌握: 开发:
了解这些知识点后,开发者可以进一步学习如何在AWS上搭建和管理Elasticsearch集群,如何使用Riak作为Hadoop的数据源,以及如何参与和贡献开源项目。这涵盖了大数据处理、分布式存储和云计算等多个领域,对于提升技术...
6. **监控和日志分析**: Prometheus和Grafana用于系统监控,InfluxDB、OpenTSDB和Kibana用于时间序列数据存储和可视化,而Elasticsearch和Logstash用于日志管理和分析。HAProxy可以确保这些监控系统的稳定性和性能。...
`sumo_db` 是一个为Erlang编程语言设计的持久性框架,旨在提供与多种数据库系统的集成,包括MySQL、Elasticsearch、Erlang的Mnesia、MongoDB、PostgreSQL(pgsql)以及Riak。这个框架的主要目标是简化在Erlang应用...
社区适配器适用于CouchDB 、 neDB 、 TingoDB 、 SQLite 、 Oracle 、 MSSQL 、 DB2 、 ElasticSearch 、 Riak 、 neo4j 、 OrientDB 、 Amazon RDS 、 DynamoDB 、 Azure Tables和RethinkDB 。 安装 npm i ...
Logstash和Elasticsearch则用于日志收集和分析,Fluentd和Beats家族(如Filebeat)提供Python插件来发送日志数据。 此外,分布式锁、分布式任务队列如Celery、分布式调度器如Airflow和Luigi,以及分布式文件系统如...
- 键值存储:如Redis、Riak - 列式存储:如Cassandra、HBase - 图数据库:如Neo4j NoSQL数据库的优点包括但不限于: - 高性能:在处理大量数据时,NoSQL可以提供更高的性能。 - 高可用性:很多NoSQL数据库支持...
很棒的环回 关于回送的很棒的东西的集合核连接器第三方弹性搜寻strongloop-community (正在供货) drakerian-(已弃用2014-10-01) offlinehacker--elasticsearch(已放弃2014-08-06) yagobski-弹性环回连接器(已...
数据库API支持SQLite,PostreSQL,DynamoDB,ElasticSearch,所有基本操作的行为方式相同,使您无需更改代码即可切换数据库。 使用相同的DB API对所有受支持的数据库进行数据库操作(获取,放置,删除,更新,选择...
10. **Riak** - 是另一个NoSQL数据库,提供高可用性和一致性。 11. **Ambari** - 是由Apache开发的用于部署、管理和监控Hadoop集群的工具。 12. **Cloudera Manager** - Cloudera提供的管理工具,用于简化Hadoop集群...
5. 状态持久化:对于需要持久化数据的场景,可以利用分布式数据库(如Cassandra、Riak)或云存储服务(如AWS S3、Google Cloud Storage),确保数据在无状态服务之间共享和备份。 6. 服务发现:服务之间通过服务...
如使用ELK Stack(Elasticsearch、Logstash、Kibana)或Prometheus+Grafana组合,可以实时监控系统状态,快速定位并解决问题。 总的来说,.NET分布式开发框架提供了一整套工具和平台,帮助开发者构建可扩展、健壮的...
5. **分布式数据库**:如Cassandra、Riak和HBase,支持高并发读写和大规模数据存储。 6. **分布式搜索引擎**:如Elasticsearch,用于实时全文搜索和数据分析。 7. **消息队列**:如RabbitMQ、Kafka,实现异步通信...
12. **MapReduce**:MapReduce是处理大规模数据的编程模型,由Google提出,现已被许多大数据工具采用,如CouchDB、MongoDB和Riak。 13. **Oozie**:Oozie是Hadoop的工作流调度系统,用于协调各种Hadoop作业和其他...
Riak是一个高度可用的分布式NoSQL数据库,支持数据复制和故障恢复。它采用键值存储方式,支持多种数据类型。 **2.10 ZooKeeper** ZooKeeper是一个分布式协调服务,用于管理和维护分布式系统的元数据。它提供了一种...
- **Riak**:分布式键值和文档存储。 - **CouchDB**:基于JSON的分布式数据库。 - **Couchbase**:高性能的分布式内存数据库。 5. **列式数据库**: - **Hypertable**:分布式列式数据库,适用于大数据场景。 ...