Недавно делал быстрый прототип асинхронного приложения в котором требовалось вызывать много синхронного кода. Да, я знаю, что это не лучший дизайн, но нужно было быстрое решение на один процесс и без очередей. Поэтому я выполнял код в потоках.
Выглядело это примерно так:
from fastapi.concurrency import run_in_threadpool
async def execute(data: DataRequest) -> DataResponse:
try:
result = await run_in_threadpool(sync_function, data)
return DataResponse(data=result)
except Exception as e:
return DataResponse(
error=str(e),
success=False,
)
В общем работает нормально. Для всех вызовов под капотом используется общий тредпул, всё работает предсказуемо.
Но потребовалось изменить количество запускаемых в пуле потоков (по умолчанию создается 40 воркеров).
Так как дело происходит с FastAPI, делается это через lifespan используя настройки anyio:
import anyio
@asynccontextmanager
async def lifespan(app: FastAPI):
limiter = anyio.to_thread.current_default_thread_limiter()
limiter.total_tokens = 100
yield
# если вдруг нужно вернуть обратно
limiter.total_tokens = 40
Зачем менять количество воркеров?
- уменьшить, если оперативки мало (один тред занимает ~8мб)
- увеличить чтобы выдержать нагрузку
Если есть предложения получше при тех же вводных - предлагайте😉
#async
Импортозамещение от AXELOT
В последнее время импортозамещение обсуждается на всех уровнях и практически во всех сферах российского бизнеса. Не является исключением и область IT-технологий. В специально созданном едином реестре отечественных программ размещены уже шесть продуктов компании AXELOT – три из них пополнили этот список в течение марта. Для решения каких задач эти продукты предназначены, и как они могут быть полезны госзаказчикам, узнайте по ссылке https://www.axelot.ru/knowhow/news/detail_52687/
#WMS#импортозамещение#AxelotWMS#автоматизациясклада#TOS#AxelotTOS#SCAP
🇮🇳🇺🇿 Контейнерные перевозки из Индии в Узбекистан запустили по новому маршруту
Как пишет LogiStan, компания «Узтемирйулконтейнер» организовала новый мультимодальный маршрут для контейнерных перевозок из индийских портов Мундра, Нхава-Шева и Ченнаи в Узбекистан.
Грузы доставляют по морю из Индии в иранский порт Бандар-Аббас, а затем по железной дороге транзитом через 🇮🇷Иран и 🇹🇲Туркменистан до станции Сергели.
Время доставки планируют сократить до 15 дней.
P.S.: Особенно приятно видеть, что контейнерной обработкой, с помощью #AXELOTTOS , по данному маршруту занимаются наши друзья из компании FDP💪
У них кстати еще и ТГ-канал есть🚂
#LOGISTICS#RAILWAY#UZBEKISTAN#IRAN#TURKMENISTAN#INDIA
Контейнерные терминалы всегда были востребованы, однако текущие тенденции рынка логистики взорвали потребность в таких площадках, а рост грузооборота привел к тому, что существующие терминалы работают на пределе возможностей. ⚠️
Возникает вопрос! Каким образом работать в реалиях рынка, когда новых терминалов еще нет, а грузооборот растет?🤔
Есть инструмент – это автоматизация, которая позволяет переложить часть работы с человека на машинный интеллект и ускорить грузообработку. 👨💻
Особенно остро проблема в нехватке терминальных мощностей отражается на действующих логистических маршрутах и центрах, например, в Республике Казахстан. 🇰🇿
Поэтому хотим рассказать вам про недавно завершившийся проект автоматизации контейнерного терминала именно в Казахстане - "ТЛЦ "Жетыген", который является первой транзитной ж/д станцией на границе Казахстана и Китайской Народной Республики.🇨🇳
Особенностью данного проекта является то, что специалисты "ТЛЦ "Жетыген", смотря в будущее, и осознавая все риски, не стали дожидаться повышенных нагрузок на свой терминал, не стали дожидаться "аврала" и невозможности обработать все потоки, а пошли путём эффективного управления, внедрив у себя систему #AXELOTTOS, систему, которая уже на страте такого грандиозного проекта позволила им сократить издержки и понять степень необходимость IT-инструментов для дальнейшего развития бизнеса💪
Переходим по ссылке выше и читаем подробнее о замечательном проекте! А если остались вопросы, то их можно задать Жданову Юрию😎
#KAZAKHSTAN#TOS#ZHETYGEN#AXELOT#TERMINAL#AUTOMATION#EASTCOMTRANS