Существует несколько способов отправки входных данных в logstash. С текущей версией вы можете найти список здесь- https://www.elastic.co/guide/en/logstash/current/input-plugins.html
Я не уверен, что если бы в состоянии помочь вам разработать, как вы хотите сделать это, но некоторые из sugeestions я мог бы дать являются- 1) войти эти сообщения стандартным способом в виде файла в формате JSON и использовать файл плагина (если вы хотите logstash на той же машине, где хранится файл)
так входной части будет выглядеть как
input {
file {
path => ...
codec =>json
}
2) использовать Кафка плагин. Для этого необходимо установить kafka и написать программу продюсера kafka для отправки сообщений в logstash. Сообщения отправляются с использованием темы, которую вы создали. вход logstash будет выглядеть как-
input {
kafka {
bootstrap_servers => "..."
topics => ["..."]
codec => json
}
}
Это может показаться сложным, но и помогает удалить зависимости и разъединить вашу архитектуру. Вам тоже нужно было бы понять кафку.
Это всего лишь пара, но вы можете использовать другие, если хотите, исходя из ваших требований.
Чтобы различать клиентов, которые отправляют данные, в вашем json вы можете иметь поле «клиент», с помощью которого вы можете фильтровать и выполнять какую-либо задачу. Чтобы отфильтровать данные на основе поля клиента, вам нужно будет ссылаться на него как «% {client}»
Надеюсь, это поможет.
Thanks