Отдельно разберём TaskGroup, который пришел на замену gather в Python 3.11.
Ключевые отличия
▫️create_task() возвращает объект asyncio.Task, у которого есть соответствюущие методы управления. То есть у нас больше контроля
▫️это контекстный менеджер, который гарантирует что все таски будут остановлены по выходу из контекста
▫️ошибка автоматически отменяет незавершенные задачи,
▫️except* передает нам ExceptionGroup, в котором каждую ошибку можно обработать отдельно
import asyncio
import random
async def do_it() -> str:
if random.random() < 0.1:
raise ValueError('Oops')
delay = random.uniform(0.5, 1.5)
await asyncio.sleep(delay)
return delay
async def main():
try:
async with asyncio.TaskGroup() as tg:
for _ in range(10):
tasks.append(tg.create_task(do_it()))
for t in tasks:
print(t.result())
except *ValueError as e:
for err in e.exceptions:
print(err)
asyncio.run(main())
Рекомендую изучить страницу Coroutines and Tasks из документации, где представлено больше интересных примеров и механизмов
- таймауты
- отмена задач
- создание задач из другого потока
#async
🇲🇽 Un incendie s'est déclaré dans un dépôt de coke de la raffinerie Olmeca, située à Dos Bocas, dans l'État de Tabasco, dans le sud du Mexique, a annoncé la compagnie pétrolière et gazière publique Pemex sur le réseau social X.
#mexique#raffinerie#incendie
🇷🇺🇺🇦 À Touapsé, dans le sud-ouest de la Russie, la lutte contre un incendie dans une raffinerie de pétrole et contre les conséquences d’une fuite de produits pétroliers causée par une attaque de drone des forces armées ukrainiennes se poursuit, a déclaré le gouverneur de la région de Krasnodar, Veniamine Kondratiev, sur sa chaîne Telegram. La situation, selon lui, est difficile mais reste sous contrôle.
#russie#touapsé#incendie#raffinerie