alicloud.sls.getEtls

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

const config = new pulumi.Config();
const name = config.get("name") || "terraform-example";
const defaulthhAPo6 = new alicloud.log.Project("defaulthhAPo6", {
    description: "terraform-etl-example-813",
    projectName: "terraform-etl-example-330",
});
const defaultzWKLkp = new alicloud.log.Store("defaultzWKLkp", {
    hotTtl: 8,
    retentionPeriod: 30,
    shardCount: 2,
    projectName: defaulthhAPo6.id,
    logstoreName: "example",
});
const defaultEtl = new alicloud.sls.Etl("default", {
    project: defaulthhAPo6.id,
    description: "etl-1740472705-185721",
    configuration: {
        script: "* | extend a=1",
        lang: "SPL",
        roleArn: name,
        sinks: [{
            name: "11111",
            endpoint: "cn-hangzhou-intranet.log.aliyuncs.com",
            project: "gy-hangzhou-huolang-1",
            logstore: "gy-rm2",
            datasets: ["__UNNAMED__"],
            roleArn: name,
        }],
        logstore: defaultzWKLkp.logstoreName,
        fromTime: 1706771697,
        toTime: 1738394097,
    },
    jobName: "etl-1740472705-185721",
    displayName: "etl-1740472705-185721",
});
const _default = alicloud.sls.getEtlsOutput({
    logstore: defaultzWKLkp.name,
    project: defaulthhAPo6.id,
});
export const alicloudSlsEtlExampleId = _default.apply(_default => _default.etls?.[0]?.id);

import pulumi
import pulumi_alicloud as alicloud

config = pulumi.Config()
name = config.get("name")
if name is None:
    name = "terraform-example"
defaulthh_a_po6 = alicloud.log.Project("defaulthhAPo6",
    description="terraform-etl-example-813",
    project_name="terraform-etl-example-330")
defaultz_wk_lkp = alicloud.log.Store("defaultzWKLkp",
    hot_ttl=8,
    retention_period=30,
    shard_count=2,
    project_name=defaulthh_a_po6.id,
    logstore_name="example")
default_etl = alicloud.sls.Etl("default",
    project=defaulthh_a_po6.id,
    description="etl-1740472705-185721",
    configuration={
        "script": "* | extend a=1",
        "lang": "SPL",
        "role_arn": name,
        "sinks": [{
            "name": "11111",
            "endpoint": "cn-hangzhou-intranet.log.aliyuncs.com",
            "project": "gy-hangzhou-huolang-1",
            "logstore": "gy-rm2",
            "datasets": ["__UNNAMED__"],
            "role_arn": name,
        }],
        "logstore": defaultz_wk_lkp.logstore_name,
        "from_time": 1706771697,
        "to_time": 1738394097,
    },
    job_name="etl-1740472705-185721",
    display_name="etl-1740472705-185721")
default = alicloud.sls.get_etls_output(logstore=defaultz_wk_lkp.name,
    project=defaulthh_a_po6.id)
pulumi.export("alicloudSlsEtlExampleId", default.etls[0].id)

package main

import (
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/log"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/sls"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi/config"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
cfg := config.New(ctx, "")
name := "terraform-example";
if param := cfg.Get("name"); param != ""{
name = param
}
defaulthhAPo6, err := log.NewProject(ctx, "defaulthhAPo6", &log.ProjectArgs{
Description: pulumi.String("terraform-etl-example-813"),
ProjectName: pulumi.String("terraform-etl-example-330"),
})
if err != nil {
return err
}
defaultzWKLkp, err := log.NewStore(ctx, "defaultzWKLkp", &log.StoreArgs{
HotTtl: pulumi.Int(8),
RetentionPeriod: pulumi.Int(30),
ShardCount: pulumi.Int(2),
ProjectName: defaulthhAPo6.ID(),
LogstoreName: pulumi.String("example"),
})
if err != nil {
return err
}
_, err = sls.NewEtl(ctx, "default", &sls.EtlArgs{
Project: defaulthhAPo6.ID(),
Description: pulumi.String("etl-1740472705-185721"),
Configuration: &sls.EtlConfigurationArgs{
Script: pulumi.String("* | extend a=1"),
Lang: pulumi.String("SPL"),
RoleArn: pulumi.String(name),
Sinks: sls.EtlConfigurationSinkArray{
&sls.EtlConfigurationSinkArgs{
Name: pulumi.String("11111"),
Endpoint: pulumi.String("cn-hangzhou-intranet.log.aliyuncs.com"),
Project: pulumi.String("gy-hangzhou-huolang-1"),
Logstore: pulumi.String("gy-rm2"),
Datasets: pulumi.StringArray{
pulumi.String("__UNNAMED__"),
},
RoleArn: pulumi.String(name),
},
},
Logstore: defaultzWKLkp.LogstoreName,
FromTime: pulumi.Int(1706771697),
ToTime: pulumi.Int(1738394097),
},
JobName: pulumi.String("etl-1740472705-185721"),
DisplayName: pulumi.String("etl-1740472705-185721"),
})
if err != nil {
return err
}
_default := sls.GetEtlsOutput(ctx, sls.GetEtlsOutputArgs{
Logstore: defaultzWKLkp.Name,
Project: defaulthhAPo6.ID(),
}, nil);
ctx.Export("alicloudSlsEtlExampleId", _default.ApplyT(func(_default sls.GetEtlsResult) (*string, error) {
return &default.Etls[0].Id, nil
}).(pulumi.StringPtrOutput))
return nil
})
}

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

return await Deployment.RunAsync(() => 
{
    var config = new Config();
    var name = config.Get("name") ?? "terraform-example";
    var defaulthhAPo6 = new AliCloud.Log.Project("defaulthhAPo6", new()
    {
        Description = "terraform-etl-example-813",
        ProjectName = "terraform-etl-example-330",
    });

    var defaultzWKLkp = new AliCloud.Log.Store("defaultzWKLkp", new()
    {
        HotTtl = 8,
        RetentionPeriod = 30,
        ShardCount = 2,
        ProjectName = defaulthhAPo6.Id,
        LogstoreName = "example",
    });

    var defaultEtl = new AliCloud.Sls.Etl("default", new()
    {
        Project = defaulthhAPo6.Id,
        Description = "etl-1740472705-185721",
        Configuration = new AliCloud.Sls.Inputs.EtlConfigurationArgs
        {
            Script = "* | extend a=1",
            Lang = "SPL",
            RoleArn = name,
            Sinks = new[]
            {
                new AliCloud.Sls.Inputs.EtlConfigurationSinkArgs
                {
                    Name = "11111",
                    Endpoint = "cn-hangzhou-intranet.log.aliyuncs.com",
                    Project = "gy-hangzhou-huolang-1",
                    Logstore = "gy-rm2",
                    Datasets = new[]
                    {
                        "__UNNAMED__",
                    },
                    RoleArn = name,
                },
            },
            Logstore = defaultzWKLkp.LogstoreName,
            FromTime = 1706771697,
            ToTime = 1738394097,
        },
        JobName = "etl-1740472705-185721",
        DisplayName = "etl-1740472705-185721",
    });

    var @default = AliCloud.Sls.GetEtls.Invoke(new()
    {
        Logstore = defaultzWKLkp.Name,
        Project = defaulthhAPo6.Id,
    });

    return new Dictionary<string, object?>
    {
        ["alicloudSlsEtlExampleId"] = @default.Apply(@default => @default.Apply(getEtlsResult => getEtlsResult.Etls[0]?.Id)),
    };
});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.alicloud.log.Project;
import com.pulumi.alicloud.log.ProjectArgs;
import com.pulumi.alicloud.log.Store;
import com.pulumi.alicloud.log.StoreArgs;
import com.pulumi.alicloud.sls.Etl;
import com.pulumi.alicloud.sls.EtlArgs;
import com.pulumi.alicloud.sls.inputs.EtlConfigurationArgs;
import com.pulumi.alicloud.sls.SlsFunctions;
import com.pulumi.alicloud.sls.inputs.GetEtlsArgs;
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 config = ctx.config();
        final var name = config.get("name").orElse("terraform-example");
        var defaulthhAPo6 = new Project("defaulthhAPo6", ProjectArgs.builder()
            .description("terraform-etl-example-813")
            .projectName("terraform-etl-example-330")
            .build());

        var defaultzWKLkp = new Store("defaultzWKLkp", StoreArgs.builder()
            .hotTtl(8)
            .retentionPeriod(30)
            .shardCount(2)
            .projectName(defaulthhAPo6.id())
            .logstoreName("example")
            .build());

        var defaultEtl = new Etl("defaultEtl", EtlArgs.builder()
            .project(defaulthhAPo6.id())
            .description("etl-1740472705-185721")
            .configuration(EtlConfigurationArgs.builder()
                .script("* | extend a=1")
                .lang("SPL")
                .roleArn(name)
                .sinks(EtlConfigurationSinkArgs.builder()
                    .name("11111")
                    .endpoint("cn-hangzhou-intranet.log.aliyuncs.com")
                    .project("gy-hangzhou-huolang-1")
                    .logstore("gy-rm2")
                    .datasets("__UNNAMED__")
                    .roleArn(name)
                    .build())
                .logstore(defaultzWKLkp.logstoreName())
                .fromTime(1706771697)
                .toTime(1738394097)
                .build())
            .jobName("etl-1740472705-185721")
            .displayName("etl-1740472705-185721")
            .build());

        final var default = SlsFunctions.getEtls(GetEtlsArgs.builder()
            .logstore(defaultzWKLkp.name())
            .project(defaulthhAPo6.id())
            .build());

        ctx.export("alicloudSlsEtlExampleId", default_.applyValue(_default_ -> _default_.etls()[0].id()));
    }
}

configuration:
  name:
    type: string
    default: terraform-example
resources:
  defaulthhAPo6:
    type: alicloud:log:Project
    properties:
      description: terraform-etl-example-813
      projectName: terraform-etl-example-330
  defaultzWKLkp:
    type: alicloud:log:Store
    properties:
      hotTtl: '8'
      retentionPeriod: '30'
      shardCount: '2'
      projectName: ${defaulthhAPo6.id}
      logstoreName: example
  defaultEtl:
    type: alicloud:sls:Etl
    name: default
    properties:
      project: ${defaulthhAPo6.id}
      description: etl-1740472705-185721
      configuration:
        script: '* | extend a=1'
        lang: SPL
        roleArn: ${name}
        sinks:
          - name: '11111'
            endpoint: cn-hangzhou-intranet.log.aliyuncs.com
            project: gy-hangzhou-huolang-1
            logstore: gy-rm2
            datasets:
              - __UNNAMED__
            roleArn: ${name}
        logstore: ${defaultzWKLkp.logstoreName}
        fromTime: '1706771697'
        toTime: '1738394097'
      jobName: etl-1740472705-185721
      displayName: etl-1740472705-185721
variables:
  default:
    fn::invoke:
      function: alicloud:sls:getEtls
      arguments:
        logstore: ${defaultzWKLkp.name}
        project: ${defaulthhAPo6.id}
outputs:
  alicloudSlsEtlExampleId: ${default.etls[0].id}

function getEtls(args: GetEtlsArgs, opts?: InvokeOptions): Promise<GetEtlsResult>
function getEtlsOutput(args: GetEtlsOutputArgs, opts?: InvokeOptions): Output<GetEtlsResult>

def get_etls(ids: Optional[Sequence[str]] = None,
             logstore: Optional[str] = None,
             offset: Optional[int] = None,
             output_file: Optional[str] = None,
             project: Optional[str] = None,
             size: Optional[int] = None,
             opts: Optional[InvokeOptions] = None) -> GetEtlsResult
def get_etls_output(ids: Optional[pulumi.Input[Sequence[pulumi.Input[str]]]] = None,
             logstore: Optional[pulumi.Input[str]] = None,
             offset: Optional[pulumi.Input[int]] = None,
             output_file: Optional[pulumi.Input[str]] = None,
             project: Optional[pulumi.Input[str]] = None,
             size: Optional[pulumi.Input[int]] = None,
             opts: Optional[InvokeOptions] = None) -> Output[GetEtlsResult]

func GetEtls(ctx *Context, args *GetEtlsArgs, opts ...InvokeOption) (*GetEtlsResult, error)
func GetEtlsOutput(ctx *Context, args *GetEtlsOutputArgs, opts ...InvokeOption) GetEtlsResultOutput

public static class GetEtls 
{
    public static Task<GetEtlsResult> InvokeAsync(GetEtlsArgs args, InvokeOptions? opts = null)
    public static Output<GetEtlsResult> Invoke(GetEtlsInvokeArgs args, InvokeOptions? opts = null)
}

public static CompletableFuture<GetEtlsResult> getEtls(GetEtlsArgs args, InvokeOptions options)
public static Output<GetEtlsResult> getEtls(GetEtlsArgs args, InvokeOptions options)

fn::invoke:
  function: alicloud:sls/getEtls:getEtls
  arguments:
    # arguments dictionary