Блог

Главная - Вопросы по программированию - Можно ли отправить задачу в очередь redis pyRQ асинхронным / ожидающим способом?

Можно ли отправить задачу в очередь redis pyRQ асинхронным / ожидающим способом?

#python-3.x #redis #python-asyncio

#python-3.x #redis #python-asyncio

Вопрос:

Можно ли отправить задачу в pyRQ очередь redis способом async / await?

Я использую tornado фреймворк, который поддерживает новый python await / async функциональность.

Посмотрите на этот пример:

 @job(`default`, connection=redis_conn)
def add(a: int, b: int):
    logger.info('Dummy adding task for {} and {}'.format(a, b))
    import time
    time.sleep(1)
    return a   b

Теперь, по-моему RequestHandler , я могу это сделать:

 add.delay(2, 3)

Строка выше создает блок ввода-вывода из-за процесса подключения с Redis. У кого-нибудь есть идеи, как я могу изменить @job декоратор на async версию, а затем иметь такие строки:

 await add.delay(2, 3)