Исторически за консистентность данных отвечает БД, а не рантайм. В вашем распоряжении на выбор: оптимтстичные блокировки, пессимистичные блокировки, клиринговая логика... Сильные уровни изоляции транзакций (с сериализуемостью) и т.д. Для того, чтобы по нескольку раз не прлсить денег или не платить. А таймауты соединений - они всего лишь уменьшают вероятность, но не гарантируют отсутствие конфликтов. Это не уровень бизнес-логики.

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

Потом при сверке уже разгребать - дооказывать услугу пользователю при необходимости

Исторически за консистентность данных отвечает БД, а не рантайм. В вашем распоряжении на выбор: оптимтстичные блокировки, пессимистичные блокировки, клиринговая логика... Сильные уровни изоляции транзакций (с сериализуемостью) и т.д. Для того, чтобы по нескольку раз не прлсить денег или не платить. А таймауты соединений - они всего лишь уменьшают вероятность, но не гарантируют отсутствие конфликтов. Это не уровень бизнес-логики.

вот я тоже подумал как таймауты от RC могут спасти. Реально, только уменьшить вероятность. И что мешает написать без косяков?

Ну ребят вы что-то вообще

От всех проблем спасает стейтмашина или очередь

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

подскажите, есть ли уже какие-нибудь книги по phoenix 1.3?

подскажите, есть ли уже какие-нибудь книги по phoenix 1.3?

по моему она на где-то на подходе

по моему она на где-то на подходе

та, что programming phoenix 1.3? а по старой книжке получится нормально следовать?

та, что programming phoenix 1.3? а по старой книжке получится нормально следовать?

в целом получится, но там описана старая структура проекта, а в 1.3 новая

118

)

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

Save half on Phoenix in Action and these other selected books. Just enter mllessellt in the Promotional Code box when you check out. Expires Tuesday, December 26. Only at manning.com 

https://www.manning.com/books/phoenix-in-action?trk_msg=SUHOFFDSRA44J1CPDB3USITBI4&trk_contact=OOSFKR732SLEB9P9MV0RS4T51K&trk_sid=P62L7PK1VCG0B2FD25UINJMGBO&utm_source=Listrak&utm_medium=Email&utm_term=https%3a%2f%2fwww.manning.com%2fbooks%2fphoenix-in-action&utm_campaign=New+MEAP!+Half+off+Phoenix+in+Action+%2b+other+selected+books

народ, поможите, а? туплю безбожно. Есть необходимость сделать рассылку email нотификаций юзерам. Событий нотификации вагон и маленькая тележка — порядка 50. Хочу прикрутить GenStage для этого дела. То есть один broadcaster, который плюёт то или иное событие и его ловит нужный consumer. Не могу разобраться как сделать так, чтобы событие ловил только искомый consumer, а не все подряд

если я правильно помню, то там нет такой опции. надо велосипед городить

я даже как-то городил, но потом вообще отказался от генстейджа

народ, поможите, а? туплю безбожно. Есть необходимость сделать рассылку email нотификаций юзерам. Событий нотификации вагон и маленькая тележка — порядка 50. Хочу прикрутить GenStage для этого дела. То есть один broadcaster, который плюёт то или иное событие и его ловит нужный consumer. Не могу разобраться как сделать так, чтобы событие ловил только искомый consumer, а не все подряд

GenStage работает вообще не так

Он работает ровно наоборот

Консюмер запрашивает данные

может какой pubsub применять?

gproc или tasks

вот я и чую что где-то я накосячил :) Вроде бы говорили что GenStage заменил GenEvent

но, видять, я не понял нифига

не уверен что таски то, что мне нужно

Тебе нужен Phoenix.PubSub

идея такая: есть апи, оттуда прилетает некая структура (скажем, тип нотификации и id записи в базе). Это дело прилетает в модуль и он вызывает нужный хэдлер для конкртеной нотификации (ищем по типу)

ну и дальше уже генерим email и так далее

я нуб в эликсире, но с текущими знаниями я бы сделал так: прилетевшую структуру кладем в хранилище(бд или EST), запущенный GenStage(consumer просит у producer список записей для работы) смотрит в хранилище

думаю знатоки поправят что тут не так)

я нуб в эликсире, но с текущими знаниями я бы сделал так: прилетевшую структуру кладем в хранилище(бд или EST), запущенный GenStage(consumer просит у producer список записей для работы) смотрит в хранилище

хм, не лишено смысла :) Спасибо!

GenStage - это не замена GenEvent. GenStage - это реактивные потоки. Вернее, воплощение этой концепции: http://www.reactive-streams.org/

Если нужен сервис, который от апстрим-сервиса принимает, скажем, видеопоток по быстрому каналу и отдаёт даунстрим (клиенту) по медленному - вот тут как раз нужен GenStage, чтобы не заполнить всю память буферизованным потоком.

То есть, в ситуациях, когда данные поступают быстрее, чем отдаются, GenStage позволяет создавать обратное давление и работать в постоянном объёме памяти.

К данному кейсу не имеет отношения, но на будущее пригодится, думаю.

В каком кейсе вы называете сообщения через сокеты?

snake_case? или CamelCase? или lowerCameleCase?

junior_CustomCase

OBERONCASESTYLE!

uSeRnAmE

u53Rn4m3

ну или, как вариант, 0001, 0002, 0003

snake_case? или CamelCase? или lowerCameleCase?

снейком

l33tc4s3

kebab-case

⠇⠑⠑⠞⠉⠁⠎⠑ только придется распечатывать код с выпуклостями

чот напомнило https://forum.kinopoisk.ru/picture.php?albumid=2897&pictureid=57226

ERROR: S client not available

превьюшка не сработала, кину так

семисегментный по-ходу

циферок нету

циферок нету

они словами их пишут :)

хищники-гуманитарии

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

прописываю ему worker(Worker, [], restart: :permanent), у супервизора настройка :one_for_one

ну вообще-то да. send(self(), init) ... handle_info(init, ...)

Старт производится по статическому списку в Supervisor.start_link? Или динамически с помощью Supervisor.start_child?

Предполагаю, что первое. В этом случае официальная документация к Erlang OTP даёт ответ: To ensure a synchronized startup procedure, start_link/2,3 does not return until Module:init/1 has returned and all child processes have been started. И далее: If any child process start function fails or returns an error tuple or an erroneous value, the supervisor first terminates all already started child processes with reason shutdown and then terminate itself and returns {error, {shutdown, Reason}}.

Предполагаю, что первое. В этом случае официальная документация к Erlang OTP даёт ответ: To ensure a synchronized startup procedure, start_link/2,3 does not return until Module:init/1 has returned and all child processes have been started. И далее: If any child process start function fails or returns an error tuple or an erroneous value, the supervisor first terminates all already started child processes with reason shutdown and then terminate itself and returns {error, {shutdown, Reason}}.

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

В смысле, в если воркер кидает на старте исключение, то супервизор не только его не поднимает, но и сам не поднимается.

И это имеет смысл. Потому что все эти стратегии супервизирования и restart: :permanent относятся к той части жизненного цикла воркеров, когда они уже проинициализированы и принимают сообщения.

Если они не могут пройти инит - система неработоспособна.

Поэтому она падает, в соответствии с концепцией "Fail fast".

Ребят, хочу написать книжку на Manning по Devops в эликсире! Помогите определиться с содержанием )

Писать ли обзор редакторов для эликсир с плагинами?

Второй вопрос - distillery только, иди exrm тоже

Потом чем деплоить - bootleg, edelivery, Mina, Capistrano

Потом надо написать про билд тачки, стейдж тачки

Раскрутка их с помощью ansible

Потом контейнеризация в docker через swarm и kubernetes