Блог

Я пытаюсь использовать nsq в качестве брокера для стека ELK.

Я думал о том, чтобы сделать это, попросив nsq отправлять данные в elasticsearch через REST api. Согласно этому документу, я могу сделать HTTP-запрос PUT для добавления данных в elastic search.

Но, согласно документу nsq, nsq может отправлять или получать запросы только через утилиту nsq_to_http. Я не могу сделать запрос PUT, который требуется elasticsearch. Как я могу передавать значения из nsq в elasticsearch?

Вы можете использовать утилиту nsq_to_file, а затем использовать logstash для публикации файлов. Для чего-либо еще вам нужно будет посмотреть на код, чтобы адаптировать его к тому, что вы хотите.