tencentcloud 1.81.189, Apr 30 25

tencentcloud 1.81.189 published on Wednesday, Apr 30, 2025 by tencentcloudstack

tencentcloudstack/terraform-provider-tencentcloud

tencentcloud.ElasticsearchLogstashPipeline

Explore with Pulumi AI

tencentcloud 1.81.189 published on Wednesday, Apr 30, 2025 by tencentcloudstack

tencentcloudstack/terraform-provider-tencentcloud

Example Usage

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

const logstashPipeline = new tencentcloud.ElasticsearchLogstashPipeline("logstashPipeline", {
    instanceId: "ls-xxxxxx",
    opType: 2,
    pipeline: {
        batchDelay: 50,
        batchSize: 125,
        config: `input{

}
filter{

}
output{

}

`,
        pipelineDesc: "",
        pipelineId: "logstash-pipeline-test",
        queueCheckPointWrites: 0,
        queueMaxBytes: "",
        queueType: "memory",
        workers: 1,
    },
});

import pulumi
import pulumi_tencentcloud as tencentcloud

logstash_pipeline = tencentcloud.ElasticsearchLogstashPipeline("logstashPipeline",
    instance_id="ls-xxxxxx",
    op_type=2,
    pipeline={
        "batch_delay": 50,
        "batch_size": 125,
        "config": """input{

}
filter{

}
output{

}

""",
        "pipeline_desc": "",
        "pipeline_id": "logstash-pipeline-test",
        "queue_check_point_writes": 0,
        "queue_max_bytes": "",
        "queue_type": "memory",
        "workers": 1,
    })

package main

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

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := tencentcloud.NewElasticsearchLogstashPipeline(ctx, "logstashPipeline", &tencentcloud.ElasticsearchLogstashPipelineArgs{
			InstanceId: pulumi.String("ls-xxxxxx"),
			OpType:     pulumi.Float64(2),
			Pipeline: &tencentcloud.ElasticsearchLogstashPipelinePipelineArgs{
				BatchDelay:            pulumi.Float64(50),
				BatchSize:             pulumi.Float64(125),
				Config:                pulumi.String("input{\n\n}\nfilter{\n\n}\noutput{\n\n}\n\n"),
				PipelineDesc:          pulumi.String(""),
				PipelineId:            pulumi.String("logstash-pipeline-test"),
				QueueCheckPointWrites: pulumi.Float64(0),
				QueueMaxBytes:         pulumi.String(""),
				QueueType:             pulumi.String("memory"),
				Workers:               pulumi.Float64(1),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

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

return await Deployment.RunAsync(() => 
{
    var logstashPipeline = new Tencentcloud.ElasticsearchLogstashPipeline("logstashPipeline", new()
    {
        InstanceId = "ls-xxxxxx",
        OpType = 2,
        Pipeline = new Tencentcloud.Inputs.ElasticsearchLogstashPipelinePipelineArgs
        {
            BatchDelay = 50,
            BatchSize = 125,
            Config = @"input{

}
filter{

}
output{

}

",
            PipelineDesc = "",
            PipelineId = "logstash-pipeline-test",
            QueueCheckPointWrites = 0,
            QueueMaxBytes = "",
            QueueType = "memory",
            Workers = 1,
        },
    });

});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.tencentcloud.ElasticsearchLogstashPipeline;
import com.pulumi.tencentcloud.ElasticsearchLogstashPipelineArgs;
import com.pulumi.tencentcloud.inputs.ElasticsearchLogstashPipelinePipelineArgs;
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) {
        var logstashPipeline = new ElasticsearchLogstashPipeline("logstashPipeline", ElasticsearchLogstashPipelineArgs.builder()
            .instanceId("ls-xxxxxx")
            .opType(2)
            .pipeline(ElasticsearchLogstashPipelinePipelineArgs.builder()
                .batchDelay(50)
                .batchSize(125)
                .config("""
input{

}
filter{

}
output{

}

                """)
                .pipelineDesc("")
                .pipelineId("logstash-pipeline-test")
                .queueCheckPointWrites(0)
                .queueMaxBytes("")
                .queueType("memory")
                .workers(1)
                .build())
            .build());

    }
}

resources:
  logstashPipeline:
    type: tencentcloud:ElasticsearchLogstashPipeline
    properties:
      instanceId: ls-xxxxxx
      opType: 2
      pipeline:
        batchDelay: 50
        batchSize: 125
        config: |+
          input{

          }
          filter{

          }
          output{

          }          

        pipelineDesc: ""
        pipelineId: logstash-pipeline-test
        queueCheckPointWrites: 0
        queueMaxBytes: ""
        queueType: memory
        workers: 1

Create ElasticsearchLogstashPipeline Resource

Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

Constructor syntax

new ElasticsearchLogstashPipeline(name: string, args: ElasticsearchLogstashPipelineArgs, opts?: CustomResourceOptions);

@overload
def ElasticsearchLogstashPipeline(resource_name: str,
                                  args: ElasticsearchLogstashPipelineArgs,
                                  opts: Optional[ResourceOptions] = None)

@overload
def ElasticsearchLogstashPipeline(resource_name: str,
                                  opts: Optional[ResourceOptions] = None,
                                  instance_id: Optional[str] = None,
                                  op_type: Optional[float] = None,
                                  pipeline: Optional[ElasticsearchLogstashPipelinePipelineArgs] = None,
                                  elasticsearch_logstash_pipeline_id: Optional[str] = None)

func NewElasticsearchLogstashPipeline(ctx *Context, name string, args ElasticsearchLogstashPipelineArgs, opts ...ResourceOption) (*ElasticsearchLogstashPipeline, error)

public ElasticsearchLogstashPipeline(string name, ElasticsearchLogstashPipelineArgs args, CustomResourceOptions? opts = null)

public ElasticsearchLogstashPipeline(String name, ElasticsearchLogstashPipelineArgs args)
public ElasticsearchLogstashPipeline(String name, ElasticsearchLogstashPipelineArgs args, CustomResourceOptions options)

type: tencentcloud:ElasticsearchLogstashPipeline
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.

Parameters

name string: The unique name of the resource.
args ElasticsearchLogstashPipelineArgs: The arguments to resource properties.
opts CustomResourceOptions: Bag of options to control resource's behavior.

resource_name str: The unique name of the resource.
args ElasticsearchLogstashPipelineArgs: The arguments to resource properties.
opts ResourceOptions: Bag of options to control resource's behavior.

ctx Context: Context object for the current deployment.
name string: The unique name of the resource.
args ElasticsearchLogstashPipelineArgs: The arguments to resource properties.
opts ResourceOption: Bag of options to control resource's behavior.

name string: The unique name of the resource.
args ElasticsearchLogstashPipelineArgs: The arguments to resource properties.
opts CustomResourceOptions: Bag of options to control resource's behavior.

name String: The unique name of the resource.
args ElasticsearchLogstashPipelineArgs: The arguments to resource properties.
options CustomResourceOptions: Bag of options to control resource's behavior.

ElasticsearchLogstashPipeline Resource Properties

To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.

Inputs

In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.

The ElasticsearchLogstashPipeline resource accepts the following input properties:

InstanceId string: Logstash instance id.
OpType double: Operation type. 1: save only; 2: save and deploy.
Pipeline ElasticsearchLogstashPipelinePipeline: Pipeline information.
ElasticsearchLogstashPipelineId string: ID of the resource.

InstanceId string: Logstash instance id.
OpType float64: Operation type. 1: save only; 2: save and deploy.
Pipeline ElasticsearchLogstashPipelinePipelineArgs: Pipeline information.
ElasticsearchLogstashPipelineId string: ID of the resource.

instanceId String: Logstash instance id.
opType Double: Operation type. 1: save only; 2: save and deploy.
pipeline ElasticsearchLogstashPipelinePipeline: Pipeline information.
elasticsearchLogstashPipelineId String: ID of the resource.

instanceId string: Logstash instance id.
opType number: Operation type. 1: save only; 2: save and deploy.
pipeline ElasticsearchLogstashPipelinePipeline: Pipeline information.
elasticsearchLogstashPipelineId string: ID of the resource.

instance_id str: Logstash instance id.
op_type float: Operation type. 1: save only; 2: save and deploy.
pipeline ElasticsearchLogstashPipelinePipelineArgs: Pipeline information.
elasticsearch_logstash_pipeline_id str: ID of the resource.

instanceId String: Logstash instance id.
opType Number: Operation type. 1: save only; 2: save and deploy.
pipeline Property Map: Pipeline information.
elasticsearchLogstashPipelineId String: ID of the resource.

Outputs

All input properties are implicitly available as output properties. Additionally, the ElasticsearchLogstashPipeline resource produces the following output properties:

Id string: The provider-assigned unique ID for this managed resource.

Id string: The provider-assigned unique ID for this managed resource.

id String: The provider-assigned unique ID for this managed resource.

id string: The provider-assigned unique ID for this managed resource.

id str: The provider-assigned unique ID for this managed resource.

id String: The provider-assigned unique ID for this managed resource.

Look up Existing ElasticsearchLogstashPipeline Resource

Get an existing ElasticsearchLogstashPipeline resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

public static get(name: string, id: Input<ID>, state?: ElasticsearchLogstashPipelineState, opts?: CustomResourceOptions): ElasticsearchLogstashPipeline

@staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        elasticsearch_logstash_pipeline_id: Optional[str] = None,
        instance_id: Optional[str] = None,
        op_type: Optional[float] = None,
        pipeline: Optional[ElasticsearchLogstashPipelinePipelineArgs] = None) -> ElasticsearchLogstashPipeline

func GetElasticsearchLogstashPipeline(ctx *Context, name string, id IDInput, state *ElasticsearchLogstashPipelineState, opts ...ResourceOption) (*ElasticsearchLogstashPipeline, error)

public static ElasticsearchLogstashPipeline Get(string name, Input<string> id, ElasticsearchLogstashPipelineState? state, CustomResourceOptions? opts = null)

public static ElasticsearchLogstashPipeline get(String name, Output<String> id, ElasticsearchLogstashPipelineState state, CustomResourceOptions options)

resources:  _:    type: tencentcloud:ElasticsearchLogstashPipeline    get:      id: ${id}

name: The unique name of the resulting resource.
id: The unique provider ID of the resource to lookup.
state: Any extra arguments used during the lookup.
opts: A bag of options that control this resource's behavior.

resource_name: The unique name of the resulting resource.
id: The unique provider ID of the resource to lookup.

name: The unique name of the resulting resource.
id: The unique provider ID of the resource to lookup.
state: Any extra arguments used during the lookup.
opts: A bag of options that control this resource's behavior.

name: The unique name of the resulting resource.
id: The unique provider ID of the resource to lookup.
state: Any extra arguments used during the lookup.
opts: A bag of options that control this resource's behavior.

name: The unique name of the resulting resource.
id: The unique provider ID of the resource to lookup.
state: Any extra arguments used during the lookup.
opts: A bag of options that control this resource's behavior.

The following state arguments are supported:

ElasticsearchLogstashPipelineId string: ID of the resource.
InstanceId string: Logstash instance id.
OpType double: Operation type. 1: save only; 2: save and deploy.
Pipeline ElasticsearchLogstashPipelinePipeline: Pipeline information.

ElasticsearchLogstashPipelineId string: ID of the resource.
InstanceId string: Logstash instance id.
OpType float64: Operation type. 1: save only; 2: save and deploy.
Pipeline ElasticsearchLogstashPipelinePipelineArgs: Pipeline information.

elasticsearchLogstashPipelineId String: ID of the resource.
instanceId String: Logstash instance id.
opType Double: Operation type. 1: save only; 2: save and deploy.
pipeline ElasticsearchLogstashPipelinePipeline: Pipeline information.

elasticsearchLogstashPipelineId string: ID of the resource.
instanceId string: Logstash instance id.
opType number: Operation type. 1: save only; 2: save and deploy.
pipeline ElasticsearchLogstashPipelinePipeline: Pipeline information.

elasticsearch_logstash_pipeline_id str: ID of the resource.
instance_id str: Logstash instance id.
op_type float: Operation type. 1: save only; 2: save and deploy.
pipeline ElasticsearchLogstashPipelinePipelineArgs: Pipeline information.

elasticsearchLogstashPipelineId String: ID of the resource.
instanceId String: Logstash instance id.
opType Number: Operation type. 1: save only; 2: save and deploy.
pipeline Property Map: Pipeline information.

Supporting Types

ElasticsearchLogstashPipelinePipeline, ElasticsearchLogstashPipelinePipelineArgs

BatchDelay double: Pipeline batch processing delay.
BatchSize double: Pipe batch size.
Config string: Pipeline configuration content.
PipelineDesc string: Pipeline description information.
PipelineId string: Pipeline id.
QueueCheckPointWrites double: Number of pipeline buffer queue checkpoint writes.
QueueMaxBytes string: Pipeline buffer queue size.
QueueType string: Pipeline buffer queue type.
Workers double: Number of Worker of pipe.

BatchDelay float64: Pipeline batch processing delay.
BatchSize float64: Pipe batch size.
Config string: Pipeline configuration content.
PipelineDesc string: Pipeline description information.
PipelineId string: Pipeline id.
QueueCheckPointWrites float64: Number of pipeline buffer queue checkpoint writes.
QueueMaxBytes string: Pipeline buffer queue size.
QueueType string: Pipeline buffer queue type.
Workers float64: Number of Worker of pipe.

batchDelay Double: Pipeline batch processing delay.
batchSize Double: Pipe batch size.
config String: Pipeline configuration content.
pipelineDesc String: Pipeline description information.
pipelineId String: Pipeline id.
queueCheckPointWrites Double: Number of pipeline buffer queue checkpoint writes.
queueMaxBytes String: Pipeline buffer queue size.
queueType String: Pipeline buffer queue type.
workers Double: Number of Worker of pipe.

batchDelay number: Pipeline batch processing delay.
batchSize number: Pipe batch size.
config string: Pipeline configuration content.
pipelineDesc string: Pipeline description information.
pipelineId string: Pipeline id.
queueCheckPointWrites number: Number of pipeline buffer queue checkpoint writes.
queueMaxBytes string: Pipeline buffer queue size.
queueType string: Pipeline buffer queue type.
workers number: Number of Worker of pipe.

batch_delay float: Pipeline batch processing delay.
batch_size float: Pipe batch size.
config str: Pipeline configuration content.
pipeline_desc str: Pipeline description information.
pipeline_id str: Pipeline id.
queue_check_point_writes float: Number of pipeline buffer queue checkpoint writes.
queue_max_bytes str: Pipeline buffer queue size.
queue_type str: Pipeline buffer queue type.
workers float: Number of Worker of pipe.

batchDelay Number: Pipeline batch processing delay.
batchSize Number: Pipe batch size.
config String: Pipeline configuration content.
pipelineDesc String: Pipeline description information.
pipelineId String: Pipeline id.
queueCheckPointWrites Number: Number of pipeline buffer queue checkpoint writes.
queueMaxBytes String: Pipeline buffer queue size.
queueType String: Pipeline buffer queue type.
workers Number: Number of Worker of pipe.

Import

elasticsearch logstash_pipeline can be imported using the id, e.g.

$ pulumi import tencentcloud:index/elasticsearchLogstashPipeline:ElasticsearchLogstashPipeline logstash_pipeline ${instance_id}#${pipeline_id}

To learn more about importing existing cloud resources, see Importing resources.

Package Details

Repository: tencentcloud tencentcloudstack/terraform-provider-tencentcloud
License
Notes: This Pulumi package is based on the tencentcloud Terraform Provider.

tencentcloud 1.81.189 published on Wednesday, Apr 30, 2025 by tencentcloudstack

tencentcloudstack/terraform-provider-tencentcloud

tencentcloud.ElasticsearchLogstashPipeline

On this page

On this page

Example Usage

Create ElasticsearchLogstashPipeline Resource

Constructor syntax

Parameters

ElasticsearchLogstashPipeline Resource Properties

Inputs

Outputs

Look up Existing ElasticsearchLogstashPipeline Resource

Supporting Types

ElasticsearchLogstashPipelinePipeline, ElasticsearchLogstashPipelinePipelineArgs

Import

Package Details

On this page

On this page