Описание тега backpressure
Противодавление относится к накоплению данных на переключателе ввода-вывода, когда буферы заполнены и не могут принимать дополнительные данные. Никакие дополнительные пакеты данных не передаются, пока не будет устранено узкое место в данных или не опустошен буфер.
1
ответ
Как уменьшить скорость приема Kafka Spout и включить противодавление?
Я использую storm-kafka-client 1.1.1 и storm-core 1.1.0. Я настроил следующие параметры, но не смог включить противодавление и снизить скорость приема кафки-излива. Носик потребляет 2000 сообщений в секунду. Для обработки сообщения нисходящему болту…
23 фев '18 в 05:00
0
ответов
Является ли Request Coalescing просто еще одним названием противодавления?
Мне интересно, если объединение запроса и обратное давление - это одно и то же? Или запрос объединяет только реализацию обратного давления? Для меня это означает, что "если запросов слишком много, не отправляйте их сразу". Хум, после второй мысли: М…
01 дек '18 в 23:28
1
ответ
Наблюдаемое противодавление в зависимости от дефицита ресурсов
В RxJava 1 / RxScala, как я могу регулировать / подавлять источник, наблюдаемый в следующей ситуации? def fast: Observable[Foo] // Supports backpressure def afterExpensiveOp: Observable[Bar] = fast.flatMap(foo => Observable.from(expensiveOp(foo))…
09 ноя '16 в 15:07
1
ответ
Акселерометр RxJava Противодавление
Возникли проблемы с противодавлением. Использование субъекта публикации для получения события датчика при отправке и необходимость сохранения данных в базе данных при подписке на предмет в транзакции. Я пытался использовать оператор.window(100), что…
25 май '16 в 21:33
1
ответ
Как реализовать поток, который правильно обрабатывает противодавление в node.js?
Я не могу понять, как реализовать поток, который правильно обрабатывает противодавление. Вы никогда не должны использовать паузу и возобновить? У меня есть эта реализация, я пытаюсь заставить работать правильно: var StreamPeeker = exports.StreamPeek…
27 мар '15 в 19:37
0
ответов
Ошибка при использовании SparkReceiever и StreamingListener для противодавления
Я создал SparkEventReciever и StreamingListener для моего приложения. Мы читаем данные из rabbitMq и сохраняем их в Spark Store. Эта задача работала нормально, пока я не добавил туда логику противодавления (задержки планирования). Итак, я использую …
29 мар '18 в 14:49
0
ответов
Проверьте текущий уровень обратного давления в потоке Node.js.
Есть ли способ в Node.js проверить состояние обратного давления потока? Например, чтобы сравнить его с отметкой максимальной воды. Мой пример использования находится внутри модульных тестов, я хотел бы убедиться, что плагин Transform Stream истощает…
30 ноя '14 в 06:56
2
ответа
Как регулировать запись запроса на кассандру при работе с "executeAsync"?
Я использую драйвер datastax java 3.1.0 для подключения к кластеру cassandra, и моя версия кластера cassandra - 2.0.10. Я пишу асинхронно с последовательностью QUORUM. private final ExecutorService executorService = Executors.newFixedThreadPool(10);…
08 дек '16 в 22:12
2
ответа
RxJS возьми сначала дроссель и жди
Я хочу наблюдать за mousewheel событие, использующее RxJS-DOM, чтобы при первом событии я включал его, а затем отбрасывал все значения до тех пор, пока задержка между последующими значениями не пройдет ранее заданную продолжительность. Оператор, кот…
19 май '16 в 23:06
0
ответов
Потребность в весеннем запуске веб-приложения для реализации примера противодавления с помощью webflux
Мне нужно приложение весенней загрузки, которое реализует противодавление с помощью webflux
01 сен '18 в 14:14
1
ответ
Node.js: неправильно написано лишних байтов при обратном давлении в доступном для записи потоке
Я сделал простую двоичную передачу с Socket.io для передачи файла на сервер от клиента. Я думал, что это работает, но я понял, что размер файла был другим. При сбое writableStream.write я прикрепил обработчик события стока, чтобы подождать, пока он …
24 ноя '16 в 05:32
2
ответа
RxJava onBackpressureBuffer не излучает элементы
Я наблюдал странное поведение с onBackpressureBuffer, я не уверен, является ли это допустимым поведением или ошибкой. У меня есть вызов TCP, который испускает элементы с определенной скоростью (с использованием потоковой передачи и inputStream, но э…
20 окт '16 в 08:55
1
ответ
Spark Streaming Kafka противодавление
У нас есть приложение Spark Streaming, которое считывает данные из очереди Kafka в приемнике и выполняет некоторые преобразования и вывод в HDFS. Интервал между партиями составляет 1 мин, мы уже настроили обратное давление и spark.streaming.receiver…
15 апр '16 в 07:57
0
ответов
Выборочное регулирование запросов с использованием потока akka-http
У меня есть один API, который вызывает два других нисходящих API. Один нижестоящий API (https://test/foo) очень важно, и это очень быстро. Еще один медленный вниз по течению API (https://test/bar) имеет ограничение, пропускная способность которого …
30 окт '17 в 13:33
1
ответ
Есть ли у C# реализация gRPC обратное давление потоковой передачи?
У меня есть служба gRPC, которая принимает потоковые сообщения от клиента. Клиент отправляет сообщения с конечной последовательностью на сервер с высокой скоростью. В результате сервер буферизует большое количество сообщений (> 1 ГБ), и его использо…
10 янв '18 в 16:31
1
ответ
Шина сообщений и Quasar/HTTP для внутренних вызовов микросервиса
Я пытаюсь оптимизировать микросервисную архитектуру, которая в настоящее время использует HTTP/REST для внутренней связи между узлами. Одним из вариантов является реализация возможности обратного давления в сервисах (например) путем интеграции чего-…
12 авг '15 в 19:08
1
ответ
WebRTC DataChannel поток / контроль / противодавление
API RTCDataChannel не обеспечивает какой-либо вид потока / управления или противодавления, означает ли это, что отправитель теоретически может вызвать сбой браузера получателя? По моему мнению, браузер (Chrome, Firefox и т. Д. Все используют SCTP по…
21 ноя '14 в 09:27
1
ответ
Как обработать RxJS потоком n элементов за раз, и как только элемент будет завершен, снова автоматически заполните n?
У меня есть поток событий, и я хотел бы вызвать функцию, которая возвращает обещание для каждого из этих событий, проблема в том, что эта функция очень дорогая, поэтому я хотел бы обрабатывать не более n событий одновременно. Эта диаграмма гальки, в…
26 июл '16 в 23:28
1
ответ
Как использовать Akka BoundedMailBox, чтобы душить производителя
У меня есть два актера, один производит сообщения, а другой потребляет сообщения с фиксированной скоростью. Можно ли ограничить производителя потребителями BoundedMailBox? (обратное давление) Мой продюсер в настоящее время периодически намечает (отп…
11 май '13 в 18:20
1
ответ
RxJava 1.x: Как имитировать противодавление в модульном тесте
Учитывая код: logItemPublisher .buffer( loggingProperties.getBufferTimeoutMillis(), TimeUnit.MILLISECONDS, loggingProperties.getBufferSize(), logDispatchScheduler ) .onBackpressureDrop(droppedLogsHandler) // persist uses Spring RestOperations .flatM…
14 сен '18 в 23:20