Вопросы, помеченные тегом «publish-subscribe»

Публикация / подписка - это шаблон обмена сообщениями, при котором отправители (издатели) сообщений не программируют сообщения для отправки непосредственно конкретным получателям (подписчикам). Скорее, опубликованные сообщения классифицируются по каналам без знания того, какие подписчики там могут быть, если таковые имеются.
avatar
Rillian Diello Lucas Pires
8 августа 2021 в 21:29
52
0

Задание потока данных + большой запрос

У меня следующая проблема: У меня есть большой запрос со следующей схемой: cpf: string name: string greaterOfAge: boolean foreigner: boolean И у меня есть pub/sub для отправки сообщений, выровненных с заданием DataFlow, которое использует очень простую функцию UDF....
avatar
SpongeBob
8 августа 2021 в 21:15
181
1

«Выстрелить и забыть» или «Опубликовать» Подписаться

Я знаю, что Fire And Forget — это шаблон, который позволяет добавить сообщение в очередь сообщений, не дожидаясь подтверждения. Кроме того, я знаю, что Pub/Sub — это шаблон, который публикуют издатели, а подписчики потребляют данные. В чем разница между этими двумя...
avatar
mitchkman
6 августа 2021 в 16:22
151
1

Только условный повторный рендеринг при обновлении значения контекста

Я работаю над большим приложением React, где производительность имеет решающее значение, а ненужные повторные рендеринги обходятся дорого. У меня есть следующий пример: const CounterContext = React.createContext(); const CounterProvider = ({children}) => { ...
avatar
mfroeh
4 августа 2021 в 15:20
58
0

Publish-Subscribe подписка на несколько событий по наследству

Моя текущая реализация Publish-Subscribe содержит следующие типы. class EventBus { readonly IDictionary<Type, IList<ISubscriber>> _subscribers = new Dictionary<Type, IList<ISubscriber>>(); void Publish<T>(T @event) where T :...
avatar
viz_tm
3 августа 2021 в 05:48
94
0

Пакетная публикация GCP Pubsub запускает сообщения в 3–4 раза чаще, чем фактическое количество сообщений.

Я пытаюсь опубликовать сообщения с помощью функции пакетной публикации Google pubsub. Код пакетной публикации выглядит следующим образом: . const gRPC = require("grpc"); const { PubSub } = require("@google-cloud/pubsub"); const createPublishEventsInBatch = (topic)...
avatar
Alia Hassan
31 июля 2021 в 11:23
33
0

Есть ли способ обойти блокировку Google Tag Manager для импорта модулей javascript? Мне нужно импортировать PubSub.js, чтобы подписаться на тему

Мне нужно подписаться на событие PubSub.js в теге GTM, чтобы вызвать действие; но я не могу этого сделать, потому что GTM не разрешает импорт модулей из-за ограничений поддержки ECMAScript. Есть ли способ использовать PubSub в моем пользовательском теге HTML? Сценарий...
avatar
Alok Kumar Singh
27 июля 2021 в 14:48
338
1

Kafka Event Router: фильтрация и маршрутизация на основе содержимого, как?

Данные доступны в chat.* темах в Kafka. Мы можем просто развернуть несколько потребителей и сделать перехватчик all в этом единственном событии для потребления. Но не все продукты хотят работать с полными событиями в основной теме. Мы хотим разветвить тему на несколько...
avatar
Harihara Krishnan
24 июля 2021 в 17:19
50
0

Как избежать многократной обработки сообщений redis pub/sub в случае масштабируемых экземпляров микросервисов?

Я использую redis pub/sub, и у меня есть служба заказов, которая публикует сообщения в order_channel, и на нее подписана служба платежей. Когда я масштабирую свой платежный сервис до 5 экземпляров, работающих на разных портах, сообщение, полученное в order_channel,...
avatar
codebot
23 июля 2021 в 17:20
31
0

Как javascript pubsub/observer видит функцию другого объекта?

У меня есть этот простой код, когда я пытаюсь изучить основы реализации метода pubsub в javascript. Объект people генерирует простое событие, а объект events является pubsub, принимает событие и передает его всем, кто слушает Затем stats, который прослушивает это...
avatar
xyz
23 июля 2021 в 12:45
500
1

Попытка подключиться к test.mosquitto.org:8883/8884 (соединение SSL) Получение ошибки, как показано ниже

Я запускаю это в raspberry pi Во-первых, я сгенерировал ca.key, используя openssl genrsa -des3 -out ca.key 2048 openssl req -new -x509 -days 1826 -key ca.key -out ca.crt создал сертификат сервера, используя openssl genrsa -out server.key 2048 ...
avatar
Riki
21 июля 2021 в 13:45
202
0

mqtt - Стоит ли единожды подписаться на тему, дождаться сообщения и тут же отписаться?

РЕДАКТИРОВАТЬ: Я узнал о флаге сохранения сообщений на серверах mqtt. Это может быть то, что я ищу. Вместо прямого запроса текущего состояния я могу подписаться на тему, и брокер отправит последнее опубликованное состояние напрямую. Я обновлю этот ответ после того,...
avatar
Kuwali
21 июля 2021 в 07:28
363
2

Зависимость между темой pubsub и подпиской с использованием скрипта terraform

Я использую один скрипт terraform для создания подтемы паба и подписки. Если подписка должна подписываться на тему, созданную тем же скриптом, есть ли способ создать зависимость, чтобы terraform пытался создать подписку публикации/подписки только после создания...
avatar
Thien Nguyen
20 июля 2021 в 06:17
643
1

Несколько реплик модулей kubernetes, подписавшихся на облачную публикацию/подписку Google

Я настраиваю службу, работающую в модуле kubernetes, и подписываюсь на тему публикации/подписки с помощью подписки по запросу. Служба будет использовать сообщения, отправленные в тему.. Теперь я масштабирую свои модули до 10 реплик и наблюдаю, что иногда, когда в тему...
avatar
dontboaboutprograming
19 июля 2021 в 09:08
14
0

Почему параметр «обработчик» должен быть заключен в прослушиватель с шаблоном публикации/подписки (в JS)?

Я видел чей-то код EventHub с шаблоном публикации/подписки export class EventHub<E extends Emiter> { private cached: { [name in keyof E]: EventListener[] } = {} as any public on<N extends keyof E>(eventName: N, handler: Handler<E[N]>) { if...
avatar
Ptsans
17 июля 2021 в 14:24
50
0

Как лучше всего транслировать события из кафки на все большее количество подключений?

Я пытаюсь выяснить, как лучше построить связь между серверами веб-сокетов и kafka с возможностью масштабирования? Первая схема, в которой каждый сервер websocket имеет своего потребителя kafka(ссылка) Вторая схема, в которой каждый сервер веб-сокетов подключается к...
avatar
Tafel
15 июля 2021 в 15:48
130
1

Лучшая практика для подписки и публикации архитектуры для приложения, похожего на чат

Я хотел бы знать, какие существуют передовые методы подписки на изменения и публикации их для пользователя. Это довольно широкий и расплывчато сформулированный вопрос. Поэтому позвольте мне пояснить это на примере. Представьте себе следующее (упрощенное) приложение,...
avatar
Ben Swinburne
14 июля 2021 в 12:21
72
0

Сообщение всем экземплярам за балансировщиком нагрузки

Мне нужно оповещать все машины за балансировщиком нагрузки, когда что-то происходит. Например, у меня есть машины за балансировщиком нагрузки, которые кэшируют данные, и если данные изменяются, я хочу уведомить машины, чтобы они могли сбросить свои кэши. Мне кажется,...
avatar
Leonardo Kuffo
12 июля 2021 в 18:37
203
0

Некоторые события с истекшим сроком действия пространства ключей не запускаются (Redis)

У меня есть Redis внутри AWS ElastiCache с активированным уведомлением о ключевом пространстве (Kx). Моя проблема в том, что иногда событие expired не запускается при истечении срока действия ключа. Я отслеживаю TTL ключа и буквально наблюдаю за его истечением,...
avatar
Ender
9 июля 2021 в 14:31
102
1

Как заставить CMake генерировать файлы TypeSupport, такие как <idl_file>Support.[cxx,h]?

Я использую CMake для создания файлов из IDL и размещения их в библиотеке на RedHat. Проблема в том, что файлы <idl_file>Support[c,h] не создаются, поэтому я не могу зарегистрировать поддержку типа. В CMake у меня есть следующая строка, которая генерирует файлы...
avatar
Acewin
8 июля 2021 в 19:40
127
0

Передача одного сообщения только одному прослушивателю сообщений с помощью Spring data redis

У меня есть служба, которая отслеживает срок действия ключа __keyevent@*__:expired в Redis. Я запускаю 3 экземпляра службы. Что означает 3 прослушивателя сообщений. Настройка RedisKeyExpirationListener на основе предложения в этом решении...