私のアプリケーション用の統計microserviceを作成しています。
複数のデバイスからのデータを格納するためのELKスタック.confファイル
私は5つの異なるクライアントから情報を収集する必要があります：IOs, Android phone, web client and JS client。
誰もが私はjson-s directly to logstashを送りたい.conf file for logstash?
で私を助けることができる、それは可能ですか？あるいは、私はいつもファイルからログを読む必要がありますか？どのフィルタを使用する必要がありますか？どのように入力を指定するのですか？
ELKスタックは、Amazon EC2コンテナサービスでmicroserviceとして実行されます。
この問題についてお手伝いできますか？
ご協力いただき誠にありがとうございます。
よろしくお願いいたします。
入力データをlogstashに送信する方法は複数あります。現在のバージョンを使用すると、here- https://www.elastic.co/guide/en/logstash/current/input-plugins.html
私はこれらのメッセージをログare- 1）あなたがそれをやりたい方法を設計したがsugeestionsのいくつかは、私が与えることができるあなたを助けることができるかどうか分からないリストを見つけることができますJSON形式のファイルで標準的な方法でと（ファイルが格納されている場所と同じマシン上logstashたい場合）、ファイルプラグインを使用
ので、入力部が
input {
file {
path => ...
codec =>json
}
2のようになります）カフカを使用プラグイン。これには、カフカをインストールし、メッセージをlogstashに送るためのカフカプロデューサープログラムを作成する必要があります。メッセージは、作成したトピックを使用して送信されます。 がlogstash入力が
input {
kafka {
bootstrap_servers => "..."
topics => ["..."]
codec => json
}
}
like-になりますこれは複雑に思えるかもしれないが、依存関係を削除し、あなたのアーキテクチャを切り離すことができます。あなたはカフカについても理解しなければなりません。
これらは単なるカップルですが、必要に応じて他のものを使用することもできます。
データを送信するクライアントを区別するために、jsonではフィルタリングして何らかのタスクを実行できる「クライアント」というフィールドがあります。 クライアントフィールドに基づいてデータをフィルタリングするには、 "％{client}"のように参照する必要があります。
ありがとうございました
Logstashにはhttp入力があります。これを聞くように設定して、アプリケーションが処理するためにデータをログに記録させることができます。
また、tcpとudpの入力と、おそらくあなたが使用できるその他の入力があります。
アプリケーションは、logstashがビジー/到達不能/死んでいた場合に対処する必要があります。