Вопросы по теме 'akka-stream'
Обработка ошибок / исключений Iteratees против реактивных потоков / akka-stream
Неожиданный сюрприз, у меня есть несколько проблем с Iteratees и обработкой ошибок.
Проблема;
Прочтите несколько байтов из InputStream (из сети, должно быть InputStream), сделайте несколько фрагментов / группировок в этом InputStream (для...
565 просмотров
schedule
17.08.2022
Использование mapFuture в потоках akka
Я играю с Akka Streams и пытаюсь немного обогатить и обработать события, полученные из коллекции MongoDB. Однако у меня есть некоторые сомнения относительно наилучшего подхода к реализации моих средств обогащения событий, которым может потребоваться...
524 просмотров
schedule
20.12.2022
Как предоставить абоненту возможность маршрутизации
У меня есть следующий путь для потока -
kafkaStream[message] ->
kafkaStream[message] -> mergedKafkaStream[message] -> stream[EnrichedMessage] -> I/O
kafkaStream[message] ->
Я не уверен, как написать это в потоке akka. Я...
412 просмотров
schedule
25.10.2022
Как подписаться на реализацию реактивных потоков, работающую на другой JVM?
Предположим, у нас есть два потока Akka Stream, каждый из которых работает на собственной JVM.
// A reactive streams publisher running on JVM 1:
val stringPublisher: Publisher[String] = Source(() => "Lorem...
493 просмотров
schedule
16.12.2023
Интеграция Актера на основе ack с akka-stream
У меня есть Актер, который был разработан для работы с подтверждением akka-io, так что он будет ждать подтверждения при отправке сообщений вверх по течению (в сеть). Этот актор является интерфейсом к асинхронному приложению в бэкенде.
Я хотел бы...
1317 просмотров
schedule
05.01.2023
Доступ к базовому объекту ActorRef потока akka Источник, созданный Source.actorRef
Я пытаюсь использовать Source.actorRef для создания akka.stream.scaladsl.Source объект. Что-то в форме
import akka.stream.OverflowStrategy.fail
import akka.stream.scaladsl.Source
case class Weather(zip : String, temp : Double, raining :...
8077 просмотров
schedule
31.08.2022
Как ответить результатом звонка актера?
Мы рассматриваем использование Akka-HTTP Java API - использование Routing DSL.
Непонятно, как использовать функцию маршрутизации для ответа на HttpRequest; с использованием нетипизированного актера Akka. Например, после сопоставления пути...
1845 просмотров
schedule
19.03.2023
Создание актера-издателя и актера-подписчика с одним и тем же актером
Я новичок в akka streams. Я использую kafka в качестве источника (используя библиотеку ReactiveKafka) и выполняю некоторую обработку данных через поток и использую подписчика (EsHandler) в качестве приемника.
Теперь мне нужно обработать ошибки и...
1875 просмотров
schedule
07.02.2023
Как правильно работать с результатами потоковой передачи slick 3.0.0 и Postgresql?
Я пытаюсь понять, как работать с гладкой потоковой передачей. Я использую slick 3.0.0 с драйвером postgres.
Ситуация следующая: сервер должен отдавать клиенту последовательности данных, разбитых на чанки, ограниченные по размеру (в байтах). Итак,...
4585 просмотров
schedule
22.01.2023
Использует ли Akka Streams Akka Actors?
Я начал изучать потоки Akka , который представляет собой платформу для обработки данных с функцией обратного давления. Библиотека является частью Akka , которая описывает себя как:
Akka - это набор инструментов и среда выполнения для...
606 просмотров
schedule
03.12.2022
Akka-streams: Как подключить поток к потоку?
Если поток А производит
Pair<Source<ByteString,?>, Object>
Как мне соединить этот выход с входом потока B, который отображается на источнике. Например, выход потока B будет
Pair<InputStream<Long>,Object>.
562 просмотров
schedule
21.07.2023
Потоковая передача CSV-файла в браузер с помощью akka stream и spray
Как подключить Source[String, Unit] к потоковому актеру?
Я думаю, что это модифицированная версия StreamingActor из https://gist.github.com/whysoserious/96050c6b4bd5fedb6e33 . будет работать хорошо, но у меня возникли трудности с соединением...
1059 просмотров
schedule
08.11.2022
Как контрамапировать акка-потоки Sink
Имея akka-streams Sink :
val sink: Sink[Foo, Any] = ???
и функция от Bar до Foo :
val f: Bar => Foo = ???
Я хочу contramap (противоположность map ) sink с f , чтобы получить сток типа Sink[Bar, Any] , но не могу найти...
489 просмотров
schedule
11.02.2023
Извлечение заголовка пути в директивах Akka
Я использую директивы akka для соответствия определенному шаблону пути:
/item/quantity
Примеры были бы
/apples/100
/bananas/200
Возможные элементы (например, яблоки, бананы и т. д.) заранее неизвестны, поэтому жесткое кодирование...
5716 просмотров
schedule
10.07.2022
Akka-streams — как получить доступ к материализованному значению потока
Я учусь работать с потоками Akka, и мне это очень нравится, но часть материализации все еще остается для меня загадкой.
Цитата из...
3318 просмотров
schedule
08.08.2022
Как начать работу с Akka Streams?
Библиотека Akka Streams уже поставляется с большим количеством богатой документации . . Однако главная проблема для меня в том, что он дает слишком много материала — я чувствую себя совершенно подавленным количеством понятий, которые мне нужно...
34741 просмотров
schedule
15.09.2022
Назначение процессора Akka Reactive Streams
Я пытаюсь понять реактивные потоки в акке. Я прочитал этот блог http://bryangilbert.com/blog/2015/02/04/akka-reactive-streams/ и, кажется, я понял, как это работает. Однако я не понимаю цели процессора в рамках этой концепции. Для чего это?...
272 просмотров
schedule
31.07.2023
Полоса загрузки с потоковой передачей Akka
Возможно ли иметь какую-то полосу загрузки с потоковой передачей Akka? Я ищу что-то, что может дать состояние продвижения источника.
Source via loadingBar(expectedElment) via someThingElse to Sink
где expectedElement — количество...
520 просмотров
schedule
21.03.2024
функция потоковой передачи искры время подачи искры через исключение
Я новичок в искровом стриминге.
когда я запускаю функцию потоковой передачи искры как обычное приложение scala, оно работает, как и ожидалось.
Я могу зафиксировать свое событие kafka и сохранить его в самом hdfs.
когда я пытаюсь запустить...
175 просмотров
schedule
18.12.2022
С игрой и akka-https: как правильно связать несколько запросов с входящим запросом, чтобы создать ответ?
Поэтому я попытался заставить небольшое игровое приложение общаться с другой службой отдыха. Идея состоит в том, чтобы получить запрос на стороне воспроизведения, а затем сделать запрос к остальным API и передать части результата другому локальному...
381 просмотров
schedule
06.05.2023
