如何在Chewy的update_index执行完成后运行指定代码块？

解决方案思路 #

针对Chewy索引完成后执行代码的需求，根据你的索引同步/异步配置，提供以下几种可靠方案：

方案一：利用Chewy索引类的after_save回调（推荐，支持同步/异步场景）

直接在Chewy索引类中绑定索引完成后的回调，确保代码在记录被成功索引后执行：

# app/chewy/users_index.rb
class UsersIndex < Chewy::Index
  define_type User do
    # 这里添加你的字段映射配置
    field :name, type: 'text'
    field :email, type: 'keyword'

    # 索引保存完成后触发
    after_save do |user|
      # 仅对新创建的记录执行逻辑
      user.run_this_block if user.previous_changes.include?(:id)
    end
  end
end

# app/models/user.rb
class User < ApplicationRecord
  update_index('USER') { self }

  def run_this_block
    index = UsersIndex.find id
    # 这里编写你需要执行的业务逻辑
  end
end

方案二：调整Rails回调顺序（适用于同步索引场景）

如果你的Chewy配置为同步索引（默认），可以通过显式设置回调顺序，让你的代码在Chewy的索引回调之后执行：

class User < ApplicationRecord
  update_index('USER') { self }

  # 仅在同步模式下执行，避免异步场景下找不到索引
  set_callback :commit, :after, :run_this_block, on: :create, unless: -> { Chewy.async? }

  def run_this_block
    index = UsersIndex.find id
    # 这里编写你需要执行的业务逻辑
  end
end

方案三：自定义异步索引Job（适用于异步索引场景）

如果使用了Chewy的异步索引（比如结合Sidekiq），可以自定义导入Job，在索引任务完成后触发代码：

# app/jobs/custom_chewy_import_job.rb
class CustomChewyImportJob < Chewy::Index::ImportJob
  after_perform do |job|
    index_name, objects, _options = job.arguments
    # 仅处理USER索引的记录
    return unless index_name == 'USER'

    objects.each do |user|
      # 仅对新创建的用户执行逻辑
      user.run_this_block if user.is_a?(User) && user.previous_changes.key?(:id)
    end
  end
end

# config/initializers/chewy.rb
Chewy.configure do |config|
  config.async = CustomChewyImportJob
end

# app/models/user.rb
class User < ApplicationRecord
  update_index('USER') { self }

  def run_this_block
    index = UsersIndex.find id
    # 这里编写你需要执行的业务逻辑
  end
end

内容的提问来源于stack exchange，提问作者Farid Anooshehpour