кто-нибудь использует spawn/task в контроллерах для создания отдельных процессов, будут ли проблемы из-за слишком большого количества паралелльных процессов?

кто-нибудь использует spawn/task в контроллерах для создания отдельных процессов, будут ли проблемы из-за слишком большого количества паралелльных процессов?

Что делать в этом процессе?

в моем случае хочу слать сообщение в сокет, результат не важен. ну и вообще для случаев когда результат не важен

проблемы с большим количеством процессов начинаются, если они используют общие ресурсы - ets, пул воркеров/коннектов, etc

сами по себе процессы почти ничего не стоят

ну и есть ключ +P

в моем случае хочу слать сообщение в сокет, результат не важен. ну и вообще для случаев когда результат не важен

Это бродкаст на эндпоинт? Можно в принципе и без создания процесса слать.

в моем случае хочу слать сообщение в сокет, результат не важен. ну и вообще для случаев когда результат не важен

интересный вопрос кстати. я пока сделал генсервер, который шлёт сообщения в сокеты

Это бродкаст на эндпоинт? Можно в принципе и без создания процесса слать.

там же зачастую не только бродкаст, а ещё темплейт срендерить или что-то ещё такое

вообще неправильно описала, у нас сообщения сначала падают в rabbitmq, а оттуда уже в сокет, так что будет писать в очередь

вообще неправильно описала, у нас сообщения сначала падают в rabbitmq, а оттуда уже в сокет, так что будет писать в очередь

Получается что куча процессов будет слать в очередь, если это ок то ничего страшного, сами по себе процессы достаточно дешёвые

по идее и так куча процессов шлет, так что попробую, спасибо ?

вообще неправильно описала, у нас сообщения сначала падают в rabbitmq, а оттуда уже в сокет, так что будет писать в очередь

в таком раскладе начинается более интересная история - какие гарантии тебе нужны

можно ли сообщения терять, какие гарантии хочется предоставить клиенту etc

в таком раскладе начинается более интересная история - какие гарантии тебе нужны

результат и сейчас не проверяется, так что гарантии не нужны, единственное что сейчас при падении запрос возвращает ошибку, но это скорее минус чем плюс

тогда вообще никакой разницы. единственный нюанс - метаданные в process dictionary. если контроллеры выполняются в процессе-обработчике ковбоя, то стоит учесть, что при connection: keep-alive этот процесс реиспользуется и метаданные надо чистить.

то есть, кейс примерно такой у меня был - lager, lager_logstash_backend. все метаданные лагера попадают в сообщение в логстеше. большую часть времени все идет отлично, но вот в некоторых случаях в выборку из эластика по, скажем, номеру телефона, начинают попадать запросы, не относящиеся к этому номеру телефона. потому что в сервисе-клиенте пул реиспользуемых коннектов с keepalive. процесс коннекта реиспользуется, а метаданные в нем переписываются не сразу.

а что из многочисленных datetime либ нормально умеет в вычисления с DST?

Tzdata has an automatic update capability that fetches updates from IANA and which is enabled by default awww

@nwalker tzdata - со своим желанием и писать в файловую систему, куда сама хочет и в интернет лазить по-своему усмотрению одно время немного попила крови.

Dmitry вот меня тоже заранее пугает

Раньше в ней эта опция лазить в интернет не отключалась, с нашей подачи теперь отключается ?

а вот это уже как-то жестко https://gist.github.com/nwalker/bcb7492657598dff59c7ea459e972c3e

это я timex в зависимости добавил

Кстати, по timex, есть у него возможность форматирования даты в гггг-мм-дд? Не нашёл форматтера для дня из 2 чисел, если день меньше 10 получается что-то типа 2018-10-1

@Slavenin {{2018, 2, 2}, {12, 0, 0}} |> NaiveDateTime.from_erl!() |> Timex.format!("%d/%m/%Y %H:%M:%S", :strftime) "02/02/2018 12:00:00" - Разве есть форматтер из одного числа для дня? Помойму из двух только.

Дефолтные форматтеры я смотрел

@Slavenin Timex.format!(date, "{YYYY}-{0M}-{0D}")

А, дефолтный вот так, я просто везде использую стандартизированный.

date = ~D[2016-02-02]; Timex.format!(date, "{YYYY}-{0M}-{0D}") "2016-02-02"

а что-нибудь типа rolify есть для ролевой модели? или превед велосипед?

@nwalker Ну, это tzdata тащит hackney и все его зависимости. В идеале - это должна быть опциональная зависимость, но так как мы всё равно везде так или иначе используем hackney - у нас не было проблем с тем, что у tzdata такие зависимости.

@nwalker Ну, это tzdata тащит hackney и все его зависимости. В идеале - это должна быть опциональная зависимость, но так как мы всё равно везде так или иначе используем hackney - у нас не было проблем с тем, что у tzdata такие зависимости.

весело то, что он полностью проигнорировал deps.get и тот факт, что у меня уже есть hackney в зависимостях.

А, в этом смысле)

короче, я не стал заморачиваться и оберну qdate_localtime

предварительно его обновив, пожалуй

Hello, Uladzimir! Please, calculate: 27+81=... If you don't answer - you'll get banned from the channel... Good luck!

Как думаете почему неимплементированые behaviors бросают только warning, а не прекращают компиляцию полностью?

Как если бы в ооп забили на интерфейс)

А почему другие warning не прекращают компиляцию?

Есть опция - превратить warning-и в ошибку.

Тогда они будут прекращать компиляцию.

Хорошая опция, только deprecated функции сторонних либок повалят все, хех

Сторонние Либы не валят, на сколько я знаю

потому что иногда даже не реализованный полностью behavior может работать. Например не реализовывать handle_cast вполне норм -- если никогда не кидать процессу gen_server:cast

Какая же штука классная Stream.concat, думал с Range и Stream.cycle не сработает - работает отлично ?

phoenix_ecto гарантирует, что все запросы к постгресу в рамках обработки одного http-запроса выполняются в одной сессии бд?

т.е. могу ли я в плаг засадить установку переменной сессии и быть уверенным, что она там останется во всех транзакциях, выполняемых из этого процесса?

@feymartynov phoenix_ecto не делает сам вообще никаких запросов к базе данных.

ну я имею ввиду стек phoenix и ecto

phoenix_ecto гарантирует, что все запросы к постгресу в рамках обработки одного http-запроса выполняются в одной сессии бд?

а что под сессией подразумевается?

сессия бд в постегресе

транзакция что ли?

нет, именно сессия

в рамках одной сессии может выполняться несколько транзакций

в рамках одной сессии может выполняться несколько транзакций

connection ?

к БД?

скажи уже что ты там придумал

у меня какое то дежа-вю, что-то типа того спрашивали три года назад

connection ?

ну почти

я придумал заиспользовать RLS в постгре

зачем тебе переменная?

типа как тут https://github.com/mbuhot/ecto_row_level_security

Насколько я знаю там пул соединений

я придумал заиспользовать RLS в постгре

да там пул соединений