Описание тега akka.net-streams

Вопросы с тегом
0 ответов

Читатель журнала Akka.net пропустил события

В нашем приложении мы используем Akka.net, с источником событий. Постоянные участники сохраняют свои события в базе данных SQL Server. У нас также есть акторы представлений, которые подписываются на эти события, используя запрос чтения журнала / пос…
30 авг '18 в 08:38
0 ответов

Akka.net создает собственный поток для mqtt

Мне нужно создать поток akka с помощью mqtt. случай использования: сообщения публикуются в канале mqtt, мне нужно получить эти сообщения в виде потока akka. пример использования будет выглядеть ниже. mqttstream. .Buffer(50, OverflowStrategy.DropHead…
10 янв '19 в 06:46
0 ответов

Akka.Net Streams - пакетная передача потоков с помощью GroupedWithin

Я тестирую потоки Akka.Net, чтобы посмотреть, смогу ли я интегрировать его в свой проект, и я немного запутался с GroupedWithin, Если я использую его таким образом, он не разделяет поток на части, но выполняется только один раз: Akka.Streams.Dsl.Sou…
24 янв '19 в 16:12
1 ответ

Akka.NET Streams

Как бы вы повторяли запрос веб-службы каждые десять секунд по десять раз, пока он не ответит? я пробовал RecoverWithRetries а также InitialDelay, но первое восстановление немедленно повторяет вызов веб-службы: FromThirdOfContract().RecoverWithRetrie…
11 сен '17 в 09:09
1 ответ

Отправка потока (например, файла) от актера к актеру

Я хочу отправить данные из потока одного актера в поток другого актера. В конце концов это должно работать с удаленными актерами. С Akka.NET Streams это должно быть легкой задачей, но, возможно, я неправильно понял это. Это часть SenderActor: var st…
27 июл '17 в 19:41
1 ответ

Почему мой подписчик Akka.NET Stream не получает сообщения?

Я пытаюсь написать простой поток потоков Akka.NET. Источник является IActorRef, Раковина ISubscriber, Я использую TestKit, чтобы реализовать его в качестве модульного теста: [Fact] public void AkkaStreams_ActorSourcePublisherSink_Works() { using (va…
04 фев '18 в 07:43
1 ответ

Это хорошая идея использовать кинезис для передачи сообщений в akka.net

В настоящее время мы создаем систему акторов с принципами DDD поверх Akka.NET. У нас есть несколько упущений в том, как сделать наш сервис более устойчивым: По крайней мере одна доставка по умолчанию между актерами Устойчивость актёров почтовых ящик…
18 янв '18 в 15:59
1 ответ

Создание источника асинхронного потока

У меня есть дорогой метод для вызова пакета исходных элементов: private Task<List<SourceItem>> GetUnprocessedBatch(int batchSize) { //impl } Я хочу заполнять новые элементы только тогда, когда нет элементов для обработки (или они опускаю…
25 май '19 в 19:02
1 ответ

Как поставить элементы в очередь в akka.net

Как я могу добавить элементы в очередь после создания источника очереди в потоках akka.net? В созданном объекте нет метода Enqueue, Add или Offer. Source<int, ISourceQueueWithComplete<int>> source = Source.Queue<int>(100, OverflowS…
14 май '19 в 15:16
1 ответ

Неправильное значение Akka.Streams.Amqp.IncomingMessage.Envelope.RoutingKey

Я пытаюсь прочитать входящее сообщение на RabbitMQ через Akka.streams.Ampq источник но RoutingKey это неверно. Еще один вопрос, касающийся того, что конверт не содержит обменного имени. //code coming back with incorrect key public void Consume(IActo…
01 авг '19 в 12:05
2 ответа

Как использовать Akka.Streams. *. ConcatMany в F#?

Я хочу создать поток, который создает новый источник (это будет запрос на сохранение) из входящих элементов, а затем сглаживает результаты. Что-то вроде этого упрощенного примера: var z = Source.Single(1).ConcatMany(i => Source.Single(i)); этот к…
21 окт '19 в 13:19
1 ответ

Akka.Net: Реактивные потоки по сети

Я пытаюсь реализовать как источник как источник, так и приемник как удаленный, а затем приемник как источник и источник как удаленные рабочие процессы типа 1 и типа 2 в AkkaStreamsModel соответственно. Тип 1 создает SourceRefи передает это удаленном…
04 май '20 в 11:37
1 ответ

Как интегрировать потоки Akka.Net с ядром AspNet или жирафом

Когда я использую Giraffe или ASP.Net Core в целом, я могу создать систему акторов, добавить ее как службу, а затем заставить ее думать, что обработчик запросов выберет любого актера и спросит / передаст сообщение. Либо с помощью Cluster.Sharding, л…
06 окт '20 в 01:32
0 ответов

Можно ли в Akka.Net получить актор TcpStream из актора Tcp?

Можно ли в Akka.Net получить актор TcpStream из актора Tcp? Я создал актера Tcp, используя Context.System.Tcp().Tell(new IoTcp.Connect(endPoint)); Затем я регистрируюсь как обработчик Sender.Tell(new IoTcp.Register(Self, true, true)); Конечная точка…
05 апр '21 в 10:35
0 ответов

Почему у Akka.net Streams низкая производительность

Итак, я прочитал 7 тем, связанных с производительностью потоков AKKA, но я все еще публикую этот вопрос, чтобы подтвердить свои выводы (что, выбирая использование потоков, вы, вероятно, получите снижение производительности в определенных ситуациях).…
23 июл '21 в 04:14
1 ответ

Простой TCP-сервер с Akka.NET

Привет, я учусь использовать Akka.net, и я хочу создать простой TCP-сервер, который будет периодически отправлять данные в TCP-соединение. (который затем будет выбран клиентом processingjs и отображен в выводе) Не уверен, что мне здесь не хватает. Н…
11 сен '21 в 13:32
0 ответов

Поддерживает ли Kafka создание прогнозов из потоков нескольких категорий?

Мы используем EventStore для нашего решения, основанного на событиях. Мы хотим экспортировать события в Kafka и выполнять потоковую обработку с помощью Kafka. В EventStore каждый тип потока относится к категории, например, Заказ, Клиент, Платеж и т.…
11 ноя '21 в 15:46
0 ответов

Реализация удаленной динамической потоковой передачи Akka.Net

Фон Я и моя команда создаем решение в рамках .Net Core Framework. Нам удалось реализовать как SinkRefпредложение и SourceRefпредложение согласно документации Akka.Net . Однако мы находимся в некотором роде препятствия с точки зрения лучших практик д…
04 мар '21 в 08:04
1 ответ

Как объединить события из двух систем Event Sourcing

Мне нужно объединить события, поступающие из двух разных систем поиска событий, которые обрабатывает модуль Akka.Net Persistence. Слияние должно сортировать события на основе их метки времени, и я нашел оператор MergeSorted в Akka.Stream, который де…
22 сен '22 в 10:28
0 ответов

Список всех снимков определенного актера Akka.Net в веб-интерфейсе

Мне нужна помощь в попытке выяснить Akka.Net для PoC Event-Source, который я создаю. Скажем, у меня есть система ввода заказов, в которой заказы моделируются как. Я разобрался с процессом отправки Команд в Орден, чтобы он сохранял соответствующие со…
08 авг '22 в 10:08