John Loehrer 72squared
72squared
/ publish-test.py
Created
October 28, 2015 20:40
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| #!/usr/bin/python | |
| import time | |
| import rediscluster | |
| CHANNEL = 'chat' | |
| COUNT = 1000 | |
| SLEEP = 0.01 | |
| startup_nodes = [{'host':'127.0.0.1', 'port': 7000}] |
72squared
/ redis-threaded-example.py
Created
October 26, 2015 13:31
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import rediscluster | |
| import threading | |
| import time | |
| import random | |
| startup_nodes = [ | |
| {'host':'127.0.0.1', 'port': 7000}, | |
| {'host':'127.0.0.1', 'port': 7001}, | |
| {'host':'127.0.0.1', 'port': 7002}, |
72squared
/ hack-for-showing-threaded-vs-non-threaded.diff
Created
October 22, 2015 16:45
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| diff --git a/rediscluster/pipeline.py b/rediscluster/pipeline.py | |
| index 2106e70..a13e867 100644 | |
| --- a/rediscluster/pipeline.py | |
| +++ b/rediscluster/pipeline.py | |
| @@ -175,6 +175,8 @@ class StrictClusterPipeline(StrictRedisCluster): | |
| if i in ask_retry: | |
| track_cmds[node_name].append(None) | |
| cmds.append((['ASKING'], {})) | |
| + print "ASKING ... threaded" | |
| + |
72squared
/ pipeline-incrby.py
Last active
October 22, 2015 16:50
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| from rediscluster import RedisCluster | |
| startup_nodes = [{"host": "127.0.0.1", "port": 7000}] | |
| r = RedisCluster(startup_nodes=startup_nodes, max_connections=32, decode_responses=True) | |
| for i in xrange(1000000): | |
| d = str(i) | |
| pipe = r.pipeline(transaction=False) | |
| pipe.set(d, d) | |
| pipe.incrby(d, 1) |
72squared
/ set-get-writer.py
Created
October 21, 2015 22:05
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| from rediscluster import RedisCluster | |
| startup_nodes = [{"host": "127.0.0.1", "port": 7000}] | |
| r = RedisCluster(startup_nodes=startup_nodes, max_connections=32, decode_responses=True) | |
| for i in xrange(1000000): | |
| d = str(i) | |
| r.set(d, d) | |
| res = r.get(d) | |
| if res != d: |
72squared
/ incr-test-writer.py
Created
October 21, 2015 22:01
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| from rediscluster import RedisCluster | |
| startup_nodes = [{"host": "127.0.0.1", "port": 7000}] | |
| r = RedisCluster(startup_nodes=startup_nodes, max_connections=32, decode_responses=True) | |
| for i in xrange(1000000): | |
| d = str(i) | |
| r.set(d, d) | |
| r.incrby(d, 1) |
72squared
/ redis-writer.py
Created
October 19, 2015 15:16
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| from rediscluster import RedisCluster | |
| startup_nodes = [{"host": "127.0.0.1", "port": 7000}] | |
| r = RedisCluster(startup_nodes=startup_nodes, max_connections=32, decode_responses=True) | |
| N = 1000000 | |
| p = 0 | |
| pdiff = 1 | |
| progress = 0 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import rediscluster | |
| import threading | |
| import time | |
| import random | |
| startup_nodes = [ | |
| {'host':'127.0.0.1', 'port': 7000}, | |
| {'host':'127.0.0.1', 'port': 7001}, | |
| {'host':'127.0.0.1', 'port': 7002}, | |
| ] |
72squared
/ gist:8e9adb5fa5dff0ec65c8
Created
January 12, 2015 23:39
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| #!/usr/bin/env python | |
| import redis | |
| import rediscluster | |
| import argparse | |
| def main(srcs, dsts, verbose=False): | |
| srcs = [redis.StrictRedis(**host) for host in srcs] | |
| if len(dsts) > 1: |
72squared
/ gist:df7760716a4e8203d319
Created
December 4, 2014 22:54
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| $ redis-trib check :7000 | |
| Connecting to node :7000: OK | |
| Connecting to node 172.31.14.27:7001: OK | |
| Connecting to node 172.31.12.228:7001: [ERR] Sorry, can't connect to node 172.31.12.228:7001 | |
| OK | |
| Connecting to node 172.31.12.228:7002: [ERR] Sorry, can't connect to node 172.31.12.228:7002 | |
| OK | |
| Connecting to node 172.31.12.228:7000: [ERR] Sorry, can't connect to node 172.31.12.228:7000 | |
| OK | |
| Connecting to node 172.31.14.27:7000: OK |