当我尝试从模型内部重新索引记录时,它最终会在elasticsearch服务器上设置一个空索引.
所以,我有一个课程模型,其中有许多教师.
现在,我在instructor.rb模型中有这个回调方法,它在Instructor上更新某些内容时会尝试重新索引.
class Instructor < ActiveRecord::Base
belongs_to :teacher,:class_name => "User",:foreign_key => "user_id"
belongs_to :instructorable,polymorphic: true
after_commit :reindex_course
private
def reindex_course
Course.reindex_course
end
end
course.rb模型看起来像这样：
class Course < ActiveRecord::Base
has_many :instructors,as: :instructorable,dependent: :destroy
searchkick word_start: [ :name,:description,:instructor_name]
def search_data
{
name: name,description: description,searchable: searchable,}.merge(
instructor_name: instructors.includes(:teacher).pluck(:'users.name').reject(&:nil?),institute_id: creator.try(:institute_id)
)
def self.reindex_course
index = Course.reindex(async: true,refresh_interval: "5s")
Course.search_index.promote(index[:index_name],update_refresh_interval: true)
Course.search_index.clean_indices
end
end
创建新教师可以重新编制记录索引
Instructor.create(user_id: 4009,instructorable_id: 4792,instructorable_type:"ScheduledCourse")
ETHON: performed EASY effective_url=http://xx:xx@xxx.xx.xx.xxx/elasticsearch/_aliases response_code=200 return_code=ok total_time=0.630504
ETHON: performed EASY effective_url=http://xx:xx@xxx.xx.xx.xxx/elasticsearch/courses_development_20171204162604885 response_code=200 return_code=ok total_time=0.922072
ETHON: performed EASY effective_url=http://xx:xx@xxx.xx.xx.xxx/elasticsearch/_alias/courses_development response_code=200 return_code=ok total_time=0.29790799999999995
(5.0ms) SELECT MIN("courses"."id") FROM "courses" LEFT OUTER JOIN "users" ON "users"."id" = "courses"."creator_id" LEFT OUTER JOIN "units" ON "units"."course_id" = "courses"."id" LEFT OUTER JOIN "instructors" ON "instructors"."instructorable_id" = "courses"."id" AND "instructors"."instructorable_type" = $1 [["instructorable_type","Course"]]
(4.4ms) SELECT MAX("courses"."id") FROM "courses" LEFT OUTER JOIN "users" ON "users"."id" = "courses"."creator_id" LEFT OUTER JOIN "units" ON "units"."course_id" = "courses"."id" LEFT OUTER JOIN "instructors" ON "instructors"."instructorable_id" = "courses"."id" AND "instructors"."instructorable_type" = $1 [["instructorable_type","Course"]]
Enqueued Searchkick::BulkReindexJob (Job ID: d710eff3-5e39-4347-b02a-5459bfd4b1be) to Sidekiq(searchkick) with arguments: {:class_name=>"Course",:index_name=>"courses_development_20171204162604885",:batch_id=>1,:min_id=>2,:max_id=>1001}
Enqueued Searchkick::BulkReindexJob (Job ID: f0bf5866-f3da-42dd-9132-2de23735fbf4) to Sidekiq(searchkick) with arguments: {:class_name=>"Course",:batch_id=>2,:min_id=>1002,:max_id=>2001}
Enqueued Searchkick::BulkReindexJob (Job ID: 348e07b8-a85a-4a9f-a2f2-d2b70416d2bf) to Sidekiq(searchkick) with arguments: {:class_name=>"Course",:batch_id=>3,:min_id=>2002,:max_id=>3001}
Enqueued Searchkick::BulkReindexJob (Job ID: e40f2a33-e2f7-4f77-9416-920d84e285e7) to Sidekiq(searchkick) with arguments: {:class_name=>"Course",:batch_id=>4,:min_id=>3002,:max_id=>4001}
Enqueued Searchkick::BulkReindexJob (Job ID: 18b357c1-cd53-4836-8aaf-4c97dde56281) to Sidekiq(searchkick) with arguments: {:class_name=>"Course",:batch_id=>5,:min_id=>4002,:max_id=>5001}
ETHON: performed EASY effective_url=http://xx:xx@xxx.xx.xx.xxx/elasticsearch/courses_development_20171204162604885/_settings response_code=200 return_code=ok total_time=0.372641
ETHON: performed EASY effective_url=http://xx:xx@xxx.xx.xx.xxx/elasticsearch/_alias/courses_development response_code=200 return_code=ok total_time=0.333225
ETHON: performed EASY effective_url=http://xx:xx@xxx.xx.xx.xxx/elasticsearch/_aliases response_code=200 return_code=ok total_time=0.42405099999999996
ETHON: performed EASY effective_url=http://xx:xx@xxx.xx.xx.xxx/elasticsearch/_aliases response_code=200 return_code=ok total_time=0.382619
ETHON: performed EASY effective_url=http://xx:xx@xxx.xx.xx.xxx/elasticsearch/courses_development_20171204162504480 response_code=200 return_code=ok total_time=0.408705
现在,当我运行此查询时：
Searchkick.search search_params[:search],operator: "or",index_name: [Course],where:{institute_id: institute_id,searchable: true},fields: ['name^100','instructor_name^100','description^50'],match: :word_start,misspellings: {edit_distance: 2},page: search_params[:page],per_page: 20,order: {_score: :desc}
我得到一个空的回复：
ETHON: performed EASY effective_url=http://xx:xxxx@xy.xyz.xx.xyz/elasticsearch/courses_development/_search response_code=200 return_code=ok total_time=0.733799
Search (738.0ms) curl http://xx.xxx.xx.xxx:80/courses_development/_search?pretty -d '{"query":{"bool":{"must":{"dis_max":{"queries":[{"bool":{"must":{"bool":{"should":[{"match":{"name.word_start":{"query":"Elasticsearch","boost":1000.0,"operator":"or","analyzer":"searchkick_word_search"}}},{"match":{"name.word_start":{"query":"Elasticsearch","boost":100.0,"analyzer":"searchkick_word_search","fuzziness":2,"prefix_length":0,"max_expansions":3,"fuzzy_transpositions":true}}}]}},"should":{"match":{"name.analyzed":{"query":"Elasticsearch","analyzer":"searchkick_word_search"}}}}},{"bool":{"must":{"bool":{"should":[{"match":{"instructor_name.word_start":{"query":"Elasticsearch",{"match":{"instructor_name.word_start":{"query":"Elasticsearch","should":{"match":{"instructor_name.analyzed":{"query":"Elasticsearch",{"bool":{"must":{"bool":{"should":[{"match":{"description.word_start":{"query":"Elasticsearch","boost":500.0,{"match":{"description.word_start":{"query":"Elasticsearch","boost":50.0,"should":{"match":{"description.analyzed":{"query":"Elasticsearch","analyzer":"searchkick_word_search"}}}}}]}},"filter":[{"term":{"institute_id":113}},{"term":{"searchable":true}}]}},"size":1000,"from":0,"timeout":"11s","_source":false}'
=> #<Searchkick::Results:0x007fcb8c9cb378
@klass=nil,@options=
{:page=>1,:per_page=>1000,:padding=>0,:load=>true,:includes=>nil,:model_includes=>nil,:json=>false,:match_suffix=>:word_start,:highlighted_fields=>[],:misspellings=>true},@response=
{"took"=>1,"timed_out"=>false,"_shards"=>{"total"=>5,"successful"=>5,"skipped"=>0,"Failed"=>0},"hits"=>{"total"=>0,"max_score"=>nil,"hits"=>[]}}>
但是,当我运行Course.reindex(来自控制台或模型)或RAILS_ENV =开发包exec rake searchkick：reindex CLASS = Course –trace form terminal它再次开始工作.
[33] pry(main)> Searchkick.search "Elasticsearch",where:{institute_id: 113,misspellings: {edit_distance: 2}
ETHON: performed EASY effective_url=http://xx:xx@xxx.xx.xx.xxx/elasticsearch/courses_development/_search response_code=200 return_code=ok total_time=0.57072
Search (573.5ms) curl http://xxx.xx.xx.xxx:80/courses_development/_search?pretty -d '{"query":{"bool":{"must":{"dis_max":{"queries":[{"bool":{"must":{"bool":{"should":[{"match":{"name.word_start":{"query":"Elasticsearch","filter":[{"term":{"institute_id":113}}]}},"_source":false}'
=> #<Searchkick::Results:0x007fcb8f2893a0
@klass=nil,@response=
{"took"=>32,"hits"=>
{"total"=>2,"max_score"=>19030.512,"hits"=>
[{"_index"=>"courses_development_20171204170257200","_type"=>"course","_id"=>"4792","_score"=>19030.512},{"_index"=>"courses_development_20171204170257200","_id"=>"4782","_score"=>14400.825}]}}>