3

我正在构建一个应用程序，有时我需要将 fb 中的一堆数据与我的数据库同步，所以我（尝试）使用延迟作业将其推送到后台。这是我的延迟作业课程的一部分。

class FbSyncJob < Struct.new(:user_id)
  require 'RsvpHelper'

  def perform
    user = User.find(user_id)
    FbSyncJob.sync_user(user)
  end

  def FbSyncJob.sync_user(user)
    friends = HTTParty.get(
      "https://graph.facebook.com/me/friends?access_token=#{user.fb['token']}"
    )
    friends_list = friends["data"].map { |friend| friend["id"] }
    user.fb["friends"] = friends_list
    user.fb["sync"]["friends"] = Time.now
    user.save!
    FbSyncJob.friend_crawl(user)
  end
end

随着RsvpHelper班级生活lib/RsvpHelper.rb。因此，在我的应用程序的某个时刻，我Delayed::Job.enqueue(FbSyncJob.new(user.id))与一个已知的有效用户通话。我设置的工人甚至告诉我工作已经成功完成：

1 jobs processed at 37.1777 j/s, 0 failed

但是，当我检查数据库中的用户时，他的朋友列表没有更新。我做错了什么还是什么？非常感谢您的帮助，这让我发疯了。

4

1 回答 1

6

Delayed::Job.enqueue会在延迟的作业表中放一条记录，但是需要运行一个单独的进程来执行作业代码（perform方法）

通常在开发中是这样bundle exec rake jobs:work（注意：您必须在每次更改代码时重新启动此 rake 任务，它不会自动加载更改）

我通常在开发时将以下内容放入我的延迟配置中 - 这永远不会在延迟作业表中放置记录并同步运行所有后台代码（在开发中），默认情况下，rails 将重新加载对代码的更改

Delayed::Worker.delay_jobs = !(Rails.env.test? || Rails.env.development?)

于 2013-03-13T19:29:07.143 回答