Logstash Elasticsearch Input - 一度だけ実行されますか？

Question

私はElasticsearch入力、いくつかのフィルタとElasticsearch出力でEC2インスタンス上で実行されているLogstash設定を持つインデックスB.

にインデックスAからのデータの小さなサブセットをコピーしようとしています。

これは私がそれを最初に実行したときに正常に動作しますが、新しいデータがインデックスA（つまり、入力のクエリ条件を満たしている）に追加された場合Logstashの設定が

インデックスB.にして出力することを検出しません

これは私に考えている、Elasticsearchの入力は1回だけ実行されますか？追加された新しいファイルをピックアップするファイルやS3入力のような入力とは異なります。

Answer 1

Logstash elasticsearch入力プラグインは、オプションのクエリで1回の検索（スキャン/スクロール）を行い、終了すると終了します。

file入力プラグインの場合と同じように動作しないので、1つまたは複数のファイルをテールして、その場で新しい行を処理します。

新しい文書がクエリと一致したときに通知を受ける方法が必要な場合は、Watcherプラグインを調べることができます。 Watcherはクエリに一致する新しい文書の存在を検出してから、Webhookを呼び出します。これは、Logstash内のhttp input pluginによって実現できます。