ruby-on-rails – 从模型重建索引后,Searchkick索引为空

当我尝试从模型内部重新索引记录时,它最终会在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}]}}>

解决方法

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

看起来在最后一行调用Course.search_index.clean_indices会清理旧索引.我想你可能想在第一行调用它,或者根本不调用它.

ruby-on-rails – 从模型重建索引后,Searchkick索引为空

解决方法

猜你在找的Ruby相关文章