3

我已经阅读了 Tire 文档,并且知道可以使用 Tire 创建索引并将对象导入 Elasticsearch,而无需使用 ActiveModel 包含。

我想让我的模型文件完全没有任何轮胎映射,而是单独实现它们。

到目前为止,我已经为我的 Member 模型创建了一个索引对象,如下所示:

class MemberIndexer
  def initialize(member)
    @member = member
  end

  def attributes
    {
      id: @member.id,
      name: @member.full_name,
      age: @member.age,
      birthday: @member.birthday,
      type: 'member'
    }.to_json
  end

  def self.refresh_index
    Tire.index 'members' do
      delete
      create mappings: {
        member: {
          properties: {
            id: { type: 'integer' },
            name: { type: 'string', boost: 5 },
            age: { type: 'integer' },
            birthday: { type: 'date' }
          }
        }
      }

      Member.find_in_batches do |members|
        import members.map { |m| MemberIndexer.new(m).attributes }
      end
    end
  end
end

这工作正常,索引已创建,我可以正确搜索。我缺少的是可以通过使用包含的回调Tire::Model::Callbacks。是否可以使用轮胎更新索引中的单个记录而无需包含Tire::Model::Callbacks在模型本身中?

例如,如果我更新 aMember我希望能够手动更新成员索引中的相应项目。_id在不知道该项目的情况下这可能吗?

我应该只使用 ActiveRecord id 搜索对象,然后在索引上使用更新方法吗?

更新: 我对 ES 不是使用实际的 ActiveRecord id 而是通过在 ES 中生成唯一 id 来索引成员这一事实感到困惑,即使我认为我在属性 json 中传递了一个 id。

当我将 ruby​​ 哈希传递给import方法时,id 字段得到了尊重,这个问题就消失了,因为我现在可以执行以下操作来更新索引记录:

Tire.index('member') do
  store(MemberIndexer.new(@member).attributes)
end
4

3 回答 3

6

更新回调无非就是如下代码

after_save do
  update_index
end

因此,如果您要从某个地方调用 @member.update_index ,它将更新该记录的索引。

于 2013-04-18T06:53:12.860 回答
1

我不确定你_id从你发布的代码中不知道 ,是什么意思@member.id,对吧?

但是你可以像这样实现它:

def update_es_index!
  Tire.index 'members' do
    store(@member)
  end
end

它将调用store 方法,该方法将确定要发布到哪个 URL。

于 2013-04-17T23:15:37.183 回答
0

原来问题是在将 Ruby 哈希转换为 JSON 时出现了某种错误翻译。

当我将 Ruby 哈希传递给该import方法时,索引记录是使用适当的 ActiveRecord id 创建的,因此store当我想更新索引时,我可以使用包含 ActiveRecord id 的属性进行调用。

于 2013-04-19T06:29:09.473 回答