все равно все из базы читаться будет

У нас тут премия Ванги напрашивается...

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

кейс - фреймоворк для оркестрации контейнеров, https://github.com/mesosphere/marathon нагрузка - у разных кастомеров по разному, например чуваки из China Unicom гоняют 37000 контейнеров

кейс - фреймоворк для оркестрации контейнеров, https://github.com/mesosphere/marathon нагрузка - у разных кастомеров по разному, например чуваки из China Unicom гоняют 37000 контейнеров

а где было горлышко, если не секрет?

а где было горлышко, если не секрет?

я бы тоже хотел это знать :)

просто в каком-то акторе все падало и не ясно в каком?

а где было горлышко, если не секрет?

Между стулом и экраном было)

просто в каком-то акторе все падало и не ясно в каком?

я не думаю что это вина какого-то одного актора

я не думаю что это вина какого-то одного актора

просто ловили оом и переписали все?

или на стадии прототипа валилось ?

ловили OOM пока не переписали пару кусов на стримы, и сейчас стало стабильнее

У меня марафон недавно падал от Оом на ровном месте) ничего страшного, главное что обратно встал

привет

никак не могу найти пул акторов в акке. Там есть такое вообще ?

никак не могу найти пул акторов в акке. Там есть такое вообще ?

Есть

роуты вот какие то есть

никак не могу найти пул акторов в акке. Там есть такое вообще ?

пулл акторов? а заче ищите ?

ну у меня есть много запросов и мне надо писать их в кафку с помощью KafkaProducer. по уму же надо пул кафка продусеров иметь, не?

походу роутеры это то что мне нужно

ну у меня есть много запросов и мне надо писать их в кафку с помощью KafkaProducer. по уму же надо пул кафка продусеров иметь, не?

Думаю по уму посмотреть в сторону стримов

а что мне стримы. У меня запросы приходят не пачками.

стримы и батчи умеют

ну для начала я таки попробую роуты. И еще вопрос. А есть ли в акке аналог gen_server в ерланге? чтобы можно было синхронно посылать сообщение. Ну то есть вызывающий процесс шлет сообщение и ждет ответного сообщения?

можно но зачем ?

ask ждет ответа

нужны ли акторы если нужна синхронность ?

ask не ждёт, фьючку возвращает

можно либо блокироваться на фьючке, либо использовать Inbox

идея у меня простая. Собственно приходит http запрос. Допустим он представляет из себя отдельный процесс. В этом процессе я дергаю из пула один KafkaProducer(процесс с вызовом KafkaProducer) и делаю к нему синхронный запрос, который возвращает результат записи в кафку. ну и я возвращаю клиенту что все хорошо

правда чот я щас подумал и понял, зачем мне пул процессов если я могу просто шарить пул экземпляров KafkaProducer

или чего то такое

зачем это делать синхронно?

Если нужно организовать работу с ресурсом, выделяйте под этот ресурс актор. Он будет работать с ним синхронно (последовательно). А клиент пусть асинхронным остаётся

идея у меня простая. Собственно приходит http запрос. Допустим он представляет из себя отдельный процесс. В этом процессе я дергаю из пула один KafkaProducer(процесс с вызовом KafkaProducer) и делаю к нему синхронный запрос, который возвращает результат записи в кафку. ну и я возвращаю клиенту что все хорошо

а зачем тут акторы ?

зачем это делать синхронно?

потому что мне кажется что я пытаюсь натянуть то как делается в ерланге на скалу

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

а зачем тут акторы ?

а че бы нет)

в ерланге ты спаунишь пул коннектов - процессов к базе например. Берешь из пула один процесс и шлешь ему сообщение, он пишет в базу и отсылает тебе сообщение когда готово. Когда процесс находится в состтоянии receive шедулер переключает контекст на другой процесс. С точки зрения пользователя апи это синхронно выглядит

Тогда юзай ask, с логикой на onComplete

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

там любят эт через стримы делать)

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

ну так сделай как в скале через стримы а не через акторы

отбой. Пишут мол одного продусера достаточно

https://community.cloudera.com/t5/Cloudera-Labs/Kafka-Producer-Connection-Pool-is-required-or-not/td-p/58720

не будет акторов ?

ну здесь видимо нет

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

jta? Но лучше никак

хз как мне jta тут поможет, лучше конечно да) вариантов нет

если взять quill то там открываем 2 тразы получает 2 executioncontext выполняем в каждом свое через flatmap и если где-то фейлится то фейлятся Future и все норм, а тут не могу сообразить

ты не можешь взять две базы и научить их "слушать" транзакции друг друга

одна база моя, другая хужая, в чужую доступа нет

если взять quill то там открываем 2 тразы получает 2 executioncontext выполняем в каждом свое через flatmap и если где-то фейлится то фейлятся Future и все норм, а тут не могу сообразить

Transactor.after.set ... не подойдет?

щас зугуглю

это старый синтаксис, я не смотрел особо, что в новом дуби)

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

да, положи себе мину замедленного действия

ахаха))

год живу с ней

да, положи себе мину замедленного действия

не о тех минах разговор

год живу с ней

а что не так с дуби? (интересно)

квилл бы лучше предпочел дуби?

сколько я понял это заява про распределенную тразу через 2 базы

а

дуби норм) у квила свои приколы

ERROR: S client not available

дуби норм) у квила свои приколы

Только сегодня слушал подкаст, где за квил высказали что он плохой.

он не однозначный

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

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

и если ты написал что-то не тривиальное - потом запаришься разбирать где какую часть AST он не разобрал

jooq?

из-за его приколов с AST часто не может скомпилить очевидные вещи, приходится извращаться в итоге уходит куча времени на выходной SQL ужасен

я пока ближе к тому что нужно что типа doobie, scalikejdbc, anorm и писать самому SQL. На каждый написать тест и все. Все эти генераторы - сомнительный профит

jooq?

побойся бога, как будто слика недостаточно

из-за его приколов с AST часто не может скомпилить очевидные вещи, приходится извращаться в итоге уходит куча времени на выходной SQL ужасен

Just lol

побойся бога, как будто слика недостаточно

его почему-то в подкасте не рассмотрели

Еще гибернейт не расмотрели! Ироді!

А с жуком все так плохо?

jdbc)

scalikejdbc тогда

зачем нужен jooq, если и так слик есть с этой же функциональностью?

зачем нужен jooq, если и так слик есть с этой же функциональностью?

Jooq это всё таки ближе к sql dsl из scalike

А doobie умеет джойнить?

А doobie умеет джойнить?

Он умеет исполнять любые запросы

На выходе что? Голый result set или там есть orm часть?

Hl, tuple, case class

Что пожелаешь

То есть если есть джойн в запросе то можно сделать на выходе case class в вложенными объектами?

Или все ручками собирать?

на выходе ты получишь последоватльнгсть полей которые выбрал

Можно сделать

во что ты это превратишь - реашть тебе

Окей спс. Есть ещё skinny orm фреймворк, простой но много что умеет

https://typelevel.org/cats/typeclasses/parallel.html Как-то я упустил этот тапкласс. Что теперь можно монаду с параллелем без аппликатива пользовать?

он похоже в 1.0 появился

Интересно как в мониксе 3 запиливают аппликатив

Интересно как в мониксе 3 запиливают аппликатив

Там скорее io запиливают