3

나는 큐 (rabbitmq)에서 데이터를 가지고 어떤 노동자가 나는 액티브 비동기 적으로 사용 기록을 작성하려는 노동자 내부, 내 현재의 구현 뭔가 같다 : I 실행할액티브 실행 비동기

require "rubygems" 
require "amqp" 
require 'eventmachine' 
require 'em-http' 

AMQP.start(:host => $AMQP_URL) do |connection| 
    @queue ||= AMQP::Channel.new(connection).queue("results") 

    @queue.subscribe do |body|    
    EventMachine::HttpRequest.new('http://someurl').post :body => {:message => body }  
    Record.create!(:name => body) 
    end 
end 

비동기 방식으로 기록 여기에, 어떤 권고 성능을 BOST하는?

+0

를? – fl00r

+0

이 코드의 사용법을 알려주시겠습니까? 난 하루 종일 그것을 사용하려고 노력했지만 그렇게 할 수 없었어요 – Eqbal

답변

0

당신은 delayed_job에서 살펴 봐야 할 수 있습니다 : 왜 EM-mysql을하지

https://github.com/collectiveidea/delayed_job

+1

그것은 작업자와 내가 그것을 찾고있는 병렬 시스템에서 쿼리를 삽입하는 메커니즘입니다, 나는 rabbitmq를 사용하고 있습니다 이미 레일즈를 사용하고 있지는 않습니다. 단지 루비 프로세스와 활성 레코드입니다. – Eqbal

관련 문제