python-asyncio

Вопрос или проблема Учитывая taskgroup и количество выполняемых задач, согласно документации по taskgroup, если какая-либо из задач вызывает ошибку, остальные задачи в группе будут отменены. Если некоторые из этих задач должны выполнить очистку после

Вопрос или проблема Когда я использую метод connect библиотеки socks напрямую, соединение устанавливается успешно, но когда я заменяю его на метод sock_connect библиотеки asynic, соединение истекает по времени. import asyncio import socks from _socket

Вопрос или проблема Я использую Tortoise ORM в своем приложении FastAPI. Из-за специфики моего приложения мне требуется Celery для выполнения почти дюжины задач, большинство из которых связано с операциями с базой данных. Поскольку я управляю базами данных

Вопрос или проблема Я начинаю работать с asyncio и создал следующее: import asyncio async def handle_data(q): while (item := await q.get()) is not None: print(f'Обрабатываю {item}') async def main(): q = asyncio.Queue() consumer = asyncio.

Вопрос или проблема У меня есть странная проблема с FastAPI. Предыстория такова, что у меня есть очередь, которая состоит из задач, добавляемых, когда я делаю запрос к конечной точке FastAPI. Я использую это для тестирования, поэтому намеренно держу запрос

Вопрос или проблема У меня есть следующий пример кода: import asyncio import concurrent.futures import functools import time async def run_till_first_success(tasks, timeout=None): results = [] exceptions = [] while tasks: try: async with asyncio.