Существует ли плагин Telegraf, который принимает запросы для чтения данных из Influxdb, а затем публикует их в теме kafka, используя плагин вывода Kafka?

Question

Используя плагины Telegraf, есть способ прочитать данные из InfluxDb и опубликовать их в теме Kafka.

Но есть ли способ прочитать данные по запросу и разместить их в теме Kafka?Как запрос на основе запроса.

Я могу сделать запрос на основе чтения через REST API (curl GET).

Есть плагины HTTP Listener, но они только для методов POST.Нет для метода GET, где я могу запросить подмножество данных из InfluxDb и разместить их в теме Кафки.В этом случае плагин вывода будет kafka.

Answer 1

Этого можно добиться с помощью обработчика событий Kapacitor Kafka . Kapacitor может быть настроен либо в пакетном режиме, либо в потоковом режиме. В случае потокового режима, если условие выполнено для обработки, обработчик событий Kapacitor немедленно обработает запись и отправит ее в кластер Kafaka. Пожалуйста, обратитесь здесь для более подробной информации.