質問: ingest nodeのon_failure処理について お世話になっております。 ingest node pipelineのon_failureについて質問させて頂きます。 下記のように pipelineaからpipelineb、pipelinebからpipelinecを呼び出す処理を実施しています。 取込ファイルは、s3→filebeat→elasticsearch(ingest node)の順でindex登録しています。 put /_ingest/pipeline/pipelinea { "processors": [ { "pipeline": { "if": "ctx.aws.s3.buck...
回答: 事象をシンプルにするため、最低限のデータの準備と、登録はkibanaのdevtoolで行いましたが、 pipelinccを削除後、データを投入したところsimulateで実行した場合と同じ結果になりました。 filebeat→elasticsearchのところは、本質的には、kibana devtoolsやcurlを用いてpost hoge/_doc/1のようにデータを投入するのと変わらないはずですので、 簡易な手段で再現できる方法がありますと、ヒントが見つかるかもしれません。 こちらでは、7.5.0で確認しています。以下、確認したときに使用した内容です。 put /_ingest/...