Интеграция производителя Kafka Python с веб-приложением django - PullRequest
0 голосов
/ 18 января 2019

У меня вопрос о том, как мы можем интегрировать производителя kafka с интерфейсным веб-приложением. получить данные за каждую минуту или секунду. Может ли веб-приложение передавать объект JSON работающему производителю при каждом его создании? или нам нужно запускать клиент kafka каждый раз, когда мы получаем объект JSON?

1 Ответ

0 голосов
/ 18 января 2019

Возможно, вы захотите открывать новый источник для каждой сессии , возможно, не открывать и не закрывать для каждого запроса . И это будет сделано на бэкэнде, а не на фронтэнде.

Но веб-сервер, состоящий из клиента Kafka, ничем не отличается под слоем HTTP от обычного консольного приложения; Вы принимаете входящий запрос, десериализуете его, затем, при необходимости, анализируете, затем снова сериализуетесь для вывода Kafka, а затем, по желанию, возвращаете что-то пользователю.

Если вы действительно спрашиваете, «Кафка с HTTP-запросами возможна», независимо от языка и платформ, тогда, конечно, Confluent REST Proxy работает аналогично, только на Java

Что касается отслеживания веб-приложений, я бы посоветовал изучить Divolte Collector

...