Rails ActiveJob SQS и запись по-прежнему не существует при выполнении задания

Я использую SQS в качестве серверной части для своих ActiveJobs.

У меня есть очень простое задание, которое отправляется в очередь в обратном вызове after_create моей модели:

after_create :update_stuff_after_create

Это инициализирует ActiveJob:

UpdateStuffAfterCreateJob.perform_later(self.id)

Задание правильно отправлено в очередь SQS. Проблема в том, что когда другой экземпляр, отвечающий за чтение из очереди, пытается выполнить задание, я вижу ActiveRecord::RecordNotFound:

class UpdateStuffAfterCreateJob < ActiveJob::Base
  def perform(id)
    publisher_offer_click = MyModel.find(id) # ActiveRecord::RecordNotFound
    my_model.update_stuff
  end
end

Похоже, что запись существует в экземпляре, который отправляет задание, но запись не существует в экземпляре, который использует задание.

введите здесь описание изображения


Я отлаживал глубже, и я создал это задание:

class TestingEntityExistsJob < ActiveJob::Base
  def perform(id, exists_outside, time_outside_string)
    Rails.logger.info "[TestingEntityExistsJob] #{id}, #{MyModel.last.id}, #{Time.now.strftime("%H:%M:%S.%L")}, #{time_outside_string}, exists: #{MyModel.where(:id => publisher_offer_click_id).exists?}, exists_outside: #{exists_outside}"
  end
end

И я называю это так в after_create моей модели:

TestingEntityExistsJob.perform_later(self.id, MyModel.where(:id => self.id).exists?, Time.now.strftime('%H:%M:%S.%L'))

У меня такие странные результаты:

[2017-05-05 16:13:12.773] [TestingEntityExistsJob] 30645284, 30645284, 16:13:12.781, 16:13:12.720, exists: true, exists_outside: true
[2017-05-05 16:13:12.773] [TestingEntityExistsJob] 30645281, 30645284, 16:13:12.781, 16:13:12.659, exists: true, exists_outside: true
[2017-05-05 16:13:12.913] [TestingEntityExistsJob] 30645283, 30645284, 16:13:12.929, 16:13:12.838, exists: true, exists_outside: true
[2017-05-05 16:13:12.964] [TestingEntityExistsJob] 30645285, 30645285, 16:13:12.970, 16:13:12.927, exists: true, exists_outside: true
[2017-05-05 16:13:13.368] [TestingEntityExistsJob] 30645286, 30645285, 16:13:13.391, 16:13:13.309, exists: false, exists_outside: true
[2017-05-05 16:13:13.374] [TestingEntityExistsJob] 30645287, 30645285, 16:13:13.391, 16:13:13.339, exists: false, exists_outside: true
[2017-05-05 16:13:13.447] [TestingEntityExistsJob] 30645288, 30645288, 16:13:13.453, 16:13:13.411, exists: true, exists_outside: true
[2017-05-05 16:13:13.718] [TestingEntityExistsJob] 30645289, 30645289, 16:13:13.723, 16:13:13.658, exists: true, exists_outside: true
[2017-05-05 16:13:14.702] [TestingEntityExistsJob] 30645290, 30645290, 16:13:14.722, 16:13:14.642, exists: true, exists_outside: true
[2017-05-05 16:13:14.842] [TestingEntityExistsJob] 30645291, 30645291, 16:13:14.850, 16:13:14.789, exists: true, exists_outside: true
[2017-05-05 16:13:17.658] [TestingEntityExistsJob] 30645292, 30645292, 16:13:17.663, 16:13:17.599, exists: true, exists_outside: true
[2017-05-05 16:13:18.558] [TestingEntityExistsJob] 30645294, 30645294, 16:13:18.565, 16:13:18.513, exists: true, exists_outside: true
[2017-05-05 16:13:18.648] [TestingEntityExistsJob] 30645293, 30645294, 16:13:18.652, 16:13:18.592, exists: false, exists_outside: true
[2017-05-05 16:13:19.565] [TestingEntityExistsJob] 30645295, 30645295, 16:13:19.570, 16:13:19.514, exists: true, exists_outside: true
[2017-05-05 16:13:21.899] [TestingEntityExistsJob] 30645296, 30645295, 16:13:21.918, 16:13:21.771, exists: false, exists_outside: true
[2017-05-05 16:13:21.916] [TestingEntityExistsJob] 30645297, 30645295, 16:13:21.923, 16:13:21.832, exists: false, exists_outside: true
[2017-05-05 16:13:22.541] [TestingEntityExistsJob] 30645298, 30645298, 16:13:22.547, 16:13:22.484, exists: true, exists_outside: true
[2017-05-05 16:13:23.223] [TestingEntityExistsJob] 30645299, 30645299, 16:13:23.228, 16:13:23.171, exists: true, exists_outside: true

Вы можете видеть запись всегда exists снаружи, но не всегда внутри выполнения задания. Иногда MyModel.last.id меньше, чем id записи, которую я пытаюсь загрузить.

Любое предложение, почему это может происходить? Что я делаю не так?


person fguillen    schedule 05.05.2017    source источник
comment
Мой фактический обходной путь - это UpdateStuffAfterCreateJob.set(:wait => 2.seconds).perform_later(self.id) то, что я считал уродливым, и в этом нет необходимости: /   -  person fguillen    schedule 05.05.2017


Ответы (1)


Причина такого поведения в том, что after_create срабатывает как раз в тот момент, когда транзакция save фиксируется. Это приводит к короткому периоду, в течение которого соединение с базой данных задания не имеет доступа к записи, поскольку соединение с базой данных модели еще не зафиксировало ее.

Вы захотите использовать

after_commit :some_method, on: [:create]

вместо

after_create :some_method

https://apidock.com/rails/ActiveRecord/Transactions/ClassMethods/after_commit

person Kyle Decot    schedule 06.05.2017