Railsはグループごとに上位nレコード（メモリリーク）

Question

を選択し、私はそれは限られたレコードを持つローカル環境で正常に働いている各ソース

def latest_results 
    Entry.find_by_sql([" 
    select x.id,x.created_at,x.updated_at,x.source_id,x.`data`,x.`uuid`,x.source_entry_id 
    from 
     (select t.*, 
     (@num:=if(@group = `source_id`, @num +1, if(@group := `source_id`, 1, 1))) row_number 
      from (
     select d.id,d.created_at,d.updated_at,d.source_id,d.`data`,d.`uuid`,d.source_entry_id 
     from `streams` a 
     JOIN `stream_filters` b 
     on b.stream_id=a.id 
     JOIN `filter_results` c 
     on c.filter_id=b.id 
     JOIN `entries` d 
     on d.id=c.entry_id 
     where a.id=? 
     ) t 
     order by `source_id`,created_at desc 
    ) as x 
     where x.row_number <= 10 
     ORDER BY x.created_at DESC 
    ",self.id]) 
    end 

の10件の最新のレコードを返すですfind_by_sqlを使用してこの方法を持っています。 私はアプリケーションにサービスするために2つのGibメモリを持つt2.microを持っています。今私の全体のメモリとアプリを実行しているこのクエリは、frizzing得る。 提案はどうすればよいですか？私はマシンのサイズを増やすことなくこれを解決したい。

Answer 1

私は一度同様の問題がありました。 mysql変数を使用したソリューションは最初はきちんとしているようですが、最適化するのは難しいです。それはあなたのケースで完全なテーブルスキャンを行っているようです。

最初に表示するソースを取得することをお勧めします。次に、ソースごとに1つずつ、上位10の選択肢が複数あり、すべてが共用体と結合された2番目の問合せを実行します。

組合のトップ10には、あなたが簡単にルビーを自動生成することができますいくつかのrepetiveステートメントを持つことになります選択します。

# pseudo code 
sources = Entry.group(:source).limit(n) 
sql = sources.map do |source| 
    "select * from entries where source = #{source} order by created_at limit 10" 
end.join("\nunion all\n") 

Entry.find_by_sql(sql)