这是一个创建于 3774 天前的主题，其中的信息可能已经有所发展或是发生改变。
现在有这样一个需求，
我要从redis的key里面取东西，但是这些key是不定的（命名有一定规则）， 我现在的想法是通过一个协程没一秒去扫描存活的key， 存入AsyncResult里面， 然后在其他协程里面使用这些key之前先从这个AsyncResult里面取值。这样有个问题， 如果在协程运行起来后， 新加入了key， 下面的代码不能捕获到新的key了， 求解。
import gevent, redis
alive_keys = gevent.event.AsyncResult()
def get_alive_keys():
----client = redis.StrictRedis(host='localhost')
----while 1:
--------try:
------------keys = client.keys('alive*balabala*')
------------alive_keys.set(keys)
--------except:
------------pass
--------gevent.sleep(1)
def foo(key):
----balabala....
try:
----keys = alive_keys.get()
----tasks = [gevent.spawn(foo, key) for key in keys]
----tasks.append(gevent.spawn(get_alive_keys))
----gevent.joinall(tasks)
except:
----pass
我要从redis的key里面取东西，但是这些key是不定的（命名有一定规则）， 我现在的想法是通过一个协程没一秒去扫描存活的key， 存入AsyncResult里面， 然后在其他协程里面使用这些key之前先从这个AsyncResult里面取值。这样有个问题， 如果在协程运行起来后， 新加入了key， 下面的代码不能捕获到新的key了， 求解。
import gevent, redis
alive_keys = gevent.event.AsyncResult()
def get_alive_keys():
----client = redis.StrictRedis(host='localhost')
----while 1:
--------try:
------------keys = client.keys('alive*balabala*')
------------alive_keys.set(keys)
--------except:
------------pass
--------gevent.sleep(1)
def foo(key):
----balabala....
try:
----keys = alive_keys.get()
----tasks = [gevent.spawn(foo, key) for key in keys]
----tasks.append(gevent.spawn(get_alive_keys))
----gevent.joinall(tasks)
except:
----pass
 |
1
KDr2 2014-08-04 12:24:44 +08:00
alive_keys.get之前，get_alive_keys还没spawn啊，更没运行，当然是空的了。可以先调用一次来初始化。
另外你的 foo 如果也是周期性调用的话，得每次调用或者 spanw 前重新 alive_keys.get() 不然 keys 永远是第一次拿到的存活 keys |
 |
2
zjxubinbin 2014-08-04 13:50:55 +08:00
缓存的缓存真的有必要嚒?
|
 |
3
Zuckonit OP @KDr2 每次spawn之前重新alive_keys.get() 这样可以吗？， 我是一个key开一个协程啊tasks = [gevent.spawn(foo, key) for key in keys]
|
|
4
Zuckonit OP @zjxubinbin 求指点
|
Select Language