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併發問題

回答

相關問題