Tire

Ruby client for CSDNSearch.

Usage

配置：

# 设置日志： Tire::Configuration.logger(STDOUT, :level => "debug")

# 设置搜索后端URL Tire::Configuration.url("http://localhost:9200") 或者在环境变量设置： export CSDNSEARCH_URL=http://localhost:9200

注册分片：index.regist_shard(options) ``` [1] pry(main)> index = Tire.index(“index_name”) => #<Tire::Index:0xb2b3b958 @name=”index_name”> [2] pry(main)> index.regist_shard :cs1 => [0,1], :cs2 => [2] # 2012-06-21 17:47:34:%L [_regist_shard] (“index_name”) # curl -X PUT “http://192.168.6.35:9400/index_name/_shard” -d ‘“cs2”:[2],”cs1”:[0,1]’

2012-06-21 17:47:34:%L [200]

# # “"ok":true,"acknowledged":"true"”

=> true ```

查看分片信息：index.shard_info ``` [2] pry(main)> index.shard_info # 2012-06-05 16:25:40:748 [_regist_shard_info] (“index_name”) # curl -X GET http://192.168.6.35:9400/index_name

2012-06-05 16:25:40:748 [200]

=> [“index”=>”index_name”, “shardId”=>0, “index”=>”index_name”, “shardId”=>1, “index”=>”index_name”, “shardId”=>2, “index”=>”index_name”, “shardId”=>3, “index”=>”index_name”, “shardId”=>4, “index”=>”index_name”, “shardId”=>5]

```

删除索引：index.delete

``` [5] pry(main)> index.delete # 2012-06-05 17:07:02:158 [DELETE] (“index_name”) # curl -X DELETE http://192.168.6.35:9400/index_name

2012-06-05 17:07:02:158 [200]

=> true

```

创建Mapping:index.create_mapping(type, options)

``` [4] pry(main)> mapping = [4] pry(main)* {“_source”=>{“enabled”=>false, [4] pry(main)* “properties”=> [4] pry(main)* [4] pry(main)* {“type”=>”string”, [4] pry(main)* “term_vector”=>”with_positions_offsets”, [4] pry(main)* “boost”=>2.0, [4] pry(main)* “body”=>“term_vector”=>”with_positions_offsets”, [4] pry(main)* “username”=>“index”=>”not_analyzed”, “store”=>”no”, [4] pry(main)* “id”=> [4] pry(main)* “index”=>”not_analyzed”, “include_in_all”=>false, [4] pry(main)* “created_at”=> [4] pry(main)* “index”=>”not_analyzed”, “include_in_all”=>false}}} => {“_source”=>{“enabled”=>false, “properties”=> {“type”=>”string”, “term_vector”=>”with_positions_offsets”, “boost”=>2.0, “body”=>“term_vector”=>”with_positions_offsets”, “username”=>“index”=>”not_analyzed”, “store”=>”no”, “id”=> “index”=>”not_analyzed”, “include_in_all”=>false, “created_at”=> “index”=>”not_analyzed”, “include_in_all”=>false}}} [6] pry(main)> index.create_mapping(“csdn”, mapping) # 2012-06-06 13:22:25:504 [CREATE MAPPING] (“index_name”) # curl -X PUT http://192.168.6.35:9400/index_name/csdn/_mapping -d ‘“csdn”:{“_source”:{“enabled”:false,”properties”:“title”:{“type”:”string”,”term_vector”:”with_positions_offsets”,”boost”:2“title”:{“type”:”string”,”term_vector”:”with_positions_offsets”,”boost”:2.0,”body”:“type”:”string”,”term_vector”:”with_positions_offsets”,”username”:“type”:”string”,”index”:”not_analyzed”,”store”:”no”,”id”:“type”:”integer”,”index”:”not_analyzed”,”include_in_all”:false,”created_at”:“type”:”integer”,”index”:”not_analyzed”,”include_in_all”:false}}}’

2012-06-06 13:22:25:505 [200]

=> true ```

查看Mapping:index.mapping(type)

``` [1] pry(main)> index = Tire.index(“index_name”) => #<Tire::Index:0x89f22cc @name=”index_name”> [2] pry(main)> index.mapping index.mapping [2] pry(main)> index.mapping(“csdn”) => {“_source”=>{“enabled”=>false, “properties”=> {“type”=>”string”, “term_vector”=>”with_positions_offsets”, “boost”=>2.0, “body”=>“term_vector”=>”with_positions_offsets”, “username”=>“index”=>”not_analyzed”, “store”=>”no”, “id”=> “index”=>”not_analyzed”, “include_in_all”=>false, “created_at”=> “index”=>”not_analyzed”, “include_in_all”=>false}}} [3] pry(main)>

```

批量提交索引数据：index.bulk(type, doc)

``` [14] pry(main)> doc = «-EOF [14] pry(main)* [ [14] pry(main)* 是好东西”,”body”:”hey java”,”id”:”1”,”username”:”jack”,”created_at”:2007072323, [14] pry(main)* java cool”,”body”:”hey java”,”id”:”2”,”created_at”:2009072323,”username”:”robbin”, [14] pry(main)* is java cool”,”body”:”hey java”,”id”:”3”,”created_at”:2010072323,”username”:”www”, [14] pry(main)* is really cool”,”body”:”hey java”,”id”:”4”,”created_at”:2007062323,”username”:”google”, [14] pry(main)* is wakak cool”,”body”:”hey java”,”id”:”5”,”created_at”:2007062323,”username”:”jackde”, [14] pry(main)* is java cool”,”body”:”hey java”,”id”:”6”,”created_at”:2007012323,”username”:”jackk wa”, [14] pry(main)* java really cool”,”body”:”hey java”,”id”:”7”,”created_at”:2002072323,”username”:”william” [14] pry(main)* ] [14] pry(main)* EOF => “[\n 是好东西","body":"hey java","id":"1","username":"jack","created_at":2007072323,\n java cool","body":"hey java","id":"2","created_at":2009072323,"username":"robbin",\n is java cool","body":"hey java","id":"3","created_at":2010072323,"username":"www",\n is really cool","body":"hey java","id":"4","created_at":2007062323,"username":"google",\n is wakak cool","body":"hey java","id":"5","created_at":2007062323,"username":"jackde",\n is java cool","body":"hey java","id":"6","created_at":2007012323,"username":"jackk wa",\n java really cool","body":"hey java","id":"7","created_at":2002072323,"username":"william"\n]\n” [15] pry(main)> hash_doc = JSON.parse doc => [是好东西”, “body”=>”hey java”, “id”=>”1”, “username”=>”jack”, “created_at”=>2007072323, java cool”, “body”=>”hey java”, “id”=>”2”, “created_at”=>2009072323, “username”=>”robbin”, is java cool”, “body”=>”hey java”, “id”=>”3”, “created_at”=>2010072323, “username”=>”www”, is really cool”, “body”=>”hey java”, “id”=>”4”, “created_at”=>2007062323, “username”=>”google”, is wakak cool”, “body”=>”hey java”, “id”=>”5”, “created_at”=>2007062323, “username”=>”jackde”, is java cool”, “body”=>”hey java”, “id”=>”6”, “created_at”=>2007012323, “username”=>”jackk wa”, java really cool”, “body”=>”hey java”, “id”=>”7”, “created_at”=>2002072323, “username”=>”william”] [16] pry(main)> index => #<Tire::Index:0xa809bd4 @name=”index_name”, @options= {“_source”=>{“enabled”=>false, “properties”=> {“type”=>”string”, “term_vector”=>”with_positions_offsets”, “boost”=>2.0, “body”=>“term_vector”=>”with_positions_offsets”, “username”=>“index”=>”not_analyzed”, “store”=>”no”, “id”=> “index”=>”not_analyzed”, “include_in_all”=>false, “created_at”=> “index”=>”not_analyzed”, “include_in_all”=>false}}}, @response=200 : “ok”:true,”acknowledged”:true> [17] pry(main)> index.bulk(“csdn”, hash_doc) # 2012-06-06 13:35:54:133 [BULK] (“index_name”) # curl -X PUT http://192.168.6.35:9400/index_name/csdn/_pulk -d ‘[是好东西”,”body”:”hey java”,”id”:”1”,”username”:”jack”,”created_at”:2007072323,java cool”,”body”:”hey java”,”id”:”2”,”created_at”:2009072323,”username”:”robbin”,is java cool”,”body”:”hey java”,”id”:”3”,”created_at”:2010072323,”username”:”www”,is really cool”,”body”:”hey java”,”id”:”4”,”created_at”:2007062323,”username”:”google”,is wakak cool”,”body”:”hey java”,”id”:”5”,”created_at”:2007062323,”username”:”jackde”,is java cool”,”body”:”hey java”,”id”:”6”,”created_at”:2007012323,”username”:”jackk wa”,java really cool”,”body”:”hey java”,”id”:”7”,”created_at”:2002072323,”username”:”william”]’

2012-06-06 13:35:54:133 [200]

=> true ```

持久化索引：index.flush

``` [2] pry(main)> index.flush # 2012-06-06 14:44:23:782 [FLUSH] (“index_name”) # curl -X PUT http://192.168.6.35:9400/index_name/_flush

2012-06-06 14:44:23:782 [200]

=> true ```

刷新索引：index.refresh

``` [3] pry(main)> index.refresh # 2012-06-06 14:44:29:085 [REFRESH] (“index_name”) # curl -X PUT http://192.168.6.35:9400/index_name/_refresh

2012-06-06 14:44:29:085 [200]

=> true ```

搜索：Tire.search(index, type, payload)

``` search = Tire.search(“bbs”, “csdn”, ‘“query”:{“text”:{“title”:”java”},”size”:10,”from”:0}’) => #<Tire::Search:0xb34e5328 @indices=[“bbs”], @path=”/bbs/csdn/_search”, @payload=”"query":{"text":{"title":"java"},"size":10,"from":0}”, @types=[“csdn”]> [28] pry(main)> search.results # 2012-06-11 14:34:37:%L [_search] ([“bbs”]) # curl -X GET http://192.168.6.35:9400/bbs/csdn/_search -d ‘“query”:{“text”:{“title”:”java”},”size”:10,”from”:0}’

2012-06-11 14:34:37:%L [200] (N/A msec)

```

统计：

``` count = Tire.count(“bbs”, “csdn”, ‘“query”:{“text”:{“title”:”java”},”size”:10,”from”:0}’) => #<Tire::Count:0xb34b2860 @indices=[“bbs”], @path=”/bbs/csdn/_count”, @payload=”"query":{"text":{"title":"java"},"size":10,"from":0}”, @types=[“csdn”]> [27] pry(main)> p count.results # 2012-06-11 15:41:05:%L [_search] ([“bbs”]) # curl -X GET http://192.168.6.35:9400/bbs/csdn/_count -d ‘“query”:{“text”:{“title”:”java”},”size”:10,”from”:0}’

2012-06-11 15:41:05:%L [200] (N/A msec)

# # { # “totalHits”: 6 # } ```

集群状态： Tire::Cluster.state Tire::Cluster.state(true)

索引列表： Tire::Cluster.index

主机信息： Tire::Cluster.host