Redis

The Redis module provides a Redis-based version of the DBContextStorage class. This class is used to store and retrieve context data in a Redis. It allows Chatsky to easily store and retrieve context data in a format that is highly scalable and easy to work with.

Redis is an open-source, in-memory data structure store that is known for its high performance and scalability. It stores data in key-value pairs and supports a variety of data structures such as strings, hashes, lists, sets, and more. Additionally, Redis can be used as a cache, message broker, and database, making it a versatile and powerful choice for data storage and management.

class RedisContextStorage(path, rewrite_existing=False, partial_read_config=None, key_prefix='chatsky_keys')

Bases: DBContextStorage

Implements DBContextStorage with redis as the database backend.

The main context info is stored in redis hashes, one for each context. The TURNS table values are stored in redis hashes, one for each field.

That’s how MAIN table fields are stored: “KEY_PREFIX:main:ctx_id”: “DATA” That’s how TURNS table fields are stored: “KEY_PREFIX:turns:ctx_id:FIELD_NAME”: “DATA”

Parameters:

• path (str) – Database URI string. Example: redis://user:password@host:port.

• rewrite_existing (bool) – Whether TURNS modified locally should be updated in database or not.

• partial_read_config (Optional[Dict[Literal['labels', 'requests', 'responses'], Union[Literal['__all__'], int, Set[int]]]]) – Dictionary of subscripts for all possible turn items.

• key_prefix (str) – “namespace” prefix for all keys, should be set for efficient clearing of all data.

is_concurrent: bool = True

async _connect()

static _keys_to_bytes(keys)

Return type:

List[bytes]

static _bytes_to_keys(keys)

Return type:

List[int]

async _load_main_info(ctx_id)

Return type:

Optional[ContextMainInfo]

async _update_context(ctx_id, ctx_info, field_info)

Return type:

None

async _delete_context(ctx_id)

Return type:

None

async _load_field_latest(ctx_id, field_name)

Return type:

List[Tuple[int, bytes]]

async _load_field_keys(ctx_id, field_name)

Return type:

List[int]

async _load_field_items(ctx_id, field_name, keys)

Return type:

List[Tuple[int, bytes]]

async _clear_all()

Return type:

None