Перейти к содержанию

SyncRedisGlobalConfig

Sync Redis Global Config.

SyncRedisGlobalConfig

Bases: BaseGlobalConfig, SyncPluginMixin

Глобальный Конфиг, работающий через Redis и работает с глобальными значениями.

Пример

from qtasks import QueueTasks
from qtasks.configs import SyncRedisGlobalConfig
from qtasks.storage import SyncRedisStorage
from qtasks.brokers import SyncRedisBroker

global_config = SyncRedisGlobalConfig(name="QueueTasks", url="redis://localhost:6379/2")

storage = SyncRedisStorage(name="QueueTasks", global_config=global_config, url="redis://localhost:6379/2")

broker = SyncRedisBroker(name="QueueTasks", storage=storage, url="redis://localhost:6379/2")

app = QueueTasks(broker=broker)

__init__(name='QueueTasks', url='redis://localhost:6379/0', redis_connect=None, config_name=None, log=None, config=None)

Инициализация асинхронного Redis глобального конфига.

Parameters:

Name Type Description Default
name str

Имя проекта. По умолчанию: "QueueTasks".

'QueueTasks'
url str

URL для подключения к Redis. По умолчанию: "redis://localhost:6379/0".

'redis://localhost:6379/0'
redis_connect Redis

Внешний класс подключения к Redis. По умолчанию: None.

None
config_name str

Имя Папки с Hash. По умолчанию: None.

None
log Logger

Логгер. По умолчанию: None.

None
config QueueConfig

Конфигурация. По умолчанию: None.

None

get(key, name)

Получить значение.

Parameters:

Name Type Description Default
key str

Ключ.

required
name str

Имя.

required

Returns:

Name Type Description
Any Any

Значение.

get_all(key)

Получить все значения.

Parameters:

Name Type Description Default
key str

Ключ.

required

Returns:

Type Description
dict[Any]

dict[Any]: Значения.

get_match(match)

Получить значения по паттерну.

Parameters:

Name Type Description Default
match str

Паттерн.

required

Returns:

Type Description
Any | dict[Any]

Any | dict[Any]: Значение или Значения.

set(name, key, value)

Добавить новое значение.

Parameters:

Name Type Description Default
name str

Имя.

required
key str

Ключ.

required
value str

Значение.

required

start()

Запуск Брокера. Эта функция задействуется основным экземпляром QueueTasks через `run_forever.

stop()

Останавливает Глобальный Конфиг. Эта функция задействуется основным экземпляром QueueTasks после завершения функции run_forever.