Вопросы по теме 'akka-stream'
Потоковая передача Akka-http с использованием Slick 3.0 Databasepublisher
Я использую slick 3.0 и имею объект databasepublisher как
def getAsStream = db.stream[Entity](tblquery.result)
Я использую akka-http для остальных слоев следующим образом:
val route =
path("stream"){
get {
complete { // how to...
910 просмотров
schedule
12.05.2022
Как преобразовать Source[ByteString, Any] в InputStream
akka-http представляет файл, загруженный с использованием кодировки multipart/form-data как Source[ByteString, Any] . Мне нужно распаковать его с помощью библиотеки Java, которая ожидает InputStream .
Как Source[ByteString, Any] можно...
14424 просмотров
schedule
04.01.2023
Живые ресурсы в описании потока Akka Stream
Это примечание есть в документах akka-stream. заявив следующее:
… многократно используемое описание потока не может быть привязано к «живым» ресурсам, любое подключение или выделение таких ресурсов должно быть отложено до времени...
311 просмотров
schedule
14.12.2022
Как получить подписчика и издателя из транслируемого потока Akka?
У меня возникают проблемы с удалением издателей и подписчиков из моих потоков при использовании более сложных графиков. Моя цель - предоставить API издателей и подписчиков и запустить потоковую передачу Akka внутри. Вот моя первая попытка, которая...
1388 просмотров
schedule
07.03.2023
Источник на основе издателя не выводит элементы
Я сделал источник для потока Akka на основе ReactiveStreams Publisher следующим образом:
object FlickrSource {
val apiKey = Play.current.configuration.getString("flickr.apikey")
val flickrUserId =...
90 просмотров
schedule
08.10.2022
В akka-stream как создать неупорядоченный источник из коллекции фьючерсов
Мне нужно создать akka.stream.scaladsl.Source[T, Unit] из коллекции Future[T] .
Например, имея коллекцию фьючерсов, возвращающих целые числа,
val f1: Future[Int] = ???
val f2: Future[Int] = ???
val fN: Future[Int] = ???
val futures =...
3306 просмотров
schedule
27.12.2022
Почему цикл потоков Akka не заканчивается на этом графике?
Я хотел бы создать график, который зацикливается n раз, прежде чем утонет. Я только что создал этот образец, который соответствует моим требованиям, но не заканчивается после того, как он утонет, и я действительно не понимаю, почему. Может ли...
1730 просмотров
schedule
08.07.2022
Scala Akka Stream: как пройти через последовательность
Я пытаюсь обернуть некоторые блокирующие вызовы в Future . Тип возвращаемого значения — Seq[User] , где User — это case class . Следующее просто не будет компилироваться с жалобами на наличие различных перегруженных версий. Какие-либо...
5303 просмотров
schedule
14.08.2022
Как получить материализованный результат от Akka Stream Graph?
Я пытаюсь понять, как получить материализованный результат из графика scala Akka Stream.
Я использую "com.typesafe.akka" %% "akka-stream-experimental" % "1.0" .
Я просмотрел документы , но смог не найти ни одного примера.
Итак, допустим, у...
359 просмотров
schedule
21.02.2023
Запрос tcp к базе с потоками akka
Я пытаюсь отправить запрос в базу данных с помощью клиента Tcp akka-streams, но я не понимаю, что мне не хватает.
Итак, у меня есть два типа Query и Response , которые прекрасно конвертируются в ByteString akka и обратно. Итак, я создаю...
548 просмотров
schedule
19.01.2023
Как создать поток Akka с истинным потоком извлечения с асинхронными этапами
Я пытаюсь создать источник, который предоставляет токены OAuth2, а также заботится об обновлении токенов с истекшим сроком действия. В настоящее время мой код выглядит примерно так
case class Token(expires: Instant = Instant.now().plus(100,...
833 просмотров
schedule
21.01.2023
Akka-HTTP: загрузка файла
Я пытаюсь реализовать простую загрузку файлов с помощью akka http. Моя попытка выглядит следующим образом:
import akka.actor.ActorSystem
import akka.event.{LoggingAdapter, Logging}
import akka.http.scaladsl.Http
import...
2712 просмотров
schedule
01.07.2023
Scala читает непрерывный http-поток
Как я могу подключиться и прочитать непрерывный (разделенный) поток http в scala? Например, если у меня есть этот простой сервис, написанный на python/bottle:
from gevent import monkey; monkey.patch_all()
import gevent
from bottle import route,...
765 просмотров
schedule
26.07.2023
akka http: потоки Akka против актеров для создания сервиса отдыха
Когда дело доходит до создания веб-службы REST с 60+ API на akka http. Как я могу выбрать, что мне следует использовать: потоки акка или актеры акка? В своем сообщении Джос показывает два способа создания API на akka http, но не показывает, когда...
6126 просмотров
schedule
05.07.2022
Как отлаживать потоки akka?
Когда я ставлю точку останова где-то в методе processLine, отладчик не останавливается на этой строке. Он выполняется так, как будто точки останова нет. Отладка потоков akka несколько отличается, как я могу решить эту проблему?
val stream =...
1384 просмотров
schedule
22.12.2022
Утечка groupBy в akka-stream?
Я хочу написать поток на akka-stream для группировки событий из бесконечного потока по session_uid и рассчитать сумму трафика для каждого сеанса (подробности в моем предыдущий вопрос ).
Я собираюсь использовать функцию Source#groupBy для...
1007 просмотров
schedule
22.02.2023
обратное давление неправильно обрабатывается в akka-streams
Я написал простой поток, используя API akka-streams, предполагая, что он будет обрабатывать мой источник, но, к сожалению, это не так. Я уверен, что делаю что-то не так в своем источнике. Я просто создал итератор, который генерирует очень большое...
122 просмотров
schedule
22.08.2023
Хранение клиентских сессий на сервере akka-http
Как в службе akka-http кэшировать некоторую информацию для каждого сеанса клиента? Это не совсем очевидно в документах. Например, я хотел бы создать актера для каждого соединения.
Где я должен создать актера и как мне получить ссылку на него...
1217 просмотров
schedule
22.09.2022
Akka streams - выбросить сообщение
У меня есть поток, который выглядит так:
case class T1 extends A
case class T2 extends A
case class T3 extends A
val proc: Flow[A, B, Unit] = Flow[A] .map {
case x: T1 => B()
case x: T2 => B()
case x: T3 =>...
189 просмотров
schedule
04.09.2022
Балансировка нагрузки akka-http
Я использую akka-http, моя конфигурация build.sbt такова:
scalaVersion := "2.11.7"
libraryDependencies += "com.typesafe.akka" % "akka-actor_2.11" % "2.4.2"
libraryDependencies += "com.typesafe.akka" % "akka-http-experimental_2.11" % "2.4.2"...
1723 просмотров
schedule
12.10.2022
