Merge pull request joke2k#122 from sanoma/feature/redis_locations

Feature: support for multiple redis locations

Author: joke2k

.gitignore

@@ -35,4 +35,7 @@ nosetests.xml
 .pydevproject
 .idea
 .projectile
-.ropeproject
+.ropeproject
+
+# pyenv/pyenv-virtualenv
+.python-version

README.rst

@@ -227,6 +227,15 @@ In order to use unsafe characters you have to encode with ``urllib.parse.encode`
 
 See https://perishablepress.com/stop-using-unsafe-characters-in-urls/ for reference.
 
+Multiple redis cache locations
+------------------------------
+
+For redis cache, `multiple master/slave or shard locations <http://niwinz.github.io/django-redis/latest/#_pluggable_clients>`_ can be configured as follows:
+
+.. code-block::
+
+    CACHE_URL='rediscache://master:6379,slave1:6379,slave2:6379/1'
+
 Email settings
 --------------
 
@@ -267,6 +276,11 @@ Django-environ is licensed under the MIT License - see the `LICENSE_FILE`_ file
 Changelog
 =========
 
+`pending`
+---------
+
+  - Support for django-redis multiple locations (master/slave, shards)
+
 `0.4.2 - 13-April-2017 <https://github.com/joke2k/django-environ/compare/v0.4.1...v0.4.2>`__
 --------------------------------------------------------------------------------------------
 

environ/environ.py

@@ -456,8 +456,8 @@ def cache_url_config(cls, url, backend=None):
                 scheme = url.scheme.replace('cache', '')
             else:
                 scheme = 'unix'
-
-            config['LOCATION'] = scheme + '://' + url.netloc + url.path
+            locations = [scheme + '://' + loc + url.path for loc in url.netloc.split(',')]
+            config['LOCATION'] = locations[0] if len(locations) == 1 else locations
 
         if url.query:
             config_options = {}

environ/test.py

@@ -477,6 +477,17 @@ def test_redis_with_password_parsing(self):
         self.assertEqual(REDIS_DRIVER, url['BACKEND'])
         self.assertEqual(url['LOCATION'], 'redis://:redispass@127.0.0.1:6379/0')
 
+    def test_redis_multi_location_parsing(self):
+        url = 'rediscache://host1:6379,host2:6379,host3:9999/1'
+        url = Env.cache_url_config(url)
+
+        self.assertEqual(url['BACKEND'], REDIS_DRIVER)
+        self.assertEqual(url['LOCATION'], [
+            'redis://host1:6379/1',
+            'redis://host2:6379/1',
+            'redis://host3:9999/1',
+        ])
+
     def test_redis_socket_url(self):
         url = 'redis://:redispass@/path/to/socket.sock?db=0'
         url = Env.cache_url_config(url)
@@ -485,7 +496,7 @@ def test_redis_socket_url(self):
         self.assertEqual(url['OPTIONS'], {
             'DB': 0
         })
-
+    
     def test_options_parsing(self):
         url = 'filecache:///var/tmp/django_cache?timeout=60&max_entries=1000&cull_frequency=0'
         url = Env.cache_url_config(url)