Ruby Mongo或Mongoid并发问题

我有我认为必须是并发问题。我使用乘客，铁轨2.3.5，mongoid 1.9.2和mongo红宝石驱动程序1.0.9。我使用jQuery来请求从MongoDB中提取并在浏览器中呈现的数据。在我开始同时提出两个这样的请求之前，一切都很好。在模型中，这些都是得到由请求执行的方法：Ruby Mongo或Mongoid并发问题

Class Visit 
    include Mongoid::Document 
    ... 
    def self.cancellations_and_visits_by_therapist_graph(clinic_id) 
    visits = collection.group("function(x){ return { resource_id : x.resource_id } }", 
      {:clinic_id => clinic_id, :visit_date => { "$gte" => Time.now - 6.months, "$lte" => Time.now}}, 
      {:visits => 0, :cancel_no_shows => 0}, 
      'function(obj, count) { 
       if (obj.visit_status == "NO SHOW" || obj.visits_status == "CANCELLED") { 
       count.cancel_no_shows += 1; 
       } else { 
       count.visits += 1; 
       } 

      }') 

    visits = visits.group_by {|g| g['resource_id']} 

    Resource.any_in(:mysql_id => visits.keys).order_by([:last_name, :asc]).order_by([:first_name, :asc]).inject({ 'visits' => [], 'cancel_no_shows' => [], 'xlabels' => []}) do |formatted_visits, resource| 
     formatted_visits['visits'] << visits[resource.mysql_id.to_f].first['visits'] 
     formatted_visits['cancel_no_shows'] << visits[resource.mysql_id.to_f].first['cancel_no_shows'] 
     formatted_visits['xlabels'] << resource.last_name + ", " + resource.first_name 
     formatted_visits 
    end 
    end 



    def self.total_visits_for_graph(practice_id) 
    visits = collection.group("function(x) { return { clinic_id : x.clinic_id } }", 
          {:practice_id => practice_id, :visit_status => 'COMPLETE', :visit_date => { "$gte" => Time.now - 6.months, "$lte" => Time.now}}, 
          {:visits => 0}, "function(obj, count) { count.visits += 1; }") 

    visits = visits.group_by {|g| g['clinic_id']} 
    Clinic.any_in(:mysql_id => visits.keys).order_by([:name, :asc]).inject({ 'data' => [], 'xlabels' => []}) do |formatted_visits, clinic| 
     formatted_visits['data'] << visits[clinic.mysql_id.to_f].first['visits'] 
     formatted_visits['xlabels'] << clinic.name 
     formatted_visits 
    end 
    end 
end

说明问题的最好办法是，从Mongo的结果获得通过给错了对象。我lookated这样一个例子：

这是我打电话时CLinic.any_in返回（它是从所述组中的一个的结果）：

{"group"=>{"$keyf"=>"function(x){ return { resource_id : x.resource_id } }", "cond"=>{:clinic_id=>101, :visit_date=>{"$gte"=>Tue Apr 20 15:34:37 +0800 2010, "$lte"=>Wed Oct 20 15:34:37 +0800 2010}}, "ns"=>"visits", "initial"=>{:visits=>0, :cancel_no_shows=>0}, "$reduce"=>"function(obj, count) {\n    if (obj.visit_status == \"NO SHOW\" || obj.visits_status == \"CANCELLED\") {\n    count.cancel_no_shows += 1;\n    } else {\n    count.visits += 1;\n    }\n\n   }"}}

这（一个诊所对象）中的溶液由所述收集返回.group呼叫：

{"_id"=>BSON::ObjectId('4cb7d72b3bc5457800ce2e6f'), "name"=>"Corona", "practice_id"=>39, "mysql_id"=>101}

与所有良好的结核病问题一样，结果是随机的，有时它可以正常工作，有时会爆炸。我是mongo和mongoid的新手，所以我实际上不确定这是mongoid还是mongo驱动程序的问题，但我认为它与Mongoid有关。我包含了我用来在rails中加载Mongoid的初始化程序。任何想法，甚至只是额外的调试想法，都非常感谢。

连接

mongoid_conf = YAML::load_file(Rails.root.join('config/mongoid.yml'))[Rails.env] 

Mongoid.configure do |config| 
    config.master = Mongo::Connection.new(mongoid_conf['host'], 27017, :pool_size => 5, :timeout => 5).db(mongoid_conf['database']) 
end

来源

2010-10-20 Josh Moore

我找到了解决这个问题。这实际上不是Mongo车手或Mongoid车手，而是乘客。当Passenger跨越rails过程时，它会分叉当前实例，以便文件描述符（包括TCP描述符在应用程序实例之间共享）。这意味着mongo正在被同一个套接字写入和读取，这导致了并发问题。解决方案是让Mongo在分叉时重新连接。这是我找到了解决办法：对于原来的答案张贴和讨论

# Handle the creation of new processes by Phusion Passenger 
if defined?(PhusionPassenger) 
    PhusionPassenger.on_event(:starting_worker_process) do |forked| 
    if forked 
     # We're in smart spawning mode. 

     # Reset the connection to MongoDB 
     Mongoid.config.master.connection.close 
     load File.join(RAILS_ROOT, 'config/initializers/mongoid_init.rb') 
    else 
     # We're in conservative spawning mode. We don't need to do anything.  
    end 
    end 
end

参考http://groups.google.com/group/mongodb-user/browse_thread/thread/f31e2d23de38136a。

来源

2010-10-22 01:55:41

Ruby Mongo或Mongoid并发问题

回答

相关问题