1

我正在尝试使用 memcached 从 aiohttp 缓存一个函数。缓存我想做一个装饰者。调用装饰器的示例如下所示：

@cache("main_page", expire=25)
@asyncio.coroutine
def page(request):
    return aiohttp_jinja2.render_template('index', request, {} )

处理缓存的函数装饰器如下所示：

def cache_key(name, kwargs):
    key = b'\xff'.join(bytes(k, 'utf-8') + b'\xff' + pickle.dumps(v) for k, v in kwargs.items())
    key = bytes(hashlib.sha1(key).hexdigest(), 'ascii')
    return key


def cache(name, expire=0):
    def decorator(func):
        @asyncio.coroutine
        def wrapper(request=None, **kwargs):
            assert isinstance(request, (aiohttp.web_reqrep.Request, type(None))), type(request)
            args = [r for r in [request] if isinstance(r, aiohttp.web_reqrep.Request)]
            assert isinstance(mc, aiomcache.Client)
            key = cache_key(name, kwargs)
            value = yield from mc.get(key)
            if value is None:
                value = yield from func(*args, **kwargs)
                yield from mc.set(key, pickle.dumps(value,   protocol=pickle.HIGHEST_PROTOCOL), exptime=expire)
            else:
                value = pickle.loads(value)
            print(value)
            return value

        return wrapper

    return decorator

但我在控制台中收到错误：

  File "/usr/local/lib/python3.4/dist-packages/aiohttp_debugtoolbar/panels/headers.py", line 25, in process_response
    sorted(response.headers.items())]
  File "aiohttp/_multidict.pyx", line 464, in aiohttp._multidict._ItemsView.__iter__ (aiohttp/_multidict.c:8990)
TypeError: 'NoneType' object is not iterable

据我了解的问题：

如果可能，如何序列化/反序列化响应，如果不可能，如何缓存结果 - 有一些解决方法？

4

1 回答 1

0

aiohttp不打算用作缓存代理 - 因此web.StreamResponse后代不可序列化。

序列化流响应或 websocket 会话的想法有点尴尬，不是吗？也许我应该通过添加对 multidicts 的酸洗支持——但我没有用户要求。

无论如何，我建议不要缓存响应，而是缓存页面片段或整个呈现的响应主体——这需要更多的工作，但听起来像是强大的解决方案。

于 2015-10-03T08:44:28.707 回答