nameko-redis

Redis dependency for nameko services

Installation

pip install nameko-redis

Usage

from nameko.rpc import rpc
from nameko_redis import Redis


class MyService(object):
    name = "my_service"

    redis = Redis('development')

    @rpc
    def hello(self, name):
        self.redis.set("foo", name)
        return "Hello, {}!".format(name)

    @rpc
    def bye(self):
        name = self.redis.get("foo")
        return "Bye, {}!".format(name)

To specify redis connection string you will need a config

AMQP_URI: 'amqp://guest:guest@localhost'
REDIS_URIS:
 development: 'redis://localhost:6379/0'

You can also pass extra options to the class, like this:

class MyOtherService(object):
    name = "my_other_service"

    redis = Redis('development', decode_responses=False, encoding='utf-8')

    ...