This repository has been archived on 2024-07-22. You can view files and clone it, but cannot push or open issues or pull requests.
2022-05-22 13:16:43 -07:00
|
|
|
# frozen_string_literal: true
|
|
|
|
|
|
|
|
class Importer::AccountsIndexImporter < Importer::BaseImporter
|
|
|
|
def import!
|
|
|
|
scope.includes(:account_stat).find_in_batches(batch_size: @batch_size) do |tmp|
|
|
|
|
in_work_unit(tmp) do |accounts|
|
2023-08-31 10:04:27 -07:00
|
|
|
bulk = build_bulk_body(accounts)
|
2022-05-22 13:16:43 -07:00
|
|
|
|
2023-08-31 10:04:27 -07:00
|
|
|
indexed = bulk.size
|
|
|
|
deleted = 0
|
2022-05-22 13:16:43 -07:00
|
|
|
|
|
|
|
Chewy::Index::Import::BulkRequest.new(index).perform(bulk)
|
|
|
|
|
|
|
|
[indexed, deleted]
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
wait!
|
|
|
|
end
|
|
|
|
|
|
|
|
private
|
|
|
|
|
|
|
|
def index
|
|
|
|
AccountsIndex
|
|
|
|
end
|
|
|
|
|
|
|
|
def scope
|
|
|
|
Account.searchable
|
|
|
|
end
|
|
|
|
end
|