私はキュー(の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
を非同期で記録すると、ここでの推奨事項はどれですか?
なぜEM-mysqlの? – fl00r
このコードの使用方法を教えていただけますか?私は一日中それを使用しようとしてきましたが、それを行うことはできませんでした。 – Eqbal