2016-08-23 16 views
0

ストリーミングデータにlogstash-input-elasticsearchプラグインを使用できるかどうかを知りたいと思います。たとえば、データベースにデータがあり、ElasticSearch入力プラグインを実行すると、 ElasticSearchの入力プラグインは、ログ・スタッシュを再起動しなくてもそのデータのインデックスを作成できますか?ストリーミングデータ用のLogstash Elasticsearch Inputプラグイン

ご協力いただきありがとうございます。

答えて

1

デフォルトでは、elasticsearch入力は、ESインスタンスのスクロールクエリを実行し、クエリに一致するドキュメントをポンピングし、出力にストリームします。終了すると、Logstashはシャットダウンします。

ただし、定期的にLogstashパイプラインを開始し、ESにある新しい文書を照会するcronジョブを設定することができます。

+0

もう一度ありがとうございます。ヴァル!私はあなたが私を推薦したものを開発しています。しかし、前の実行で扱った最後の文書から開始し、すべてのelasticsearchデータベースをスクロールしないようにlogstashに指示するにはどうすればよいですか? –

+1

クエリの中で確認できるような日付のようなフィールドが必要です。前回パイプラインを実行したときよりも日付が大きいすべてのドキュメントを照会する必要があるたびに、 – Val

関連する問題