Docs Home Pulumi IaC Pulumi ESC Pulumi Insights Pulumi Cloud Packages Tutorials
  1. Packages
  2. Elasticstack Provider
  3. API Docs
  4. getElasticsearchIngestProcessorSet
elasticstack 0.11.15 published on Wednesday, Apr 23, 2025 by elastic
elastic/terraform-provider-elasticstack

elasticstack.getElasticsearchIngestProcessorSet

Explore with Pulumi AI

elasticstack logo
elasticstack 0.11.15 published on Wednesday, Apr 23, 2025 by elastic
elastic/terraform-provider-elasticstack

    Sets one field and associates it with the specified value. If the field already exists, its value will be replaced with the provided one.

    See: https://www.elastic.co/guide/en/elasticsearch/reference/current/set-processor.html

    Example Usage

    import * as pulumi from "@pulumi/pulumi";
import * as elasticstack from "@pulumi/elasticstack";

const set = elasticstack.getElasticsearchIngestProcessorSet({
    field: "count",
    value: "1",
});
const myIngestPipeline = new elasticstack.ElasticsearchIngestPipeline("myIngestPipeline", {processors: [set.then(set => set.json)]});

    import pulumi
import pulumi_elasticstack as elasticstack

set = elasticstack.get_elasticsearch_ingest_processor_set(field="count",
    value="1")
my_ingest_pipeline = elasticstack.ElasticsearchIngestPipeline("myIngestPipeline", processors=[set.json])

    package main

import (
	"github.com/pulumi/pulumi-terraform-provider/sdks/go/elasticstack/elasticstack"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		set, err := elasticstack.GetElasticsearchIngestProcessorSet(ctx, &elasticstack.GetElasticsearchIngestProcessorSetArgs{
			Field: "count",
			Value: pulumi.StringRef("1"),
		}, nil)
		if err != nil {
			return err
		}
		_, err = elasticstack.NewElasticsearchIngestPipeline(ctx, "myIngestPipeline", &elasticstack.ElasticsearchIngestPipelineArgs{
			Processors: pulumi.StringArray{
				pulumi.String(set.Json),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

    using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Elasticstack = Pulumi.Elasticstack;

return await Deployment.RunAsync(() => 
{
    var @set = Elasticstack.GetElasticsearchIngestProcessorSet.Invoke(new()
    {
        Field = "count",
        Value = "1",
    });

    var myIngestPipeline = new Elasticstack.ElasticsearchIngestPipeline("myIngestPipeline", new()
    {
        Processors = new[]
        {
            @set.Apply(@set => @set.Apply(getElasticsearchIngestProcessorSetResult => getElasticsearchIngestProcessorSetResult.Json)),
        },
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.elasticstack.ElasticstackFunctions;
import com.pulumi.elasticstack.inputs.GetElasticsearchIngestProcessorSetArgs;
import com.pulumi.elasticstack.ElasticsearchIngestPipeline;
import com.pulumi.elasticstack.ElasticsearchIngestPipelineArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        final var set = ElasticstackFunctions.getElasticsearchIngestProcessorSet(GetElasticsearchIngestProcessorSetArgs.builder()
            .field("count")
            .value(1)
            .build());

        var myIngestPipeline = new ElasticsearchIngestPipeline("myIngestPipeline", ElasticsearchIngestPipelineArgs.builder()
            .processors(set.applyValue(getElasticsearchIngestProcessorSetResult -> getElasticsearchIngestProcessorSetResult.json()))
            .build());

    }
}

    resources:
  myIngestPipeline:
    type: elasticstack:ElasticsearchIngestPipeline
    properties:
      processors:
        - ${set.json}
variables:
  set:
    fn::invoke:
      function: elasticstack:getElasticsearchIngestProcessorSet
      arguments:
        field: count
        value: 1

    Using getElasticsearchIngestProcessorSet

    Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.

    function getElasticsearchIngestProcessorSet(args: GetElasticsearchIngestProcessorSetArgs, opts?: InvokeOptions): Promise<GetElasticsearchIngestProcessorSetResult>
function getElasticsearchIngestProcessorSetOutput(args: GetElasticsearchIngestProcessorSetOutputArgs, opts?: InvokeOptions): Output<GetElasticsearchIngestProcessorSetResult>
    def get_elasticsearch_ingest_processor_set(copy_from: Optional[str] = None,
                                           description: Optional[str] = None,
                                           field: Optional[str] = None,
                                           if_: Optional[str] = None,
                                           ignore_empty_value: Optional[bool] = None,
                                           ignore_failure: Optional[bool] = None,
                                           media_type: Optional[str] = None,
                                           on_failures: Optional[Sequence[str]] = None,
                                           override: Optional[bool] = None,
                                           tag: Optional[str] = None,
                                           value: Optional[str] = None,
                                           opts: Optional[InvokeOptions] = None) -> GetElasticsearchIngestProcessorSetResult
def get_elasticsearch_ingest_processor_set_output(copy_from: Optional[pulumi.Input[str]] = None,
                                           description: Optional[pulumi.Input[str]] = None,
                                           field: Optional[pulumi.Input[str]] = None,
                                           if_: Optional[pulumi.Input[str]] = None,
                                           ignore_empty_value: Optional[pulumi.Input[bool]] = None,
                                           ignore_failure: Optional[pulumi.Input[bool]] = None,
                                           media_type: Optional[pulumi.Input[str]] = None,
                                           on_failures: Optional[pulumi.Input[Sequence[pulumi.Input[str]]]] = None,
                                           override: Optional[pulumi.Input[bool]] = None,
                                           tag: Optional[pulumi.Input[str]] = None,
                                           value: Optional[pulumi.Input[str]] = None,
                                           opts: Optional[InvokeOptions] = None) -> Output[GetElasticsearchIngestProcessorSetResult]
    func GetElasticsearchIngestProcessorSet(ctx *Context, args *GetElasticsearchIngestProcessorSetArgs, opts ...InvokeOption) (*GetElasticsearchIngestProcessorSetResult, error)
func GetElasticsearchIngestProcessorSetOutput(ctx *Context, args *GetElasticsearchIngestProcessorSetOutputArgs, opts ...InvokeOption) GetElasticsearchIngestProcessorSetResultOutput

    > Note: This function is named GetElasticsearchIngestProcessorSet in the Go SDK.

    public static class GetElasticsearchIngestProcessorSet 
{
    public static Task<GetElasticsearchIngestProcessorSetResult> InvokeAsync(GetElasticsearchIngestProcessorSetArgs args, InvokeOptions? opts = null)
    public static Output<GetElasticsearchIngestProcessorSetResult> Invoke(GetElasticsearchIngestProcessorSetInvokeArgs args, InvokeOptions? opts = null)
}
    public static CompletableFuture<GetElasticsearchIngestProcessorSetResult> getElasticsearchIngestProcessorSet(GetElasticsearchIngestProcessorSetArgs args, InvokeOptions options)
public static Output<GetElasticsearchIngestProcessorSetResult> getElasticsearchIngestProcessorSet(GetElasticsearchIngestProcessorSetArgs args, InvokeOptions options)

    fn::invoke:
  function: elasticstack:index/getElasticsearchIngestProcessorSet:getElasticsearchIngestProcessorSet
  arguments:
    # arguments dictionary

    The following arguments are supported:

    Field string
    The field to insert, upsert, or update.
    CopyFrom string
    The origin field which will be copied to field, cannot set value simultaneously.
    Description string
    Description of the processor.
    If string
    Conditionally execute the processor
    IgnoreEmptyValue bool
    If true and value is a template snippet that evaluates to null or the empty string, the processor quietly exits without modifying the document
    IgnoreFailure bool
    Ignore failures for the processor.
    MediaType string
    The media type for encoding value.
    OnFailures List<string>
    Handle failures for the processor.
    Override bool
    If processor will update fields with pre-existing non-null-valued field.
    Tag string
    Identifier for the processor.
    Value string
    The value to be set for the field. Supports template snippets. May specify only one of value or copy_from.
    Field string
    The field to insert, upsert, or update.
    CopyFrom string
    The origin field which will be copied to field, cannot set value simultaneously.
    Description string
    Description of the processor.
    If string
    Conditionally execute the processor
    IgnoreEmptyValue bool
    If true and value is a template snippet that evaluates to null or the empty string, the processor quietly exits without modifying the document
    IgnoreFailure bool
    Ignore failures for the processor.
    MediaType string
    The media type for encoding value.
    OnFailures []string
    Handle failures for the processor.
    Override bool
    If processor will update fields with pre-existing non-null-valued field.
    Tag string
    Identifier for the processor.
    Value string
    The value to be set for the field. Supports template snippets. May specify only one of value or copy_from.
    field String
    The field to insert, upsert, or update.
    copyFrom String
    The origin field which will be copied to field, cannot set value simultaneously.
    description String
    Description of the processor.
    if_ String
    Conditionally execute the processor
    ignoreEmptyValue Boolean
    If true and value is a template snippet that evaluates to null or the empty string, the processor quietly exits without modifying the document
    ignoreFailure Boolean
    Ignore failures for the processor.
    mediaType String
    The media type for encoding value.
    onFailures List<String>
    Handle failures for the processor.
    override Boolean
    If processor will update fields with pre-existing non-null-valued field.
    tag String
    Identifier for the processor.
    value String
    The value to be set for the field. Supports template snippets. May specify only one of value or copy_from.
    field string
    The field to insert, upsert, or update.
    copyFrom string
    The origin field which will be copied to field, cannot set value simultaneously.
    description string
    Description of the processor.
    if string
    Conditionally execute the processor
    ignoreEmptyValue boolean
    If true and value is a template snippet that evaluates to null or the empty string, the processor quietly exits without modifying the document
    ignoreFailure boolean
    Ignore failures for the processor.
    mediaType string
    The media type for encoding value.
    onFailures string[]
    Handle failures for the processor.
    override boolean
    If processor will update fields with pre-existing non-null-valued field.
    tag string
    Identifier for the processor.
    value string
    The value to be set for the field. Supports template snippets. May specify only one of value or copy_from.
    field str
    The field to insert, upsert, or update.
    copy_from str
    The origin field which will be copied to field, cannot set value simultaneously.
    description str
    Description of the processor.
    if_ str
    Conditionally execute the processor
    ignore_empty_value bool
    If true and value is a template snippet that evaluates to null or the empty string, the processor quietly exits without modifying the document
    ignore_failure bool
    Ignore failures for the processor.
    media_type str
    The media type for encoding value.
    on_failures Sequence[str]
    Handle failures for the processor.
    override bool
    If processor will update fields with pre-existing non-null-valued field.
    tag str
    Identifier for the processor.
    value str
    The value to be set for the field. Supports template snippets. May specify only one of value or copy_from.
    field String
    The field to insert, upsert, or update.
    copyFrom String
    The origin field which will be copied to field, cannot set value simultaneously.
    description String
    Description of the processor.
    if String
    Conditionally execute the processor
    ignoreEmptyValue Boolean
    If true and value is a template snippet that evaluates to null or the empty string, the processor quietly exits without modifying the document
    ignoreFailure Boolean
    Ignore failures for the processor.
    mediaType String
    The media type for encoding value.
    onFailures List<String>
    Handle failures for the processor.
    override Boolean
    If processor will update fields with pre-existing non-null-valued field.
    tag String
    Identifier for the processor.
    value String
    The value to be set for the field. Supports template snippets. May specify only one of value or copy_from.

    getElasticsearchIngestProcessorSet Result

    The following output properties are available:

    Field string
    The field to insert, upsert, or update.
    Id string
    Internal identifier of the resource.
    Json string
    JSON representation of this data source.
    CopyFrom string
    The origin field which will be copied to field, cannot set value simultaneously.
    Description string
    Description of the processor.
    If string
    Conditionally execute the processor
    IgnoreEmptyValue bool
    If true and value is a template snippet that evaluates to null or the empty string, the processor quietly exits without modifying the document
    IgnoreFailure bool
    Ignore failures for the processor.
    MediaType string
    The media type for encoding value.
    OnFailures List<string>
    Handle failures for the processor.
    Override bool
    If processor will update fields with pre-existing non-null-valued field.
    Tag string
    Identifier for the processor.
    Value string
    The value to be set for the field. Supports template snippets. May specify only one of value or copy_from.
    Field string
    The field to insert, upsert, or update.
    Id string
    Internal identifier of the resource.
    Json string
    JSON representation of this data source.
    CopyFrom string
    The origin field which will be copied to field, cannot set value simultaneously.
    Description string
    Description of the processor.
    If string
    Conditionally execute the processor
    IgnoreEmptyValue bool
    If true and value is a template snippet that evaluates to null or the empty string, the processor quietly exits without modifying the document
    IgnoreFailure bool
    Ignore failures for the processor.
    MediaType string
    The media type for encoding value.
    OnFailures []string
    Handle failures for the processor.
    Override bool
    If processor will update fields with pre-existing non-null-valued field.
    Tag string
    Identifier for the processor.
    Value string
    The value to be set for the field. Supports template snippets. May specify only one of value or copy_from.
    field String
    The field to insert, upsert, or update.
    id String
    Internal identifier of the resource.
    json String
    JSON representation of this data source.
    copyFrom String
    The origin field which will be copied to field, cannot set value simultaneously.
    description String
    Description of the processor.
    if_ String
    Conditionally execute the processor
    ignoreEmptyValue Boolean
    If true and value is a template snippet that evaluates to null or the empty string, the processor quietly exits without modifying the document
    ignoreFailure Boolean
    Ignore failures for the processor.
    mediaType String
    The media type for encoding value.
    onFailures List<String>
    Handle failures for the processor.
    override Boolean
    If processor will update fields with pre-existing non-null-valued field.
    tag String
    Identifier for the processor.
    value String
    The value to be set for the field. Supports template snippets. May specify only one of value or copy_from.
    field string
    The field to insert, upsert, or update.
    id string
    Internal identifier of the resource.
    json string
    JSON representation of this data source.
    copyFrom string
    The origin field which will be copied to field, cannot set value simultaneously.
    description string
    Description of the processor.
    if string
    Conditionally execute the processor
    ignoreEmptyValue boolean
    If true and value is a template snippet that evaluates to null or the empty string, the processor quietly exits without modifying the document
    ignoreFailure boolean
    Ignore failures for the processor.
    mediaType string
    The media type for encoding value.
    onFailures string[]
    Handle failures for the processor.
    override boolean
    If processor will update fields with pre-existing non-null-valued field.
    tag string
    Identifier for the processor.
    value string
    The value to be set for the field. Supports template snippets. May specify only one of value or copy_from.
    field str
    The field to insert, upsert, or update.
    id str
    Internal identifier of the resource.
    json str
    JSON representation of this data source.
    copy_from str
    The origin field which will be copied to field, cannot set value simultaneously.
    description str
    Description of the processor.
    if_ str
    Conditionally execute the processor
    ignore_empty_value bool
    If true and value is a template snippet that evaluates to null or the empty string, the processor quietly exits without modifying the document
    ignore_failure bool
    Ignore failures for the processor.
    media_type str
    The media type for encoding value.
    on_failures Sequence[str]
    Handle failures for the processor.
    override bool
    If processor will update fields with pre-existing non-null-valued field.
    tag str
    Identifier for the processor.
    value str
    The value to be set for the field. Supports template snippets. May specify only one of value or copy_from.
    field String
    The field to insert, upsert, or update.
    id String
    Internal identifier of the resource.
    json String
    JSON representation of this data source.
    copyFrom String
    The origin field which will be copied to field, cannot set value simultaneously.
    description String
    Description of the processor.
    if String
    Conditionally execute the processor
    ignoreEmptyValue Boolean
    If true and value is a template snippet that evaluates to null or the empty string, the processor quietly exits without modifying the document
    ignoreFailure Boolean
    Ignore failures for the processor.
    mediaType String
    The media type for encoding value.
    onFailures List<String>
    Handle failures for the processor.
    override Boolean
    If processor will update fields with pre-existing non-null-valued field.
    tag String
    Identifier for the processor.
    value String
    The value to be set for the field. Supports template snippets. May specify only one of value or copy_from.

    Package Details

    Repository
    elasticstack elastic/terraform-provider-elasticstack
    License
    Notes
    This Pulumi package is based on the elasticstack Terraform Provider.
    elasticstack logo
    elasticstack 0.11.15 published on Wednesday, Apr 23, 2025 by elastic
    elastic/terraform-provider-elasticstack