AsyncRedisGlobalConfig
Async Redis Global Config.
AsyncRedisGlobalConfig
¶
Bases: BaseGlobalConfig
, AsyncPluginMixin
Глобальный Конфиг, работающий через Redis и работает с глобальными значениями.
Пример¶
from qtasks import QueueTasks
from qtasks.configs import AsyncRedisGlobalConfig
from qtasks.storage import AsyncRedisStorage
from qtasks.brokers import AsyncRedisBroker
global_config = AsyncRedisGlobalConfig(name="QueueTasks", url="redis://localhost:6379/2")
storage = AsyncRedisStorage(name="QueueTasks", global_config=global_config, url="redis://localhost:6379/2")
broker = AsyncRedisBroker(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)
async
¶
Получить значение.
Parameters:
Name | Type | Description | Default |
---|---|---|---|
key
|
str
|
Ключ. |
required |
name
|
str
|
Имя. |
required |
Returns:
Name | Type | Description |
---|---|---|
Any |
Any
|
Значение. |
get_all(key)
async
¶
Получить все значения.
Parameters:
Name | Type | Description | Default |
---|---|---|---|
key
|
str
|
Ключ. |
required |
Returns:
Type | Description |
---|---|
dict[Any]
|
dict[Any]: Значения. |
get_match(match)
async
¶
Получить значения по паттерну.
Parameters:
Name | Type | Description | Default |
---|---|---|---|
match
|
str
|
Паттерн. |
required |
Returns:
Type | Description |
---|---|
Any | dict[Any]
|
Any | dict[Any]: Значение или Значения. |
set(name, key, value)
async
¶
Добавить новое значение.
Parameters:
Name | Type | Description | Default |
---|---|---|---|
name
|
str
|
Имя. |
required |
key
|
str
|
Ключ. |
required |
value
|
str
|
Значение. |
required |
start()
async
¶
Запуск Брокера. Эта функция задействуется основным экземпляром QueueTasks
через `run_forever.
stop()
async
¶
Останавливает Глобальный Конфиг. Эта функция задействуется основным экземпляром QueueTasks
после завершения функции run_forever
.