Add utility for pipelining within 'with' statement.

1 files changed, 8 insertions, 0 deletions

diff --git a/redis/utils.py b/redis/utils.py
index ee681bf..b7e7f46 100644
--- a/redis/utils.py
+++ b/redis/utils.py
@@ -14,3 +14,11 @@ def from_url(url, db=None, **kwargs):
     """
     from redis.client import Redis
     return Redis.from_url(url, db, **kwargs)
+
+
+from contextlib import contextmanager
+@contextmanager
+def pipeline(redis_obj):
+    p = redis_obj.pipeline()
+    yield p
+    p.execute()