Описание тега akka-stream
Akka implementation for handling streaming data on the JVM
1
ответ
Akka Streams, тайм-аут, если время между завершенной обработкой одного элемента до следующей обработки
Я хочу, чтобы мой поток не работал, если время между завершением обработки одного элемента и началом обработки следующего элемента превышает определенное количество. Похоже, что ни один из существующих методов тайм-аута не имеет отношения к этому сл…
11 апр '18 в 17:41
1
ответ
Является ли обработка в Sink.fold() сериализованной в Akka Streams?
Я начинаю с потоков Akka; Я пытаюсь создать поток, который читает данные из веб-службы, а затем сохраняет их в S3. Мне было интересно, если я определю Sink, используя метод Sink.fold (для сбора информации о постоянных элементах) для сохранения, буду…
06 апр '16 в 20:03
1
ответ
Scala потоковая передача живого / растущего файла
Мое приложение Scala запускает внешний процесс, который записывает файл на диск. В отдельном потоке я хочу прочитать этот файл и скопировать его содержимое в OutputStream пока процесс не будет завершен и файл больше не будет расти. Есть несколько кр…
21 апр '18 в 23:32
1
ответ
Скачать указанный файл с потоками Акка?
Для следующего кода мне нужно, чтобы клиент отправил имя файла на сервер, чтобы сервер мог ответить клиенту на содержимое указанного файла. Это может сработать, если я не укажу имя файла, просто жесткое кодирование в серверной части, но как клиент с…
02 фев '18 в 08:02
1
ответ
Кафка Коннект против Акка-стрим Кафка
Я собираюсь внедрить потоковую инфраструктуру для своей организации на основе Kafka и Spark. Тем не менее, я озадачен, решив, как лучше поступить, когда дело доходит до приема данных в Кафке. Многие решения действительно возможны для этой задачи Сам…
03 авг '17 в 13:24
1
ответ
Как отправить в реальном времени количество активных подключений WebSocket через HTTP WebSocket Akka? (работает только с Akka Streams)
Как можно посчитать в реальном времени количество активных подключений WebSocket через Akka WebSocket? Кажется, что Akka HTTP WebSockets изменяет ход предварительной подготовки Akka Stream. В первом блоке кода, приведенном ниже, счетчик отправляется…
06 сен '17 в 19:04
1
ответ
HTTP-поток Akka не останавливается при возникновении исключения
Я пытаюсь использовать Akka HTTP для размещения на веб-сервере. Если POST терпит неудачу, я хотел бы, чтобы он прекратил и не отправлял больше POST, поскольку они не являются идемпотентными. Приведенный ниже код создает сообщения POST и отправляет и…
09 май '16 в 16:17
1
ответ
Что означают параметры типа для Source<Out, Mat>?
Я пытаюсь понять тип источника для потоков Akka, указанный здесь. К сожалению, документация и примеры, которые я нашел, не объясняют, что на самом деле означает каждый из параметров типа. Я предполагаю, что Out это тип, который источник излучает при…
13 дек '16 в 19:57
0
ответов
Выполнение события akka-persistence-cassandra задерживается из-за пропущенных событий
Как часть кода akka-persistence-cassandra - событие, которое приходит с порядковым номером!= 1, инициирует поиск отсутствующей процедуры в случае, если порядковый номер 1 отсутствует в текущем временном интервале. Поскольку события для одного и того…
05 ноя '18 в 10:02
1
ответ
Написать GeoLocation Twitter4J в Postgres
Я извлекаю твиты, используя Twitter4J и Akka Streams. Я выбрал несколько полей, таких как userId, tweetId, tweet text и так далее. Эта сущность Tweet записывается в базу данных: class Counter extends StatusAdapter with Databases{ implicit val system…
10 янв '18 в 08:37
2
ответа
Мойка для построчного файла IO с противодавлением
У меня есть задание по обработке файлов, которое в настоящее время использует акторы akka с управляемым вручную противодавлением для обработки конвейера обработки, но мне никогда не удавалось успешно справиться с противодавлением на этапе чтения вхо…
15 апр '16 в 21:06
1
ответ
Распространение контекста через анализатор и тело действия в игровой среде
Я распространил информацию трассировки, которая передается с запросами между службами в заголовках HTTP (специально для opentracing). Я хотел бы, чтобы эта информация была доступна везде, чтобы я мог включить идентификатор трассировки в журналы, рас…
24 апр '18 в 20:50
1
ответ
Тестирование потока Akka, содержащего поток cachedHostConnectionPool Akka Http
Любые идеи о том, как лучше всего протестировать Akka Stream, содержащий Akka Http Flow? Я борюсь со следующим методом, в частности: def akkaHttpFlow(server: String)(implicit actorSystem: ActorSystem, actorMaterializer: ActorMaterializer) = { val ur…
28 янв '18 в 21:03
1
ответ
Как сделать поток источника Акка FIFO очереди?
Я разрабатываю систему торговли акциями с использованием Акки. Я предлагаю книги заказов в TradeQueue, как показано ниже: val tradeQueue = Source.queue[TradeTask](1, OverflowStrategy.backpressure) .map(task=>{ println("TradeTask Start："+task) tas…
22 май '18 в 13:40
1
ответ
Ничто не приходит в Раковину, определенную также
Кроме того, кажется, не работает для меня. Предметы не приходят в тонуть, определенные в нем. Вот что у меня есть. val merged: Source[ArticleWithKeywords, _] = ... val (ks, fut) = merged .alsoTo(Flow[ArticleWithKeywords].map { a => a.id -> a.i…
05 мар '17 в 11:04
1
ответ
akka-http отвечает исходящим ответом, если не удалось
Я звоню по внешнему API и хочу вернуть пользователю результат "КАК ЕСТЬ", если код состояния отличается от " ОК": val connectionFlow: Flow[HttpRequest, HttpResponse, Future[Http.OutgoingConnection]] = Http().outgoingConnection("akka.io") def respons…
14 дек '16 в 13:53
0
ответов
Scala + Akka Streams + libgdx + gradle = мне трудно
Я пытаюсь провести эксперимент... Я пытался следовать руководству по потокам akka и libgdx, но хотел, чтобы мой проект использовал gradle вместо sbt (я думаю, что в будущем, если я захочу сделать больше, это будет для меня будет более тривиально выя…
27 авг '17 в 02:34
1
ответ
Как обрабатывать и сортировать большие сообщения в Reactive Kafka с помощью Akka-Stream
Можно ли при отправке большого файла с помощью Kafka распределить его по разделам, а затем повторно собрать с помощью Akka-Stream? как описано в этой презентации: http://www.slideshare.net/JiangjieQin/handle-large-messages-in-apache-kafka-58692297
30 сен '16 в 23:54
0
ответов
Как создать исходный текст Akka из клиента RestApi
Я хочу, чтобы потоковые объекты, которые читаются через Java-клиент RestApi. Клиент читает набор данных постраничным способом. Решение, которое я придумал, состояло в том, чтобы создать Источник из Итерируемого, где эта итерация лениво загружает стр…
02 дек '18 в 10:18
2
ответа
Переход от socko к веб-сокетам akka-http
У меня есть приложение akka, основанное на soso websockets. Связь с сокетами происходит внутри одного субъекта, а сообщения, выходящие из субъекта и входящие в него (входящие и исходящие сообщения соответственно), помечаются идентификатором сокета, …
26 май '16 в 19:12