Docs Home Pulumi IaC Pulumi ESC Pulumi Insights Pulumi IDP Pulumi Cloud Packages Tutorials
  1. Packages
  2. Elasticstack Provider
  3. API Docs
  4. getElasticsearchIngestProcessorReroute
elasticstack 0.11.17 published on Tuesday, Jul 22, 2025 by elastic
elastic/terraform-provider-elasticstack

elasticstack.getElasticsearchIngestProcessorReroute

Explore with Pulumi AI

elasticstack logo
elasticstack 0.11.17 published on Tuesday, Jul 22, 2025 by elastic
elastic/terraform-provider-elasticstack

    Reroutes a document to a different data stream, index, or index alias. This processor is useful for routing documents based on data stream routing rules.

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

    Example Usage

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

const reroute = elasticstack.getElasticsearchIngestProcessorReroute({
    destination: "logs-generic-default",
    dataset: "generic",
    namespace: "default",
});
const myIngestPipeline = new elasticstack.ElasticsearchIngestPipeline("myIngestPipeline", {processors: [reroute.then(reroute => reroute.json)]});

    import pulumi
import pulumi_elasticstack as elasticstack

reroute = elasticstack.get_elasticsearch_ingest_processor_reroute(destination="logs-generic-default",
    dataset="generic",
    namespace="default")
my_ingest_pipeline = elasticstack.ElasticsearchIngestPipeline("myIngestPipeline", processors=[reroute.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 {
		reroute, err := elasticstack.GetElasticsearchIngestProcessorReroute(ctx, &elasticstack.GetElasticsearchIngestProcessorRerouteArgs{
			Destination: pulumi.StringRef("logs-generic-default"),
			Dataset:     pulumi.StringRef("generic"),
			Namespace:   pulumi.StringRef("default"),
		}, nil)
		if err != nil {
			return err
		}
		_, err = elasticstack.NewElasticsearchIngestPipeline(ctx, "myIngestPipeline", &elasticstack.ElasticsearchIngestPipelineArgs{
			Processors: pulumi.StringArray{
				pulumi.String(reroute.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 reroute = Elasticstack.GetElasticsearchIngestProcessorReroute.Invoke(new()
    {
        Destination = "logs-generic-default",
        Dataset = "generic",
        Namespace = "default",
    });

    var myIngestPipeline = new Elasticstack.ElasticsearchIngestPipeline("myIngestPipeline", new()
    {
        Processors = new[]
        {
            reroute.Apply(getElasticsearchIngestProcessorRerouteResult => getElasticsearchIngestProcessorRerouteResult.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.GetElasticsearchIngestProcessorRerouteArgs;
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 reroute = ElasticstackFunctions.getElasticsearchIngestProcessorReroute(GetElasticsearchIngestProcessorRerouteArgs.builder()
            .destination("logs-generic-default")
            .dataset("generic")
            .namespace("default")
            .build());

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

    }
}

    resources:
  myIngestPipeline:
    type: elasticstack:ElasticsearchIngestPipeline
    properties:
      processors:
        - ${reroute.json}
variables:
  reroute:
    fn::invoke:
      function: elasticstack:getElasticsearchIngestProcessorReroute
      arguments:
        destination: logs-generic-default
        dataset: generic
        namespace: default

    Using getElasticsearchIngestProcessorReroute

    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 getElasticsearchIngestProcessorReroute(args: GetElasticsearchIngestProcessorRerouteArgs, opts?: InvokeOptions): Promise<GetElasticsearchIngestProcessorRerouteResult>
function getElasticsearchIngestProcessorRerouteOutput(args: GetElasticsearchIngestProcessorRerouteOutputArgs, opts?: InvokeOptions): Output<GetElasticsearchIngestProcessorRerouteResult>
    def get_elasticsearch_ingest_processor_reroute(dataset: Optional[str] = None,
                                               description: Optional[str] = None,
                                               destination: Optional[str] = None,
                                               if_: Optional[str] = None,
                                               ignore_failure: Optional[bool] = None,
                                               namespace: Optional[str] = None,
                                               on_failures: Optional[Sequence[str]] = None,
                                               tag: Optional[str] = None,
                                               opts: Optional[InvokeOptions] = None) -> GetElasticsearchIngestProcessorRerouteResult
def get_elasticsearch_ingest_processor_reroute_output(dataset: Optional[pulumi.Input[str]] = None,
                                               description: Optional[pulumi.Input[str]] = None,
                                               destination: Optional[pulumi.Input[str]] = None,
                                               if_: Optional[pulumi.Input[str]] = None,
                                               ignore_failure: Optional[pulumi.Input[bool]] = None,
                                               namespace: Optional[pulumi.Input[str]] = None,
                                               on_failures: Optional[pulumi.Input[Sequence[pulumi.Input[str]]]] = None,
                                               tag: Optional[pulumi.Input[str]] = None,
                                               opts: Optional[InvokeOptions] = None) -> Output[GetElasticsearchIngestProcessorRerouteResult]
    func GetElasticsearchIngestProcessorReroute(ctx *Context, args *GetElasticsearchIngestProcessorRerouteArgs, opts ...InvokeOption) (*GetElasticsearchIngestProcessorRerouteResult, error)
func GetElasticsearchIngestProcessorRerouteOutput(ctx *Context, args *GetElasticsearchIngestProcessorRerouteOutputArgs, opts ...InvokeOption) GetElasticsearchIngestProcessorRerouteResultOutput

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

    public static class GetElasticsearchIngestProcessorReroute 
{
    public static Task<GetElasticsearchIngestProcessorRerouteResult> InvokeAsync(GetElasticsearchIngestProcessorRerouteArgs args, InvokeOptions? opts = null)
    public static Output<GetElasticsearchIngestProcessorRerouteResult> Invoke(GetElasticsearchIngestProcessorRerouteInvokeArgs args, InvokeOptions? opts = null)
}
    public static CompletableFuture<GetElasticsearchIngestProcessorRerouteResult> getElasticsearchIngestProcessorReroute(GetElasticsearchIngestProcessorRerouteArgs args, InvokeOptions options)
public static Output<GetElasticsearchIngestProcessorRerouteResult> getElasticsearchIngestProcessorReroute(GetElasticsearchIngestProcessorRerouteArgs args, InvokeOptions options)

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

    The following arguments are supported:

    Dataset string
    The destination dataset to route the document to.
    Description string
    Description of the processor.
    Destination string
    The destination data stream, index, or index alias to route the document to.
    If string
    Conditionally execute the processor
    IgnoreFailure bool
    Ignore failures for the processor.
    Namespace string
    The destination namespace to route the document to.
    OnFailures List<string>
    Handle failures for the processor.
    Tag string
    Identifier for the processor.
    Dataset string
    The destination dataset to route the document to.
    Description string
    Description of the processor.
    Destination string
    The destination data stream, index, or index alias to route the document to.
    If string
    Conditionally execute the processor
    IgnoreFailure bool
    Ignore failures for the processor.
    Namespace string
    The destination namespace to route the document to.
    OnFailures []string
    Handle failures for the processor.
    Tag string
    Identifier for the processor.
    dataset String
    The destination dataset to route the document to.
    description String
    Description of the processor.
    destination String
    The destination data stream, index, or index alias to route the document to.
    if_ String
    Conditionally execute the processor
    ignoreFailure Boolean
    Ignore failures for the processor.
    namespace String
    The destination namespace to route the document to.
    onFailures List<String>
    Handle failures for the processor.
    tag String
    Identifier for the processor.
    dataset string
    The destination dataset to route the document to.
    description string
    Description of the processor.
    destination string
    The destination data stream, index, or index alias to route the document to.
    if string
    Conditionally execute the processor
    ignoreFailure boolean
    Ignore failures for the processor.
    namespace string
    The destination namespace to route the document to.
    onFailures string[]
    Handle failures for the processor.
    tag string
    Identifier for the processor.
    dataset str
    The destination dataset to route the document to.
    description str
    Description of the processor.
    destination str
    The destination data stream, index, or index alias to route the document to.
    if_ str
    Conditionally execute the processor
    ignore_failure bool
    Ignore failures for the processor.
    namespace str
    The destination namespace to route the document to.
    on_failures Sequence[str]
    Handle failures for the processor.
    tag str
    Identifier for the processor.
    dataset String
    The destination dataset to route the document to.
    description String
    Description of the processor.
    destination String
    The destination data stream, index, or index alias to route the document to.
    if String
    Conditionally execute the processor
    ignoreFailure Boolean
    Ignore failures for the processor.
    namespace String
    The destination namespace to route the document to.
    onFailures List<String>
    Handle failures for the processor.
    tag String
    Identifier for the processor.

    getElasticsearchIngestProcessorReroute Result

    The following output properties are available:

    Id string
    Internal identifier of the resource.
    Json string
    JSON representation of this data source.
    Dataset string
    The destination dataset to route the document to.
    Description string
    Description of the processor.
    Destination string
    The destination data stream, index, or index alias to route the document to.
    If string
    Conditionally execute the processor
    IgnoreFailure bool
    Ignore failures for the processor.
    Namespace string
    The destination namespace to route the document to.
    OnFailures List<string>
    Handle failures for the processor.
    Tag string
    Identifier for the processor.
    Id string
    Internal identifier of the resource.
    Json string
    JSON representation of this data source.
    Dataset string
    The destination dataset to route the document to.
    Description string
    Description of the processor.
    Destination string
    The destination data stream, index, or index alias to route the document to.
    If string
    Conditionally execute the processor
    IgnoreFailure bool
    Ignore failures for the processor.
    Namespace string
    The destination namespace to route the document to.
    OnFailures []string
    Handle failures for the processor.
    Tag string
    Identifier for the processor.
    id String
    Internal identifier of the resource.
    json String
    JSON representation of this data source.
    dataset String
    The destination dataset to route the document to.
    description String
    Description of the processor.
    destination String
    The destination data stream, index, or index alias to route the document to.
    if_ String
    Conditionally execute the processor
    ignoreFailure Boolean
    Ignore failures for the processor.
    namespace String
    The destination namespace to route the document to.
    onFailures List<String>
    Handle failures for the processor.
    tag String
    Identifier for the processor.
    id string
    Internal identifier of the resource.
    json string
    JSON representation of this data source.
    dataset string
    The destination dataset to route the document to.
    description string
    Description of the processor.
    destination string
    The destination data stream, index, or index alias to route the document to.
    if string
    Conditionally execute the processor
    ignoreFailure boolean
    Ignore failures for the processor.
    namespace string
    The destination namespace to route the document to.
    onFailures string[]
    Handle failures for the processor.
    tag string
    Identifier for the processor.
    id str
    Internal identifier of the resource.
    json str
    JSON representation of this data source.
    dataset str
    The destination dataset to route the document to.
    description str
    Description of the processor.
    destination str
    The destination data stream, index, or index alias to route the document to.
    if_ str
    Conditionally execute the processor
    ignore_failure bool
    Ignore failures for the processor.
    namespace str
    The destination namespace to route the document to.
    on_failures Sequence[str]
    Handle failures for the processor.
    tag str
    Identifier for the processor.
    id String
    Internal identifier of the resource.
    json String
    JSON representation of this data source.
    dataset String
    The destination dataset to route the document to.
    description String
    Description of the processor.
    destination String
    The destination data stream, index, or index alias to route the document to.
    if String
    Conditionally execute the processor
    ignoreFailure Boolean
    Ignore failures for the processor.
    namespace String
    The destination namespace to route the document to.
    onFailures List<String>
    Handle failures for the processor.
    tag String
    Identifier for the processor.

    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.17 published on Tuesday, Jul 22, 2025 by elastic
    elastic/terraform-provider-elasticstack