aioredis 1.0.0b1

asyncio (PEP 3156) Redis support

asyncio (PEP 3156) Redis client library.

Features

hiredis parser	Yes
Pure-python parser	Yes
Low-level & High-level APIs	Yes
Connections Pool	Yes
Pipelining support	Yes
Pub/Sub support	Yes
SSL/TLS support	Yes
Sentinel support	Yes [1]
Redis Cluster support	WIP
Trollius (python 2.7)	No
Tested CPython versions	3.3, 3.4, 3.5, 3.6
Tested PyPy3 versions	5.7.1
Tested for Redis server	2.6, 2.8, 3.0, 3.2
Support for dev Redis server	through low-level API

[1]

Sentinel support is available in master branch. This feature is not yet stable and may have some issues.

Documentation

http://aioredis.readthedocs.io/

Usage examples

Simple low-level interface:

import asyncio
import aioredis

loop = asyncio.get_event_loop()

async def go():
    conn = await aioredis.create_connection(
        ('localhost', 6379), loop=loop)
    await conn.execute('set', 'my-key', 'value')
    val = await conn.execute('get', 'my-key')
    print(val)
    conn.close()
    await conn.wait_closed()
loop.run_until_complete(go())
# will print 'value'

Simple high-level interface:

import asyncio
import aioredis

loop = asyncio.get_event_loop()

async def go():
    redis = await aioredis.create_redis(
        ('localhost', 6379), loop=loop)
    await redis.set('my-key', 'value')
    val = await redis.get('my-key')
    print(val)
    redis.close()
    await redis.wait_closed()
loop.run_until_complete(go())
# will print 'value'

Connections pool:

import asyncio
import aioredis

loop = asyncio.get_event_loop()

async def go():
    pool = await aioredis.create_pool(
        ('localhost', 6379),
        minsize=5, maxsize=10,
        loop=loop)
    await pool.execute('set', 'my-key', 'value')
    print(await pool.execute('get', 'my-key'))
    # graceful shutdown
    pool.close()
    await pool.wait_closed()

loop.run_until_complete(go())

Requirements

• Python 3.3+

• asyncio or Python 3.4+

• hiredis

Note

hiredis is preferred requirement. Pure-python protocol parser is implemented as well and can be used through parser parameter.

Discussion list

aio-libs google group: https://groups.google.com/forum/#!forum/aio-libs

License

The aioredis is offered under MIT license.

Changes

1.0.0 (2017-xx-xx)

NEW:

• Connections pool has been refactored; now create_redis function will yield Redis instance instead of RedisPool (see #129);

• Dropped create_reconnecting_redis, create_redis_pool should be used instead;

• Implement Sentinel support (see #181);

• Implement pure-python parser (see #212);

• Add migrate_keys command (see #187);

• Add zrevrangebylex command (see #201);

• Add command, command_count, command_getkeys and command_info commands (see #229);

FIX:

• Fix Multi/Exec transaction canceled error (see #225);

• Add missing arguments to create_redis and create_redis_pool;

• Fix deprecation warning (see #191);

• Make correct __aiter__() (see #192);

• Backward compatibility fix for with (yield from pool) as conn: (see #205);

• Fixed pubsub receiver stop() (see #211);

MISC:

• Multiple test fixes;

• Add PyPy3 to build matrix;

0.3.2 (2017-06-21)

NEW:

• Added zrevrangebylex command (see #201), cherry-picked from master;

• Add connection timeout (see #221), cherry-picked from master;

FIX:

• Fixed pool close warning (see #239 and #236), cherry-picked from master;

• Fixed asyncio Lock deadlock issue (see #231 and #241);

0.3.1 (2017-05-09)

FIX:

• Fix pubsub Receiver missing iter() method (see #203);

0.3.0 (2017-01-11)

NEW:

• Pub/Sub connection commands accept Channel instances (see #168);

• Implement new Pub/Sub MPSC (multi-producers, single-consumer) Queue – aioredis.pubsub.Receiver (see #176);

• Add aioredis.abc module providing abstract base classes defining interface for basic lib components; (see #176);

• Implement Geo commands support (see #177 and #179);

FIX:

• Minor tests fixes;

MISC:

• Update examples and docs to use async/await syntax also keeping yield from examples for history (see #173);

• Reflow Travis CI configuration; add Python 3.6 section (see #170);

• Add AppVeyor integration to run tests on Windows (see #180);

• Update multiple development requirements;