From f9653114d1a55179bfb8b7f69b8078fd3e0df2f6 Mon Sep 17 00:00:00 2001 From: argaen Date: Mon, 15 May 2017 20:27:55 +0200 Subject: [PATCH] Update aiocache example to latest version --- examples/cache_example.py | 53 +++++++++++++++++++++++++++++---------- 1 file changed, 40 insertions(+), 13 deletions(-) diff --git a/examples/cache_example.py b/examples/cache_example.py index df56689f..80b8edd8 100644 --- a/examples/cache_example.py +++ b/examples/cache_example.py @@ -1,40 +1,61 @@ """ -Example of caching using aiocache package. To run it you will need a Redis -instance running in localhost:6379. You can also try with SimpleMemoryCache. +Example of caching using aiocache package. To run it you will need to install +aiocache with `pip install aiocache` plus a Redis instance running +in localhost:6379 Running this example you will see that the first call lasts 3 seconds and -the rest are instant because the value is retrieved from the Redis. +the rest are instant because the value is retrieved from Redis. If you want more info about the package check https://github.com/argaen/aiocache """ import asyncio -import aiocache +import uuid from sanic import Sanic from sanic.response import json from sanic.log import log -from aiocache import cached -from aiocache.serializers import JsonSerializer + +from aiocache import caches, cached + app = Sanic(__name__) +config = { + "default": { + "cache": "aiocache.RedisCache", + "endpoint": "127.0.0.1", + "timeout": 2, + "namespace": "sanic", + "serializer": { + "class": "aiocache.serializers.JsonSerializer" + } + } +} + + @app.listener('before_server_start') def init_cache(sanic, loop): - aiocache.settings.set_defaults( - class_="aiocache.RedisCache", - # class_="aiocache.SimpleMemoryCache", - loop=loop - ) + caches.set_config(config) -@cached(key="my_custom_key", serializer=JsonSerializer()) +# You can use alias or pass explicit args instead +@cached(key="my_custom_key", ttl=30, alias="default") async def expensive_call(): log.info("Expensive has been called") await asyncio.sleep(3) - return {"test": True} + # You are storing the whole dict under "my_custom_key" + return {"test": str(uuid.uuid4())} + + +async def get_cache_value(): + # This lazy loads a singleton so it will return the same instance every + # time. If you want to create a new instance, you can use + # `caches.create("default")` + cache = caches.get("default") + return await cache.get("my_custom_key") @app.route("/") @@ -43,4 +64,10 @@ async def test(request): return json(await expensive_call()) +@app.route("/retrieve") +async def test(request): + log.info("Received GET /retrieve") + return json(await get_cache_value()) + + app.run(host="0.0.0.0", port=8000)