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]

=> [{"host"=>"127.0.0.1:9400", "index"=>"index_name", "shardId"=>0},
 {"host"=>"127.0.0.1:9500", "index"=>"index_name", "shardId"=>1},
 {"host"=>"127.0.0.1:9400", "index"=>"index_name", "shardId"=>2},
 {"host"=>"127.0.0.1:9500", "index"=>"index_name", "shardId"=>3},
 {"host"=>"127.0.0.1:9400", "index"=>"index_name", "shardId"=>4},
 {"host"=>"127.0.0.1:9500", "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 = {"csdn"=>
[4] pry(main)*   {"_source"=>{"enabled"=>false},
[4] pry(main)*     "properties"=>
[4] pry(main)*     {"title"=>
[4] pry(main)*       {"type"=>"string",
[4] pry(main)*         "term_vector"=>"with_positions_offsets",
[4] pry(main)*       "boost"=>2.0},
[4] pry(main)*       "body"=>{"type"=>"string", "term_vector"=>"with_positions_offsets"},
[4] pry(main)*       "username"=>{"type"=>"string", "index"=>"not_analyzed", "store"=>"no"},
[4] pry(main)*       "id"=>
[4] pry(main)*       {"type"=>"integer", "index"=>"not_analyzed", "include_in_all"=>false},
[4] pry(main)*       "created_at"=>
[4] pry(main)* {"type"=>"integer", "index"=>"not_analyzed", "include_in_all"=>false}}}}
=> {"csdn"=>
  {"_source"=>{"enabled"=>false},
   "properties"=>
    {"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}}}}
[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.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")
=> {"csdn"=>
  {"_source"=>{"enabled"=>false},
   "properties"=>
    {"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}}}}
[3] pry(main)>

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

[14] pry(main)> doc = <<-EOF
[14] pry(main)* [
[14] pry(main)*   {"title":"java 是好东西","body":"hey java","id":"1","username":"jack","created_at":2007072323},
[14] pry(main)*   {"title":"this java cool","body":"hey java","id":"2","created_at":2009072323,"username":"robbin"},
[14] pry(main)*   {"title":"this is java cool","body":"hey java","id":"3","created_at":2010072323,"username":"www"},
[14] pry(main)*   {"title":"java is really cool","body":"hey java","id":"4","created_at":2007062323,"username":"google"},
[14] pry(main)*   {"title":"this is wakak cool","body":"hey java","id":"5","created_at":2007062323,"username":"jackde"},
[14] pry(main)*   {"title":"this is java cool","body":"hey java","id":"6","created_at":2007012323,"username":"jackk wa"},
[14] pry(main)*   {"title":"this java really cool","body":"hey java","id":"7","created_at":2002072323,"username":"william"}
[14] pry(main)* ]
[14] pry(main)* EOF
=> "[\n  {\"title\":\"java 是好东西\",\"body\":\"hey java\",\"id\":\"1\",\"username\":\"jack\",\"created_at\":2007072323},\n  {\"title\":\"this java cool\",\"body\":\"hey java\",\"id\":\"2\",\"created_at\":2009072323,\"username\":\"robbin\"},\n  {\"title\":\"this is java cool\",\"body\":\"hey java\",\"id\":\"3\",\"created_at\":2010072323,\"username\":\"www\"},\n  {\"title\":\"java is really cool\",\"body\":\"hey java\",\"id\":\"4\",\"created_at\":2007062323,\"username\":\"google\"},\n  {\"title\":\"this is wakak cool\",\"body\":\"hey java\",\"id\":\"5\",\"created_at\":2007062323,\"username\":\"jackde\"},\n  {\"title\":\"this is java cool\",\"body\":\"hey java\",\"id\":\"6\",\"created_at\":2007012323,\"username\":\"jackk wa\"},\n  {\"title\":\"this java really cool\",\"body\":\"hey java\",\"id\":\"7\",\"created_at\":2002072323,\"username\":\"william\"}\n]\n"
[15] pry(main)> hash_doc = JSON.parse doc
=> [{"title"=>"java 是好东西",
  "body"=>"hey java",
  "id"=>"1",
  "username"=>"jack",
  "created_at"=>2007072323},
 {"title"=>"this java cool",
  "body"=>"hey java",
  "id"=>"2",
  "created_at"=>2009072323,
  "username"=>"robbin"},
 {"title"=>"this is java cool",
  "body"=>"hey java",
  "id"=>"3",
  "created_at"=>2010072323,
  "username"=>"www"},
 {"title"=>"java is really cool",
  "body"=>"hey java",
  "id"=>"4",
  "created_at"=>2007062323,
  "username"=>"google"},
 {"title"=>"this is wakak cool",
  "body"=>"hey java",
  "id"=>"5",
  "created_at"=>2007062323,
  "username"=>"jackde"},
 {"title"=>"this is java cool",
  "body"=>"hey java",
  "id"=>"6",
  "created_at"=>2007012323,
  "username"=>"jackk wa"},
 {"title"=>"this java really cool",
  "body"=>"hey java",
  "id"=>"7",
  "created_at"=>2002072323,
  "username"=>"william"}]
[16] pry(main)> index
=> #<Tire::Index:0xa809bd4
 @name="index_name",
 @options=
  {"csdn"=>
    {"_source"=>{"enabled"=>false},
     "properties"=>
      {"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}}}},
 @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 '[{"title":"java 是好东西","body":"hey java","id":"1","username":"jack","created_at":2007072323},{"title":"this java cool","body":"hey java","id":"2","created_at":2009072323,"username":"robbin"},{"title":"this is java cool","body":"hey java","id":"3","created_at":2010072323,"username":"www"},{"title":"java is really cool","body":"hey java","id":"4","created_at":2007062323,"username":"google"},{"title":"this is wakak cool","body":"hey java","id":"5","created_at":2007062323,"username":"jackde"},{"title":"this is java cool","body":"hey java","id":"6","created_at":2007012323,"username":"jackk wa"},{"title":"this 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

Name		Name	Last commit message	Last commit date
Latest commit History 652 Commits
examples		examples
lib		lib
test		test
.gitignore		.gitignore
.travis.yml		.travis.yml
Gemfile		Gemfile
MIT-LICENSE		MIT-LICENSE
README.markdown		README.markdown
Rakefile		Rakefile
tire.gemspec		tire.gemspec

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Repository files navigation

Tire

Usage

About

Releases

Packages

Languages

License

csdn-dev/tire

Folders and files

Latest commit

History

Repository files navigation

Tire

Usage

About

Resources

License

Stars

Watchers

Forks

Releases

Packages 0

Languages

Packages