`
langzhe
  • 浏览: 286955 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

riak search

    博客分类:
  • riak
 
阅读更多

 

 

现在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> 

---------------------------------------

riak search 查询中文问题,查了好多资料也没有解决,最后我不得不把所有字段用base64来编码,查询也是把条件编码完在查询的
分享到:
评论

相关推荐

    riak-Erlang.rar

    5. 查询语言:虽然主要为键值存储,但Riak还支持查询语言 Riak Search 和 Riak KV MapReduce,允许用户执行更复杂的查询操作。 安装Riak和Erlang在Linux上通常涉及以下步骤: 1. 安装依赖:确保系统安装了必要的...

    YCSB-Riak-Binding

    注意:为了支持 YCSB 的扫描操作,您必须在集群中的每个节点上启用 Riak Search。 有关启用搜索的说明,请参阅: : 如何实现 Riak 客户端以下说明将帮助您开始使用 YCCB 项目和 Riak 客户端对 Riak 进行基准测试。 ...

    yokozuna:Riak + Solr

    横纲Yokozuna-水平绳。 相扑中通常排名最高的冠军,通常被翻译成总冠军。... Yokozuna是Riak Search在Apache Solr之上构建的新实现。 下载尝试Yokozuna。 有关更多信息,请参见。建立状态掌握: 开发:

    elasticsearch-cloud-aws-0.18.5.zip

    了解这些知识点后,开发者可以进一步学习如何在AWS上搭建和管理Elasticsearch集群,如何使用Riak作为Hadoop的数据源,以及如何参与和贡献开源项目。这涵盖了大数据处理、分布式存储和云计算等多个领域,对于提升技术...

    HAProxy配置:针对Hadoop,大数据,NoSQL,Docker,Elasticsearch,SolrCloud,HBase,MySQL,PostgreSQL,Apache Drill,Hive,Presto,Impala,Hue,ZooKeeper,SSH,RabbitMQ,Redis,Riak,Cloudera的80多个HAProxy配置,OpenTSDB,InfluxDB,Prometheus,Kibana,Graphite,Rancher等

    6. **监控和日志分析**: Prometheus和Grafana用于系统监控,InfluxDB、OpenTSDB和Kibana用于时间序列数据存储和可视化,而Elasticsearch和Logstash用于日志管理和分析。HAProxy可以确保这些监控系统的稳定性和性能。...

    sumo_db:Erlang持久性框架

    `sumo_db` 是一个为Erlang编程语言设计的持久性框架,旨在提供与多种数据库系统的集成,包括MySQL、Elasticsearch、Erlang的Mnesia、MongoDB、PostgreSQL(pgsql)以及Riak。这个框架的主要目标是简化在Erlang应用...

    connect-waterline:适用于 Express 和 Connect 的 Waterline 会话存储

    社区适配器适用于CouchDB 、 neDB 、 TingoDB 、 SQLite 、 Oracle 、 MSSQL 、 DB2 、 ElasticSearch 、 Riak 、 neo4j 、 OrientDB 、 Amazon RDS 、 DynamoDB 、 Azure Tables和RethinkDB 。 安装 npm i ...

    Python-分布式系统资源大列表

    Logstash和Elasticsearch则用于日志收集和分析,Fluentd和Beats家族(如Filebeat)提供Python插件来发送日志数据。 此外,分布式锁、分布式任务队列如Celery、分布式调度器如Airflow和Luigi,以及分布式文件系统如...

    MongoDB面试专题.pdf

    - 键值存储:如Redis、Riak - 列式存储:如Cassandra、HBase - 图数据库:如Neo4j NoSQL数据库的优点包括但不限于: - 高性能:在处理大量数据时,NoSQL可以提供更高的性能。 - 高可用性:很多NoSQL数据库支持...

    awesome-loopback

    很棒的环回 关于回送的很棒的东西的集合核连接器第三方弹性搜寻strongloop-community (正在供货) drakerian-(已弃用2014-10-01) offlinehacker--elasticsearch(已放弃2014-08-06) yagobski-弹性环回连接器(已...

    backendjs:node.js后端库

    数据库API支持SQLite,PostreSQL,DynamoDB,ElasticSearch,所有基本操作的行为方式相同,使您无需更改代码即可切换数据库。 使用相同的DB API对所有受支持的数据库进行数据库操作(获取,放置,删除,更新,选择...

    lib:我的其他存储库的Perl实用程序库

    10. **Riak** - 是另一个NoSQL数据库,提供高可用性和一致性。 11. **Ambari** - 是由Apache开发的用于部署、管理和监控Hadoop集群的工具。 12. **Cloudera Manager** - Cloudera提供的管理工具,用于简化Hadoop集群...

    无状态运维.pdf

    5. 状态持久化:对于需要持久化数据的场景,可以利用分布式数据库(如Cassandra、Riak)或云存储服务(如AWS S3、Google Cloud Storage),确保数据在无状态服务之间共享和备份。 6. 服务发现:服务之间通过服务...

    .net分布式开发框架

    如使用ELK Stack(Elasticsearch、Logstash、Kibana)或Prometheus+Grafana组合,可以实时监控系统状态,快速定位并解决问题。 总的来说,.NET分布式开发框架提供了一整套工具和平台,帮助开发者构建可扩展、健壮的...

    分布式系统设计.rar

    5. **分布式数据库**:如Cassandra、Riak和HBase,支持高并发读写和大规模数据存储。 6. **分布式搜索引擎**:如Elasticsearch,用于实时全文搜索和数据分析。 7. **消息队列**:如RabbitMQ、Kafka,实现异步通信...

    大数据技术专业从业人员学习必读

    12. **MapReduce**:MapReduce是处理大规模数据的编程模型,由Google提出,现已被许多大数据工具采用,如CouchDB、MongoDB和Riak。 13. **Oozie**:Oozie是Hadoop的工作流调度系统,用于协调各种Hadoop作业和其他...

    Big Data Glossary-大数据术语

    Riak是一个高度可用的分布式NoSQL数据库,支持数据复制和故障恢复。它采用键值存储方式,支持多种数据类型。 **2.10 ZooKeeper** ZooKeeper是一个分布式协调服务,用于管理和维护分布式系统的元数据。它提供了一种...

    Data Stack Overview

    - **Riak**:分布式键值和文档存储。 - **CouchDB**:基于JSON的分布式数据库。 - **Couchbase**:高性能的分布式内存数据库。 5. **列式数据库**: - **Hypertable**:分布式列式数据库,适用于大数据场景。 ...

Global site tag (gtag.js) - Google Analytics