3

私はキュー(のRabbitMQ)からデータを取り、いくつかの労働者を持っていると私はActiveRecordを非同期的に使用してレコードを作成する作業員の内部で、私の現在の実装では、何かのようなものです:私は実行したいのActiveRecordを実行する非同期

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 

を非同期で記録すると、ここでの推奨事項はどれですか?

+0

なぜEM-mysqlの? – fl00r

+0

このコードの使用方法を教えていただけますか?私は一日中それを使用しようとしてきましたが、それを行うことはできませんでした。 – Eqbal

答えて

0

あなたはdelayed_jobを見てみたいことがあります。

https://github.com/collectiveidea/delayed_job

+1

それは私が探しているのはワーカーとキューイングシステムです。並列にクエリを挿入するメカニズムです。私はrabbitmqを使用していますすでに私はここでレールを使用していません、ただルビープロセスとアクティブレコード – Eqbal

関連する問題