パイプラインAPIの取得

1つ以上のインジェストパイプラインに関する情報を返します。このAPIは、パイプラインのローカル参照を返します。

Python

  1. resp = client.ingest.get_pipeline(
  2. id="my-pipeline-id",
  3. )
  4. print(resp)

Ruby

  1. response = client.ingest.get_pipeline(
  2. id: 'my-pipeline-id'
  3. )
  4. puts response

Js

  1. const response = await client.ingest.getPipeline({
  2. id: "my-pipeline-id",
  3. });
  4. console.log(response);

コンソール

  1. GET /_ingest/pipeline/my-pipeline-id

リクエスト

GET /_ingest/pipeline/<pipeline>

GET /_ingest/pipeline

前提条件

  • Elasticsearchのセキュリティ機能が有効になっている場合、このAPIを使用するには、read_pipelinemanage_pipelinemanage_ingest_pipelines、またはmanage クラスター権限が必要です。

パスパラメータ

  • <pipeline>
  • (オプション、文字列)取得するパイプラインIDのカンマ区切りリスト。ワイルドカード(*)式がサポートされています。
    すべてのインジェストパイプラインを取得するには、このパラメータを省略するか、*を使用します。

クエリパラメータ

  • master_timeout
  • (オプション、時間単位)マスターノードを待機する期間。タイムアウトが切れる前にマスターノードが利用できない場合、リクエストは失敗し、エラーが返されます。デフォルトは30sです。リクエストがタイムアウトしないことを示すために-1に設定することもできます。

特定のインジェストパイプラインの情報を取得

Python

  1. resp = client.ingest.get_pipeline(
  2. id="my-pipeline-id",
  3. )
  4. print(resp)

Ruby

  1. response = client.ingest.get_pipeline(
  2. id: 'my-pipeline-id'
  3. )
  4. puts response

Js

  1. const response = await client.ingest.getPipeline({
  2. id: "my-pipeline-id",
  3. });
  4. console.log(response);

コンソール

  1. GET /_ingest/pipeline/my-pipeline-id

APIは次のレスポンスを返します:

コンソール-結果

  1. {
  2. "my-pipeline-id" : {
  3. "description" : "describe pipeline",
  4. "version" : 123,
  5. "processors" : [
  6. {
  7. "set" : {
  8. "field" : "foo",
  9. "value" : "bar"
  10. }
  11. }
  12. ]
  13. }
  14. }