[RUBY] [Rails] Ich habe versucht, die Stapelverarbeitung mit der Rake-Task zu implementieren

Einführung

Umgebung

Rails: 5.2.3 Ruby: 2.6.3 MySQL: 5.6.40

Inhalt

• Es gibt einen Fehler, dass die Spalte "question_count" der Tabelle "users" nicht aktualisiert wird. Ich habe einen Stapel erstellt und es möglich gemacht, auf den richtigen Wert in einem Stapel zu aktualisieren. ――Wenn Sie eine vorhandene Methode verwenden, ist dies möglicherweise schwer zu verstehen, aber bitte verzeihen Sie mir.

user.rb

has_many :questions, dependent: false
has_many :only_questions_visible_to_user, -> { where(question_id: nil).visible_to_user }, class_name: 'Question', dependent: false

scope :visible_to_user, -> { where(is_invalid: false).where(deleted: false) }

def update_question_count!
  update!(question_count: count_questions)
end

private

# question_Methode zur Aggregation beim Aktualisieren der Anzahl
#
# @return [Integer]
def count_questions
  only_questions_visible_to_user.size
end

question.rb

belongs_to :user, optional: true

Code implementiert

• Ich habe versucht, das Erkennen des Fortschritts und des Aktualisierungsfehlers durch Ausgabe des Protokolls zu vereinfachen.
• Da es nur einmal ausgeführt wird und nicht mehr benötigt wird, legen Sie es im Verzeichnis one_shot ab und löschen Sie es nach der Ausführung.

lib/tasks/one_shot/update_users_question_count.rake

# frozen_string_literal: true

namespace :user do
  desc 'Update users_question_count'
  task update_question_count: :environment do |_task|
    index = 0
    updated_question_counts = 0
    user_count = User.count
    logger = Logger.new($stdout)
    logger.info 'Start'

    User.find_each do |user|
      begin
        if user.question_count != user.only_questions_visible_to_user.size
          user.update_question_count!
          updated_question_counts += 1
        end
      rescue ActiveRecord::RecordInvalid => e
        logger.info "Failed to update user_id: #{user.id}"
        logger.info("#{e.class}: #{e.message}")
        next
      end

      index += 1
      case index
      when 4000, 8000, 12_000, 16_000
        logger.info "Progress: #{index}/#{user_count}"
      end
    end
    logger.info "Updated User Count: #{updated_user_counts}"
    logger.info 'Finished'
  end
end

Stapelausführung

bundle exec rake user:update_question_count

――Das Aktualisieren von ca. 19.000 Datensätzen dauerte ca. 45 Sekunden.

• Da die Spalte, deren Aktualisierung fehlgeschlagen ist, angezeigt wird, ist es einfacher, sie separat zu behandeln.