Как эффективно обрабатывать гнездовые асинхронные операции с помощью Python asyncio lib? ⇐ Python

[Anonymous]

Я работаю над проектом Python, в котором есть следующие асинхронные операции. Я хочу убедиться, что каждый уровень имеет хорошую обработку ошибок и возвращается в основной цикл для повторного выполнения. Я хочу поставить лайк: если есть какая-то ошибка, я хочу, чтобы задачи pnding были отменены.

Код: Выделить всё

import asyncio

async def fetch_data_from_service(service_name):
await asyncio.sleep(1)  # Simulating I/O operation
if service_name == "ServiceB":
raise Exception(f"Error fetching data from {service_name}")
return f"Data from {service_name}"

async def process_data(data):
await asyncio.sleep(1)  # Simulating data processing
if data == "Data from ServiceC":
raise Exception("Error processing data from ServiceC")
return f"Processed {data}"

async def main_task():
try:
dataA = await fetch_data_from_service("ServiceA")
dataB = await fetch_data_from_service("ServiceB")
dataC = await fetch_data_from_service("ServiceC")

processedA = await process_data(dataA)
processedB = await process_data(dataB)
processedC = await process_data(dataC)

print(processedA, processedB, processedC)
except Exception as e:
print(f"Exception caught in main_task: {e}")
# How to ensure all pending tasks are canceled if an error occurs?
# How to propagate this error back to the main event loop?

# Running the event loop
if __name__ == "__main__":
try:
asyncio.run(main_task())
except Exception as e:
print(f"Exception caught in event loop: {e}")

Мне нужна эффективная обработка гнезд, проверка каждого уровня, отмена задачи в случае возникновения ошибки и перенаправление ошибок в основной цикл событий.
Я обернул каждый op в блоке try-expect, чтобы перехватывать ошибки и управлять ими. Но я не уверен в этом процессе отмены.
Я ожидаю, что асинхронные задачи будут выполняться без ошибок, даже если ошибка возникает, вызывать все таксы и перенаправляться в основной цикл событий.
Пожалуйста, помогите мне с этим.

Подробнее здесь: https://stackoverflow.com/questions/787 ... syncio-lib