delayed_job

Question

내가 investment가 venture 일일 전에서 investment을 가지고있는 사용자의 수의 기록을 (유지하기 위해 만들어 질 때마다 일일하여 열 (yest_shareholder_count)의 증가를 지연하기 위해 노력하고있어를 사용 증가 그래서이 데이터를 사용하여 시간이 지남에 따라 투자자의 수를 추적하는 그래프를 생성 할 수 있습니다.)

이 작업을 수행하는 가장 간단한 방법은 delayed_job이지만이 방법은 효과가 없다고 생각했습니다. delayed_job은 별도의 테이블에 만들어지고 SQLite DB Browser에 따라 하루 후 실행됩니다. 그러나 yest_shareholder_count 열이 증가하지 않습니다.

Venture 모델 :

def yest_increment 
     self.increment!(:yest_shareholder_count) 
    end 
    handle_asynchronously :yest_increment, :run_at => Proc.new {1.minute.from_now} 

Investments 컨트롤러 :

def create 
    @venture = Venture.find(params[:share_id]) 

    @venture_increment= @venture.increment(:shareholder_count) 
    @venture_yest_increment= @venture.yest_increment 

    @investment = current_user.invest!(@venture) 

    if @venture_increment.save and @venture_yest_increment.save 
    respond_to do |format| 
     format.html {redirect_to @venture} 
      end 
    end 

    end 

똑 바른 증가가 일어난다는해야하지만, 지연 증가가하는 적이있다.

이

은 유용 단지 경우, delayed_jobs 테이블에서 "처리기"칼럼의 내용은 다음과 같습니다

--- !ruby/struct:Delayed::PerformableMethod 
object: !ruby/ActiveRecord:Venture 
    attributes: 
    created_at: 2011-06-21 07:00:12.252808 
    onemth_shareholder_count: 0 
    updated_at: 2011-08-09 16:50:36.864354 
    onewk_shareholder_count: 0 
    shareholder_count: 4 
    id: 49 
    user_id: 40 
    yest_shareholder_count: 0 
method_name: :yest_increment_without_delay 
args: [] 

나는 "yest_increment_without_delay"가 "에서 오는, 또는 왜 위치를 잘 모르겠어요 args "가 비어 있습니다.

도움을 주시면 감사하겠습니다.

편집 : 코드를 테스트하기 위해 "1.day.from_now"가 아닌 "1.minute.from_now"가 있습니다.

Answer 1

지연된 작업을 사용하여 비동기 적으로 처리 할 메서드를 정의하면 지연된 작업이 별칭 메서드 체인을 만듭니다 (익숙하지 않음). 지연된 작업에 의해 처리되는 원래의 메소드 이름을 호출하고, 지연된 작업이 주변에 도착하면 original_method_name_without_delay를 호출합니다.이 메소드는 별명이있는 실제 객체 메소드입니다.

yest_increment에 인수를 전달하지 않았으므로 인수가 없습니다. yest_increment에 인수를 전달하면 작업과 함께 저장되어 지연된 작업이 실제 메소드를 호출 할 때 실제 메소드로 전달됩니다.

테이블의 개체는 개체의 serialize 된 버전이고, delayed_job은 db에 저장됩니다. 작업을 실행해야 할 때이를 역 직렬화하여 객체를 만들고 주어진 인자를 가진 메소드를 호출합니다. 객체가 ActiveRecord 객체이기 때문에 직렬화가 필요하지 않습니다. 직렬화 된 객체에서 ID를 검색하고 데이터베이스에서 객체를 찾는 것입니다.

실제 문제로 그것이 작동하지 않는다면 작동하지 않는 것이 명확하지 않습니다. 지연된 작업이 호출되지 않거나 값이 증가하지 않거나 delayed_job이 너무 빨리 호출됩니다. 마지막 코드 인 경우 다음 코드를 변경하면 도움이 될 수 있습니다.

handle_asynchronously :yest_increment, :run_at => Proc.new {Time.now.beginning_of_day + 1.day}