| Summary: | faststream - не работает брокер Redis | ||||||
|---|---|---|---|---|---|---|---|
| Product: | Sisyphus | Reporter: | Руслан Вишталмагомедов <vishtalmagomedovrg> | ||||
| Component: | python3-module-faststream | Assignee: | Sergei Dunaev <swerg.work> | ||||
| Status: | NEW --- | QA Contact: | qa-sisyphus | ||||
| Severity: | normal | ||||||
| Priority: | P5 | CC: | demidovaa, egori | ||||
| Version: | unstable | ||||||
| Hardware: | all | ||||||
| OS: | Linux | ||||||
| Attachments: |
|
||||||
Ошибка актуальна для python3-module-faststream-0.6.6-alt1 Программа не запускается, возвращает ошибку AttributeError: type object 'Redis' has no attribute 'from_pool' |
Created attachment 18308 [details] лог с ошибкой с версией из репозитория стенды: (обновленные до Sisyphus) ALT Server 11.0 ALT Workstation 11.0 ALT Workstation K 11.0 версии: python3-module-faststream-0.5.39-alt1.noarch python3-module-redis-py-4.5.5-alt1.1.noarch шаги воспроизведения: 1. # apt-get install redis python3-module-faststream && systemctl enable --now redis 2. $ cat <<EOF > test.py from faststream import FastStream from faststream.redis import RedisBroker broker = RedisBroker("redis://localhost:6379") app = FastStream(broker) @broker.subscriber("in-channel") async def handle(msg): print(f"Received: {msg}") EOF 3. $ python3 -m faststream run test:app Результат: Программа не запускается, возвращает ошибку AttributeError: type object 'Redis' has no attribute 'from_pool' Ожидаемый результат: Программа запустилась, имеется вывод вида: 2025-04-28 13:25:30,461 INFO - FastStream app starting... 2025-04-28 13:25:30,462 INFO - in-channel | - `Handle` waiting for messages 2025-04-28 13:25:30,468 INFO - FastStream app started successfully! To exit, press CTRL+C Дополнительно: Программа запускается корректно, если в системе установлена свежая версия redis-py, например через pip FastStream обращается к Redis функцией from_pool (/usr/lib/python3/site-packages/faststream/redis/broker/broker.py line 331) В версии redis-5.2.1 (из pip) данная функция присутствует, однако в версии 4.5.5 из репозитория этой функции нет