【Redis】EC2インスタンスからElastiCacheにアクセスできない

Question

AWSを利用して、ブログのようなサービスを公開しました。
その中で、記事のランキングを作成したいと思い、ElastiCacheを利用し、redisで記事のpvのカウントをとったり、それを用いてランキングを生成していたりします。

こちらの記事を参考に、ElastiCacheの設定を行いました。

①ローカル環境では問題なく動いていた。
②EC2からredis-cli -h "endpoint"というコマンドを実行すると、コマンドが問題なく

redis ”endpoint”:6379>

という状態になる。

問題は、redisが絡んでくる以下の、①アクセスログを記録する②記録したログを使い人気記事リストを生成する部分が絡んでくるリクエストでエラーになるという事です。

▼エラーログ

F, [2017-03-29T22:32:02.418576 #6652] FATAL -- :   
F, [2017-03-29T22:32:02.418608 #6652] FATAL -- : Redis::CannotConnectError (Error connecting to Redis on 127.0.0.1:6379 (Errno::ECONNREFUSED)):
F, [2017-03-29T22:32:02.418628 #6652] FATAL -- :   
F, [2017-03-29T22:32:02.418646 #6652] FATAL -- : app/controllers/services/articles_controller.rb:96:in `show'

①articles_controller showアクションでアクセスログを記録

include SetRanking
def show
# redisに該当記事のアクセス数を挿入
    REDIS.multi do
      # 1)総合ランキング用
      REDIS.zincrby "articles/daily/#{Date.today.to_s}", 1, @article.id
      REDIS.expire( "articles/daily/#{Date.today.to_s}", 172800)
      # 2)カテゴリランキング用
      REDIS.zincrby "#{@article.category_id}/articles/daily/#{Date.today.to_s}", 1, @article.id
      REDIS.expire( "#{@article.category_id}/articles/daily/#{Date.today.to_s}", 172800)
    end
end

②記事一覧画面などで人気ランキングを取得する際に利用するモジュール set_ranking.rb

module SetRanking

  def set_overall_daily_ranking

    ids = REDIS.zrevrangebyscore "articles/daily/#{Date.yesterday.to_s}", "+inf", 0, limit: [0, 20]

    @ranking_articles = ids.map { |id| Article
                                             .includes(:admin, :category)
                                             .active
                                             .published
                                             .find_by(id:id)}

    if @ranking_articles.count < 20
      adding_articles = Article
                              .includes(:admin, :category)
                              .active
                              .published
                              .parts_exists
                              .order(created_at: :DESC, updated_at: :DESC)
                              .where.not(id: ids)
                              .limit(20 - @ranking_articles.count)

      @ranking_articles.concat(adding_articles)
    end
  end

  def set_category_daily_ranking(category_id)

    ids = REDIS.zrevrangebyscore "#{category_id}/articles/daily/#{Date.yesterday.to_s}", "+inf", 0, limit: [0, 20]

    @ranking_articles = ids.map{ |id| Article
                                          .includes(:admin, :category)
                                          .active
                                          .published.
                                          find_by(id:id) }

    if @ranking_articles.count < 20
      adding_articles = Article
                             .includes(:admin, :category)
                             .active
                             .published
                             .parts_exists
                             .category(category_id)
                             .order(created_at: :DESC, updated_at: :DESC)
                             .where.not(id: ids)
                             .limit(20 - @ranking_articles.count)

      @ranking_articles.concat(adding_articles)
    end
  end

end

これは、上記の箇所の書き方の問題なのでしょうか？
でもその場合、なぜ開発環境（vagrant）だと上手くいっているのか分かりません。。。
また、redis関連の設定は以下になっています。

redis.rb

require 'redis'

uri = URI.parse(ENV["REDIS"])
REDIS = Redis.new(host: uri.host, port: uri.port)

production.rb

ENV["REDIS"] = "*ElastiCacheのPrimary Endpointを記載*（****.cache.amazonaws.com:6379というやつ）"

何か怪しい点などがありそうでしたら指摘頂けると助かります。

Answer 1

Redis::CannotConnectError (Error connecting to Redis on 127.0.0.1:6379 (Errno::ECONNREFUSED)):

このエラーログを見る限り、ローカル(EC2があるサーバ)のRedisに接続しようとしてエラーになってますね。

URI.parse(ENV["REDIS"])

ENV['REDIS'] には何が入ってるんでしょうか？ ElasticCacheに接続するのであれば、参考にした記事に書いてあるような ElasticCacheのエンドポイントのURLがセットされてないといけない気がします。

redis://testlab-lab-001.a31-res.0001.xxxx.amazonaws.com

Comments

[gogoackman3]

ご質問の箇所（production.rbの内容）を本文に追記してありますので、ご確認頂けると幸いです！

[tell_k]

ENV['Redis'] にセットされてる文字列の先頭に "redis://" てつけてますか？ついてなければ付けた上で試してみてください。たぶんURI.parseが「URLとして適切に解析できていない」せいで、uri.host が nil とかになってるかもしれません。

[gogoackman3]

本文末尾に記載した、以下がENV['REDIS']の値に関する回答なのですが、回答がずれていますでしょうか？？

ENV["REDIS"] = "*ElastiCacheのPrimary Endpointを記載*（****.cache.amazonaws.com:6379というやつ）"

[tell_k]

ENV["REDIS"] = "****.cache.amazonaws.com:6379"

多分こう書いてると思うんですが、

ENV["REDIS"] = "redis://****.cache.amazonaws.com:6379"

こういう風にして欲しいという意味です。

[gogoackman3]

ありがとうございます！！
ENV['Redis'] にセットされてる文字列の先頭に "redis://" をつけると問題なく動きました！！！

[tell_k]

よかったですー。

Answer 2

F, [2017-03-29T22:32:02.418608 #6652] FATAL -- : Redis::CannotConnectError (Error connecting to Redis on 127.0.0.1:6379 (Errno::ECONNREFUSED)):

127.0.0.1とは自分自身のことです。つまり、EC2上で動いているプログラムは、ElastiCacheのTCP:6379ではなく自分自身のTCP:6379にアクセスしようとしているように見えます。環境変数をプログラムに渡す部分が上手くいっていないのかも。