Connecting to Valkey#

Generic Client#

This is the client used to connect directly to a standard Valkey node.

class valkey.Valkey(host='localhost', port=6379, db=0, password=None, socket_timeout=None, socket_connect_timeout=None, socket_keepalive=None, socket_keepalive_options=None, connection_pool=None, unix_socket_path=None, encoding='utf-8', encoding_errors='strict', charset=None, errors=None, decode_responses=False, retry_on_timeout=False, retry_on_error=None, ssl=False, ssl_keyfile=None, ssl_certfile=None, ssl_cert_reqs='required', ssl_ca_certs=None, ssl_ca_path=None, ssl_ca_data=None, ssl_check_hostname=False, ssl_password=None, ssl_validate_ocsp=False, ssl_validate_ocsp_stapled=False, ssl_ocsp_context=None, ssl_ocsp_expected_cert=None, ssl_min_version=None, ssl_ciphers=None, max_connections=None, single_connection_client=False, health_check_interval=0, client_name=None, lib_name='valkey-py', lib_version='99.99.99', username=None, retry=None, valkey_connect_func=None, credential_provider=None, protocol=2, cache_enabled=False, client_cache=None, cache_max_size=10000, cache_ttl=0, cache_policy=EvictionPolicy.LRU, cache_deny_list=['BF.CARD', 'BF.DEBUG', 'BF.EXISTS', 'BF.INFO', 'BF.MEXISTS', 'BF.SCANDUMP', 'CF.COMPACT', 'CF.COUNT', 'CF.DEBUG', 'CF.EXISTS', 'CF.INFO', 'CF.MEXISTS', 'CF.SCANDUMP', 'CMS.INFO', 'CMS.QUERY', 'DUMP', 'EXPIRETIME', 'FT.AGGREGATE', 'FT.ALIASADD', 'FT.ALIASDEL', 'FT.ALIASUPDATE', 'FT.CURSOR', 'FT.EXPLAIN', 'FT.EXPLAINCLI', 'FT.GET', 'FT.INFO', 'FT.MGET', 'FT.PROFILE', 'FT.SEARCH', 'FT.SPELLCHECK', 'FT.SUGGET', 'FT.SUGLEN', 'FT.SYNDUMP', 'FT.TAGVALS', 'FT._ALIASADDIFNX', 'FT._ALIASDELIFX', 'HRANDFIELD', 'JSON.DEBUG', 'PEXPIRETIME', 'PFCOUNT', 'PTTL', 'SRANDMEMBER', 'TDIGEST.BYRANK', 'TDIGEST.BYREVRANK', 'TDIGEST.CDF', 'TDIGEST.INFO', 'TDIGEST.MAX', 'TDIGEST.MIN', 'TDIGEST.QUANTILE', 'TDIGEST.RANK', 'TDIGEST.REVRANK', 'TDIGEST.TRIMMED_MEAN', 'TOPK.INFO', 'TOPK.LIST', 'TOPK.QUERY', 'TOUCH', 'TTL'], cache_allow_list=['BITCOUNT', 'BITFIELD_RO', 'BITPOS', 'EXISTS', 'GEODIST', 'GEOHASH', 'GEOPOS', 'GEORADIUSBYMEMBER_RO', 'GEORADIUS_RO', 'GEOSEARCH', 'GET', 'GETBIT', 'GETRANGE', 'HEXISTS', 'HGET', 'HGETALL', 'HKEYS', 'HLEN', 'HMGET', 'HSTRLEN', 'HVALS', 'JSON.ARRINDEX', 'JSON.ARRLEN', 'JSON.GET', 'JSON.MGET', 'JSON.OBJKEYS', 'JSON.OBJLEN', 'JSON.RESP', 'JSON.STRLEN', 'JSON.TYPE', 'LCS', 'LINDEX', 'LLEN', 'LPOS', 'LRANGE', 'MGET', 'SCARD', 'SDIFF', 'SINTER', 'SINTERCARD', 'SISMEMBER', 'SMEMBERS', 'SMISMEMBER', 'SORT_RO', 'STRLEN', 'SUBSTR', 'SUNION', 'TS.GET', 'TS.INFO', 'TS.RANGE', 'TS.REVRANGE', 'TYPE', 'XLEN', 'XPENDING', 'XRANGE', 'XREAD', 'XREVRANGE', 'ZCARD', 'ZCOUNT', 'ZDIFF', 'ZINTER', 'ZINTERCARD', 'ZLEXCOUNT', 'ZMSCORE', 'ZRANGE', 'ZRANGEBYLEX', 'ZRANGEBYSCORE', 'ZRANK', 'ZREVRANGE', 'ZREVRANGEBYLEX', 'ZREVRANGEBYSCORE', 'ZREVRANK', 'ZSCORE', 'ZUNION'])[source]#

Implementation of the Valkey protocol.

This abstract class provides a Python interface to all Valkey commands and an implementation of the Valkey protocol.

Pipelines derive from this, implementing how the commands are sent and received to the Valkey server. Based on configuration, an instance will either use a ConnectionPool, or Connection object to talk to valkey.

It is not safe to pass PubSub or Pipeline objects between threads.

Parameters

credential_provider (Optional[CredentialProvider]) –
protocol (Optional[int]) –
cache_enabled (bool) –
client_cache (Optional[AbstractCache]) –
cache_max_size (int) –
cache_ttl (int) –
cache_policy (str) –
cache_deny_list (List[str]) –
cache_allow_list (List[str]) –

execute_command(*args, **options)[source]#: Execute a command and return a parsed response

classmethod from_pool(connection_pool)[source]#

Return a Valkey client from the given connection pool. The Valkey client will take ownership of the connection pool and close it when the Valkey client is closed.

Parameters: connection_pool (ConnectionPool) –
Return type: Valkey

classmethod from_url(url, **kwargs)[source]#

Return a Valkey client object configured from the given URL

For example:

valkey://[[username]:[password]]@localhost:6379/0
valkeys://[[username]:[password]]@localhost:6379/0
unix://[username@]/path/to/socket.sock?db=0[&password=password]

Three URL schemes are supported:

valkey:// creates a TCP socket connection.
valkeys:// creates a SSL wrapped TCP socket connection.
unix://: creates a Unix Domain Socket connection.

The username, password, hostname, path and all querystring values are passed through urllib.parse.unquote in order to replace any percent-encoded values with their corresponding characters.

There are several ways to specify a database number. The first value found will be used:

A db querystring option, e.g. valkey://localhost?db=0

If using the valkey:// or valkeys:// schemes, the path argument of the url, e.g. valkey://localhost/0

A db keyword argument to this function.

If none of these options are specified, the default db=0 is used.

All querystring options are cast to their appropriate Python types. Boolean arguments can be specified with string values “True”/”False” or “Yes”/”No”. Values that cannot be properly cast cause a ValueError to be raised. Once parsed, the querystring arguments and keyword arguments are passed to the ConnectionPool’s class initializer. In the case of conflicting arguments, querystring arguments always win.

Parameters: url (str) –
Return type: Valkey

get_connection_kwargs()[source]#

Get the connection’s key-word arguments

Return type: Dict

get_encoder()[source]#

Get the connection pool’s encoder

Return type: Encoder

load_external_module(funcname, func)[source]#

This function can be used to add externally defined valkey modules, and their namespaces to the valkey client.

funcname - A string containing the name of the function to create func - The function, being added to this class.

ex: Assume that one has a custom valkey module named foomod that creates command named ‘foo.dothing’ and ‘foo.anotherthing’ in valkey. To load function functions into this namespace:

from valkey import Valkey from foomodule import F r = Valkey() r.load_external_module(“foo”, F) r.foo().dothing(‘your’, ‘arguments’)

For a concrete example see the reimport of the redisjson module in tests/test_connection.py::test_loading_external_modules

Return type: None

lock(name, timeout=None, sleep=0.1, blocking=True, blocking_timeout=None, lock_class=None, thread_local=True)[source]#

Return a new Lock object using key name that mimics the behavior of threading.Lock.

If specified, timeout indicates a maximum life for the lock. By default, it will remain locked until release() is called.

sleep indicates the amount of time to sleep per loop iteration when the lock is in blocking mode and another client is currently holding the lock.

blocking indicates whether calling acquire should block until the lock has been acquired or to fail immediately, causing acquire to return False and the lock not being acquired. Defaults to True. Note this value can be overridden by passing a blocking argument to acquire.

blocking_timeout indicates the maximum amount of time in seconds to spend trying to acquire the lock. A value of None indicates continue trying forever. blocking_timeout can be specified as a float or integer, both representing the number of seconds to wait.

lock_class forces the specified lock implementation. Note that the only lock class we implement is Lock (which is a Lua-based lock). So, it’s unlikely you’ll need this parameter, unless you have created your own custom lock class.

thread_local indicates whether the lock token is placed in thread-local storage. By default, the token is placed in thread local storage so that a thread only sees its token, not a token set by another thread. Consider the following timeline:

time: 0, thread-1 acquires my-lock, with a timeout of 5 seconds.
thread-1 sets the token to “abc”

time: 1, thread-2 blocks trying to acquire my-lock using the
Lock instance.

time: 5, thread-1 has not yet completed. valkey expires the lock
key.

time: 5, thread-2 acquired my-lock now that it’s available.
thread-2 sets the token to “xyz”

time: 6, thread-1 finishes its work and calls release(). if the
token is not stored in thread local storage, then thread-1 would see the token value as “xyz” and would be able to successfully release the thread-2’s lock.

In some use cases it’s necessary to disable thread local storage. For example, if you have code where one thread acquires a lock and passes that lock instance to a worker thread to release later. If thread local storage isn’t disabled in this case, the worker thread won’t see the token set by the thread that acquired the lock. Our assumption is that these cases aren’t common and as such default to using thread local storage.

Parameters

name (str) –
timeout (Optional[float]) –
sleep (float) –
blocking (bool) –
blocking_timeout (Optional[float]) –
lock_class (Union[None, Any]) –
thread_local (bool) –

parse_response(connection, command_name, **options)[source]#: Parses a response from the Valkey server

pipeline(transaction=True, shard_hint=None)[source]#

Return a new pipeline object that can queue multiple commands for later execution. transaction indicates whether all commands should be executed atomically. Apart from making a group of operations atomic, pipelines are useful for reducing the back-and-forth overhead between the client and server.

Return type: Pipeline

pubsub(**kwargs)[source]#: Return a Publish/Subscribe object. With this object, you can subscribe to channels and listen for messages that get published to them.

set_response_callback(command, callback)[source]#

Set a custom Response Callback

Parameters

command (str) –
callback (Callable) –

Return type

None

transaction(func, *watches, **kwargs)[source]#

Convenience method for executing the callable func as a transaction while watching all keys specified in watches. The ‘func’ callable should expect a single argument which is a Pipeline object.

Parameters: func (Callable[[Pipeline], None]) –
Return type: None

Sentinel Client#

Valkey Sentinel provides high availability for Valkey. There are commands that can only be executed against a Valkey node running in sentinel mode. Connecting to those nodes, and executing commands against them requires a Sentinel connection.

Connection example (assumes Valkey exists on the ports listed below):

>>> from valkey import Sentinel
>>> sentinel = Sentinel([('localhost', 26379)], socket_timeout=0.1)
>>> sentinel.discover_master('mymaster')
('127.0.0.1', 6379)
>>> sentinel.discover_slaves('mymaster')
[('127.0.0.1', 6380)]

Sentinel#

class valkey.sentinel.Sentinel(sentinels, min_other_sentinels=0, sentinel_kwargs=None, **connection_kwargs)[source]#

Valkey Sentinel cluster client

>>> from valkey.sentinel import Sentinel
>>> sentinel = Sentinel([('localhost', 26379)], socket_timeout=0.1)
>>> master = sentinel.master_for('mymaster', socket_timeout=0.1)
>>> master.set('foo', 'bar')
>>> slave = sentinel.slave_for('mymaster', socket_timeout=0.1)
>>> slave.get('foo')
b'bar'

sentinels is a list of sentinel nodes. Each node is represented by a pair (hostname, port).

min_other_sentinels defined a minimum number of peers for a sentinel. When querying a sentinel, if it doesn’t meet this threshold, responses from that sentinel won’t be considered valid.

sentinel_kwargs is a dictionary of connection arguments used when connecting to sentinel instances. Any argument that can be passed to a normal Valkey connection can be specified here. If sentinel_kwargs is not specified, any socket_timeout and socket_keepalive options specified in connection_kwargs will be used.

connection_kwargs are keyword arguments that will be used when establishing a connection to a Valkey server.

discover_master(service_name)[source]#

Asks sentinel servers for the Valkey master’s address corresponding to the service labeled service_name.

Returns a pair (address, port) or raises MasterNotFoundError if no master is found.

discover_slaves(service_name)[source]#: Returns a list of alive slaves for service service_name

execute_command(*args, **kwargs)[source]#: Execute Sentinel command in sentinel nodes. once - If set to True, then execute the resulting command on a single node at random, rather than across the entire sentinel cluster.

filter_slaves(slaves)[source]#: Remove slaves that are in an ODOWN or SDOWN state

master_for(service_name, valkey_class=<class 'valkey.client.Valkey'>, connection_pool_class=<class 'valkey.sentinel.SentinelConnectionPool'>, **kwargs)[source]#

Returns a valkey client instance for the service_name master.

A SentinelConnectionPool class is used to retrieve the master’s address before establishing a new connection.

NOTE: If the master’s address has changed, any cached connections to the old master are closed.

By default clients will be a Valkey instance. Specify a different class to the valkey_class argument if you desire something different.

The connection_pool_class specifies the connection pool to use. The SentinelConnectionPool will be used by default.

All other keyword arguments are merged with any connection_kwargs passed to this class and passed to the connection pool as keyword arguments to be used to initialize Valkey connections.

slave_for(service_name, valkey_class=<class 'valkey.client.Valkey'>, connection_pool_class=<class 'valkey.sentinel.SentinelConnectionPool'>, **kwargs)[source]#

Returns valkey client instance for the service_name slave(s).

A SentinelConnectionPool class is used to retrieve the slave’s address before establishing a new connection.

By default clients will be a Valkey instance. Specify a different class to the valkey_class argument if you desire something different.

The connection_pool_class specifies the connection pool to use. The SentinelConnectionPool will be used by default.

All other keyword arguments are merged with any connection_kwargs passed to this class and passed to the connection pool as keyword arguments to be used to initialize Valkey connections.

SentinelConnectionPool#

class valkey.sentinel.SentinelConnectionPool(service_name, sentinel_manager, **kwargs)[source]#

Sentinel backed connection pool.

If check_connection flag is set to True, SentinelManagedConnection sends a PING command right after establishing the connection.

rotate_slaves()[source]#: Round-robin slave balancer

Cluster Client#

This client is used for connecting to a Valkey Cluster.

ValkeyCluster#

class valkey.cluster.ValkeyCluster(host=None, port=6379, startup_nodes=None, cluster_error_retry_attempts=3, retry=None, require_full_coverage=False, reinitialize_steps=5, read_from_replicas=False, dynamic_startup_nodes=True, url=None, address_remap=None, **kwargs)[source]#

Parameters

host (Optional[str]) –
port (int) –
startup_nodes (Optional[List[ClusterNode]]) –
cluster_error_retry_attempts (int) –
retry (Optional[Retry]) –
require_full_coverage (bool) –
reinitialize_steps (int) –
read_from_replicas (bool) –
dynamic_startup_nodes (bool) –
url (Optional[str]) –
address_remap (Optional[Callable[[Tuple[str, int]], Tuple[str, int]]]) –

determine_slot(*args)[source]#

Figure out what slot to use based on args.

Raises a ValkeyClusterException if there’s a missing key and we can’t: determine what slots to map the command to; or, if the keys don’t all map to the same key slot.

execute_command(*args, **kwargs)[source]#

Wrapper for ERRORS_ALLOW_RETRY error handling.

It will try the number of times specified by the config option “self.cluster_error_retry_attempts” which defaults to 3 unless manually configured.

If it reaches the number of times, the command will raise the exception

Key argument :target_nodes: can be passed with the following types:: nodes_flag: PRIMARIES, REPLICAS, ALL_NODES, RANDOM ClusterNode list<ClusterNode> dict<Any, ClusterNode>

classmethod from_url(url, **kwargs)[source]#

Return a Valkey client object configured from the given URL

For example:

valkey://[[username]:[password]]@localhost:6379/0
valkeys://[[username]:[password]]@localhost:6379/0
unix://[username@]/path/to/socket.sock?db=0[&password=password]

Three URL schemes are supported:

valkey:// creates a TCP socket connection.
valkeys:// creates a SSL wrapped TCP socket connection.
unix://: creates a Unix Domain Socket connection.

The username, password, hostname, path and all querystring values are passed through urllib.parse.unquote in order to replace any percent-encoded values with their corresponding characters.

There are several ways to specify a database number. The first value found will be used:

A db querystring option, e.g. valkey://localhost?db=0

If using the valkey:// or valkeys:// schemes, the path argument of the url, e.g. valkey://localhost/0

A db keyword argument to this function.

If none of these options are specified, the default db=0 is used.

get_connection_kwargs()[source]#: Get the connections’ key-word arguments

get_default_node()[source]#: Get the cluster’s default node

get_encoder()[source]#: Get the connections’ encoder

get_node_from_key(key, replica=False)[source]#: Get the node that holds the key’s slot. If replica set to True but the slot doesn’t have any replicas, None is returned.

keyslot(key)[source]#: Calculate keyslot for a given key. See Keys distribution model in https://redis.io/topics/cluster-spec

load_external_module(funcname, func)[source]#

This function can be used to add externally defined valkey modules, and their namespaces to the valkey client.

funcname - A string containing the name of the function to create func - The function, being added to this class.

lock(name, timeout=None, sleep=0.1, blocking=True, blocking_timeout=None, lock_class=None, thread_local=True)[source]#

Return a new Lock object using key name that mimics the behavior of threading.Lock.

If specified, timeout indicates a maximum life for the lock. By default, it will remain locked until release() is called.

sleep indicates the amount of time to sleep per loop iteration when the lock is in blocking mode and another client is currently holding the lock.

time: 0, thread-1 acquires my-lock, with a timeout of 5 seconds.
thread-1 sets the token to “abc”

time: 1, thread-2 blocks trying to acquire my-lock using the
Lock instance.

time: 5, thread-1 has not yet completed. valkey expires the lock
key.

time: 5, thread-2 acquired my-lock now that it’s available.
thread-2 sets the token to “xyz”

time: 6, thread-1 finishes its work and calls release(). if the
token is not stored in thread local storage, then thread-1 would see the token value as “xyz” and would be able to successfully release the thread-2’s lock.

monitor(target_node=None)[source]#: Returns a Monitor object for the specified target node. The default cluster node will be selected if no target node was specified. Monitor is useful for handling the MONITOR command to the valkey server. next_command() method returns one command from monitor listen() method yields commands from monitor.

on_connect(connection)[source]#

Initialize the connection, authenticate and select a database and send: READONLY if it is set during object initialization.

pipeline(transaction=None, shard_hint=None)[source]#

Cluster impl:: Pipelines do not work in cluster mode the same way they do in normal mode. Create a clone of this object so that simulating pipelines will work correctly. Each command will be called directly when used and when calling execute() will only return the result stack.

pubsub(node=None, host=None, port=None, **kwargs)[source]#: Allows passing a ClusterNode, or host&port, to get a pubsub instance connected to the specified node

set_default_node(node)[source]#: Set the default node of the cluster. :param node: ‘ClusterNode’ :return True if the default node was set, else False

set_response_callback(command, callback)[source]#: Set a custom Response Callback

ClusterNode#

class valkey.cluster.ClusterNode(host, port, server_type=None, valkey_connection=None)[source]#

Async Client#

See complete example: here

This client is used for communicating with Valkey, asynchronously.

class valkey.asyncio.client.Valkey(*, host='localhost', port=6379, db=0, password=None, socket_timeout=5, socket_connect_timeout=None, socket_keepalive=None, socket_keepalive_options=None, connection_pool=None, unix_socket_path=None, encoding='utf-8', encoding_errors='strict', decode_responses=False, retry_on_timeout=False, retry_on_error=None, ssl=False, ssl_keyfile=None, ssl_certfile=None, ssl_cert_reqs='required', ssl_ca_certs=None, ssl_ca_data=None, ssl_check_hostname=False, ssl_min_version=None, ssl_ciphers=None, max_connections=None, single_connection_client=False, health_check_interval=0, client_name=None, lib_name='valkey-py', lib_version='99.99.99', username=None, retry=None, auto_close_connection_pool=None, valkey_connect_func=None, credential_provider=None, protocol=2, cache_enabled=False, client_cache=None, cache_max_size=100, cache_ttl=0, cache_policy=EvictionPolicy.LRU, cache_deny_list=['BF.CARD', 'BF.DEBUG', 'BF.EXISTS', 'BF.INFO', 'BF.MEXISTS', 'BF.SCANDUMP', 'CF.COMPACT', 'CF.COUNT', 'CF.DEBUG', 'CF.EXISTS', 'CF.INFO', 'CF.MEXISTS', 'CF.SCANDUMP', 'CMS.INFO', 'CMS.QUERY', 'DUMP', 'EXPIRETIME', 'FT.AGGREGATE', 'FT.ALIASADD', 'FT.ALIASDEL', 'FT.ALIASUPDATE', 'FT.CURSOR', 'FT.EXPLAIN', 'FT.EXPLAINCLI', 'FT.GET', 'FT.INFO', 'FT.MGET', 'FT.PROFILE', 'FT.SEARCH', 'FT.SPELLCHECK', 'FT.SUGGET', 'FT.SUGLEN', 'FT.SYNDUMP', 'FT.TAGVALS', 'FT._ALIASADDIFNX', 'FT._ALIASDELIFX', 'HRANDFIELD', 'JSON.DEBUG', 'PEXPIRETIME', 'PFCOUNT', 'PTTL', 'SRANDMEMBER', 'TDIGEST.BYRANK', 'TDIGEST.BYREVRANK', 'TDIGEST.CDF', 'TDIGEST.INFO', 'TDIGEST.MAX', 'TDIGEST.MIN', 'TDIGEST.QUANTILE', 'TDIGEST.RANK', 'TDIGEST.REVRANK', 'TDIGEST.TRIMMED_MEAN', 'TOPK.INFO', 'TOPK.LIST', 'TOPK.QUERY', 'TOUCH', 'TTL'], cache_allow_list=['BITCOUNT', 'BITFIELD_RO', 'BITPOS', 'EXISTS', 'GEODIST', 'GEOHASH', 'GEOPOS', 'GEORADIUSBYMEMBER_RO', 'GEORADIUS_RO', 'GEOSEARCH', 'GET', 'GETBIT', 'GETRANGE', 'HEXISTS', 'HGET', 'HGETALL', 'HKEYS', 'HLEN', 'HMGET', 'HSTRLEN', 'HVALS', 'JSON.ARRINDEX', 'JSON.ARRLEN', 'JSON.GET', 'JSON.MGET', 'JSON.OBJKEYS', 'JSON.OBJLEN', 'JSON.RESP', 'JSON.STRLEN', 'JSON.TYPE', 'LCS', 'LINDEX', 'LLEN', 'LPOS', 'LRANGE', 'MGET', 'SCARD', 'SDIFF', 'SINTER', 'SINTERCARD', 'SISMEMBER', 'SMEMBERS', 'SMISMEMBER', 'SORT_RO', 'STRLEN', 'SUBSTR', 'SUNION', 'TS.GET', 'TS.INFO', 'TS.RANGE', 'TS.REVRANGE', 'TYPE', 'XLEN', 'XPENDING', 'XRANGE', 'XREAD', 'XREVRANGE', 'ZCARD', 'ZCOUNT', 'ZDIFF', 'ZINTER', 'ZINTERCARD', 'ZLEXCOUNT', 'ZMSCORE', 'ZRANGE', 'ZRANGEBYLEX', 'ZRANGEBYSCORE', 'ZRANK', 'ZREVRANGE', 'ZREVRANGEBYLEX', 'ZREVRANGEBYSCORE', 'ZREVRANK', 'ZSCORE', 'ZUNION'])[source]#

Implementation of the Valkey protocol.

This abstract class provides a Python interface to all Valkey commands and an implementation of the Valkey protocol.

Parameters

host (str) –
port (int) –
db (Union[str, int]) –
password (Optional[str]) –
socket_timeout (Optional[float]) –
socket_connect_timeout (Optional[float]) –
socket_keepalive (Optional[bool]) –
socket_keepalive_options (Optional[Mapping[int, Union[int, bytes]]]) –
connection_pool (Optional[ConnectionPool]) –
unix_socket_path (Optional[str]) –
encoding (str) –
encoding_errors (str) –
decode_responses (bool) –
retry_on_timeout (bool) –
retry_on_error (Optional[list]) –
ssl (bool) –
ssl_keyfile (Optional[str]) –
ssl_certfile (Optional[str]) –
ssl_cert_reqs (str) –
ssl_ca_certs (Optional[str]) –
ssl_ca_data (Optional[str]) –
ssl_check_hostname (bool) –
ssl_min_version (Optional[TLSVersion]) –
ssl_ciphers (Optional[str]) –
max_connections (Optional[int]) –
single_connection_client (bool) –
health_check_interval (int) –
client_name (Optional[str]) –
lib_name (Optional[str]) –
lib_version (Optional[str]) –
username (Optional[str]) –
retry (Optional[Retry]) –
auto_close_connection_pool (Optional[bool]) –
credential_provider (Optional[CredentialProvider]) –
protocol (Optional[int]) –
cache_enabled (bool) –
client_cache (Optional[AbstractCache]) –
cache_max_size (int) –
cache_ttl (int) –
cache_policy (str) –
cache_deny_list (List[str]) –
cache_allow_list (List[str]) –

async aclose(close_connection_pool=None)[source]#

Closes Valkey client connection

Parameters: close_connection_pool (Optional[bool]) – decides whether to close the connection pool used
Return type: None

by this Valkey client, overriding Valkey.auto_close_connection_pool. By default, let Valkey.auto_close_connection_pool decide whether to close the connection pool.

close(close_connection_pool=None)[source]#

Alias for aclose(), for backwards compatibility

Parameters: close_connection_pool (Optional[bool]) –
Return type: None

async execute_command(*args, **options)[source]#: Execute a command and return a parsed response

classmethod from_pool(connection_pool)[source]#

Return a Valkey client from the given connection pool. The Valkey client will take ownership of the connection pool and close it when the Valkey client is closed.

Parameters: connection_pool (ConnectionPool) –
Return type: Valkey

classmethod from_url(url, single_connection_client=False, auto_close_connection_pool=None, **kwargs)[source]#

Return a Valkey client object configured from the given URL

For example:

valkey://[[username]:[password]]@localhost:6379/0
valkeys://[[username]:[password]]@localhost:6379/0
unix://[username@]/path/to/socket.sock?db=0[&password=password]

Three URL schemes are supported:

valkey:// creates a TCP socket connection.
valkeys:// creates a SSL wrapped TCP socket connection.
unix://: creates a Unix Domain Socket connection.

The username, password, hostname, path and all querystring values are passed through urllib.parse.unquote in order to replace any percent-encoded values with their corresponding characters.

There are several ways to specify a database number. The first value found will be used:

A db querystring option, e.g. valkey://localhost?db=0
If using the valkey:// or valkeys:// schemes, the path argument
of the url, e.g. valkey://localhost/0
A db keyword argument to this function.

If none of these options are specified, the default db=0 is used.

Parameters

url (str) –
single_connection_client (bool) –
auto_close_connection_pool (Optional[bool]) –
kwargs (Any) –

get_connection_kwargs()[source]#: Get the connection’s key-word arguments

get_encoder()[source]#: Get the connection pool’s encoder