alicloud.fc.Trigger

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

const default = alicloud.getAccount({});
const defaultGetRegions = alicloud.getRegions({
    current: true,
});
const defaultInteger = new random.index.Integer("default", {
    max: 99999,
    min: 10000,
});
const defaultProject = new alicloud.log.Project("default", {projectName: `example-value-${defaultInteger.result}`});
const defaultStore = new alicloud.log.Store("default", {
    projectName: defaultProject.name,
    logstoreName: "example-value",
});
const sourceStore = new alicloud.log.Store("source_store", {
    projectName: defaultProject.name,
    logstoreName: "example-source-store",
});
const defaultRole = new alicloud.ram.Role("default", {
    name: `fcservicerole-${defaultInteger.result}`,
    document: `  {
      "Statement": [
        {
          "Action": "sts:AssumeRole",
          "Effect": "Allow",
          "Principal": {
            "Service": [
              "fc.aliyuncs.com"
            ]
          }
        }
      ],
      "Version": "1"
  }
`,
    description: "this is a example",
    force: true,
});
const defaultRolePolicyAttachment = new alicloud.ram.RolePolicyAttachment("default", {
    roleName: defaultRole.name,
    policyName: "AliyunLogFullAccess",
    policyType: "System",
});
const defaultService = new alicloud.fc.Service("default", {
    name: `example-value-${defaultInteger.result}`,
    description: "example-value",
    role: defaultRole.arn,
    logConfig: {
        project: defaultProject.name,
        logstore: defaultStore.name,
        enableInstanceMetrics: true,
        enableRequestMetrics: true,
    },
});
const defaultBucket = new alicloud.oss.Bucket("default", {bucket: `terraform-example-${defaultInteger.result}`});
// If you upload the function by OSS Bucket, you need to specify path can't upload by content.
const defaultBucketObject = new alicloud.oss.BucketObject("default", {
    bucket: defaultBucket.id,
    key: "index.py",
    content: `import logging 
def handler(event, context): 
logger = logging.getLogger() 
logger.info('hello world') 
return 'hello world'`,
});
const defaultFunction = new alicloud.fc.Function("default", {
    service: defaultService.name,
    name: "terraform-example",
    description: "example",
    ossBucket: defaultBucket.id,
    ossKey: defaultBucketObject.key,
    memorySize: 512,
    runtime: "python3.10",
    handler: "hello.handler",
});
const defaultTrigger = new alicloud.fc.Trigger("default", {
    service: defaultService.name,
    "function": defaultFunction.name,
    name: "terraform-example",
    role: defaultRole.arn,
    sourceArn: pulumi.all([defaultGetRegions, _default, defaultProject.name]).apply(([defaultGetRegions, _default, name]) => `acs:log:${defaultGetRegions.regions?.[0]?.id}:${_default.id}:project/${name}`),
    type: "log",
    config: pulumi.interpolate`    {
        "sourceConfig": {
            "logstore": "${sourceStore.name}",
            "startTime": null
        },
        "jobConfig": {
            "maxRetryTime": 3,
            "triggerInterval": 60
        },
        "functionParameter": {
            "a": "b",
            "c": "d"
        },
        "logConfig": {
             "project": "${defaultProject.name}",
            "logstore": "${defaultStore.name}"
        },
        "targetConfig": null,
        "enable": true
    }
  
`,
});

import pulumi
import pulumi_alicloud as alicloud
import pulumi_random as random

default = alicloud.get_account()
default_get_regions = alicloud.get_regions(current=True)
default_integer = random.index.Integer("default",
    max=99999,
    min=10000)
default_project = alicloud.log.Project("default", project_name=f"example-value-{default_integer['result']}")
default_store = alicloud.log.Store("default",
    project_name=default_project.name,
    logstore_name="example-value")
source_store = alicloud.log.Store("source_store",
    project_name=default_project.name,
    logstore_name="example-source-store")
default_role = alicloud.ram.Role("default",
    name=f"fcservicerole-{default_integer['result']}",
    document="""  {
      "Statement": [
        {
          "Action": "sts:AssumeRole",
          "Effect": "Allow",
          "Principal": {
            "Service": [
              "fc.aliyuncs.com"
            ]
          }
        }
      ],
      "Version": "1"
  }
""",
    description="this is a example",
    force=True)
default_role_policy_attachment = alicloud.ram.RolePolicyAttachment("default",
    role_name=default_role.name,
    policy_name="AliyunLogFullAccess",
    policy_type="System")
default_service = alicloud.fc.Service("default",
    name=f"example-value-{default_integer['result']}",
    description="example-value",
    role=default_role.arn,
    log_config=alicloud.fc.ServiceLogConfigArgs(
        project=default_project.name,
        logstore=default_store.name,
        enable_instance_metrics=True,
        enable_request_metrics=True,
    ))
default_bucket = alicloud.oss.Bucket("default", bucket=f"terraform-example-{default_integer['result']}")
# If you upload the function by OSS Bucket, you need to specify path can't upload by content.
default_bucket_object = alicloud.oss.BucketObject("default",
    bucket=default_bucket.id,
    key="index.py",
    content="""import logging 
def handler(event, context): 
logger = logging.getLogger() 
logger.info('hello world') 
return 'hello world'""")
default_function = alicloud.fc.Function("default",
    service=default_service.name,
    name="terraform-example",
    description="example",
    oss_bucket=default_bucket.id,
    oss_key=default_bucket_object.key,
    memory_size=512,
    runtime="python3.10",
    handler="hello.handler")
default_trigger = alicloud.fc.Trigger("default",
    service=default_service.name,
    function=default_function.name,
    name="terraform-example",
    role=default_role.arn,
    source_arn=default_project.name.apply(lambda name: f"acs:log:{default_get_regions.regions[0].id}:{default.id}:project/{name}"),
    type="log",
    config=pulumi.Output.all(source_store.name, default_project.name, default_store.name).apply(lambda sourceStoreName, defaultProjectName, defaultStoreName: f"""    {{
        "sourceConfig": {{
            "logstore": "{source_store_name}",
            "startTime": null
        }},
        "jobConfig": {{
            "maxRetryTime": 3,
            "triggerInterval": 60
        }},
        "functionParameter": {{
            "a": "b",
            "c": "d"
        }},
        "logConfig": {{
             "project": "{default_project_name}",
            "logstore": "{default_store_name}"
        }},
        "targetConfig": null,
        "enable": true
    }}
  
"""))

package main

import (
	"fmt"

	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/fc"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/log"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/oss"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/ram"
	"github.com/pulumi/pulumi-random/sdk/v4/go/random"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_default, err := alicloud.GetAccount(ctx, nil, nil)
		if err != nil {
			return err
		}
		defaultGetRegions, err := alicloud.GetRegions(ctx, &alicloud.GetRegionsArgs{
			Current: pulumi.BoolRef(true),
		}, nil)
		if err != nil {
			return err
		}
		defaultInteger, err := random.NewInteger(ctx, "default", &random.IntegerArgs{
			Max: 99999,
			Min: 10000,
		})
		if err != nil {
			return err
		}
		defaultProject, err := log.NewProject(ctx, "default", &log.ProjectArgs{
			ProjectName: pulumi.String(fmt.Sprintf("example-value-%v", defaultInteger.Result)),
		})
		if err != nil {
			return err
		}
		defaultStore, err := log.NewStore(ctx, "default", &log.StoreArgs{
			ProjectName:  defaultProject.Name,
			LogstoreName: pulumi.String("example-value"),
		})
		if err != nil {
			return err
		}
		sourceStore, err := log.NewStore(ctx, "source_store", &log.StoreArgs{
			ProjectName:  defaultProject.Name,
			LogstoreName: pulumi.String("example-source-store"),
		})
		if err != nil {
			return err
		}
		defaultRole, err := ram.NewRole(ctx, "default", &ram.RoleArgs{
			Name: pulumi.String(fmt.Sprintf("fcservicerole-%v", defaultInteger.Result)),
			Document: pulumi.String(`  {
      "Statement": [
        {
          "Action": "sts:AssumeRole",
          "Effect": "Allow",
          "Principal": {
            "Service": [
              "fc.aliyuncs.com"
            ]
          }
        }
      ],
      "Version": "1"
  }
`),
			Description: pulumi.String("this is a example"),
			Force:       pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		_, err = ram.NewRolePolicyAttachment(ctx, "default", &ram.RolePolicyAttachmentArgs{
			RoleName:   defaultRole.Name,
			PolicyName: pulumi.String("AliyunLogFullAccess"),
			PolicyType: pulumi.String("System"),
		})
		if err != nil {
			return err
		}
		defaultService, err := fc.NewService(ctx, "default", &fc.ServiceArgs{
			Name:        pulumi.String(fmt.Sprintf("example-value-%v", defaultInteger.Result)),
			Description: pulumi.String("example-value"),
			Role:        defaultRole.Arn,
			LogConfig: &fc.ServiceLogConfigArgs{
				Project:               defaultProject.Name,
				Logstore:              defaultStore.Name,
				EnableInstanceMetrics: pulumi.Bool(true),
				EnableRequestMetrics:  pulumi.Bool(true),
			},
		})
		if err != nil {
			return err
		}
		defaultBucket, err := oss.NewBucket(ctx, "default", &oss.BucketArgs{
			Bucket: pulumi.String(fmt.Sprintf("terraform-example-%v", defaultInteger.Result)),
		})
		if err != nil {
			return err
		}
		// If you upload the function by OSS Bucket, you need to specify path can't upload by content.
		defaultBucketObject, err := oss.NewBucketObject(ctx, "default", &oss.BucketObjectArgs{
			Bucket:  defaultBucket.ID(),
			Key:     pulumi.String("index.py"),
			Content: pulumi.String("import logging \ndef handler(event, context): \nlogger = logging.getLogger() \nlogger.info('hello world') \nreturn 'hello world'"),
		})
		if err != nil {
			return err
		}
		defaultFunction, err := fc.NewFunction(ctx, "default", &fc.FunctionArgs{
			Service:     defaultService.Name,
			Name:        pulumi.String("terraform-example"),
			Description: pulumi.String("example"),
			OssBucket:   defaultBucket.ID(),
			OssKey:      defaultBucketObject.Key,
			MemorySize:  pulumi.Int(512),
			Runtime:     pulumi.String("python3.10"),
			Handler:     pulumi.String("hello.handler"),
		})
		if err != nil {
			return err
		}
		_, err = fc.NewTrigger(ctx, "default", &fc.TriggerArgs{
			Service:  defaultService.Name,
			Function: defaultFunction.Name,
			Name:     pulumi.String("terraform-example"),
			Role:     defaultRole.Arn,
			SourceArn: defaultProject.Name.ApplyT(func(name string) (string, error) {
				return fmt.Sprintf("acs:log:%v:%v:project/%v", defaultGetRegions.Regions[0].Id, _default.Id, name), nil
			}).(pulumi.StringOutput),
			Type: pulumi.String("log"),
			Config: pulumi.All(sourceStore.Name, defaultProject.Name, defaultStore.Name).ApplyT(func(_args []interface{}) (string, error) {
				sourceStoreName := _args[0].(string)
				defaultProjectName := _args[1].(string)
				defaultStoreName := _args[2].(string)
				return fmt.Sprintf(`    {
        "sourceConfig": {
            "logstore": "%v",
            "startTime": null
        },
        "jobConfig": {
            "maxRetryTime": 3,
            "triggerInterval": 60
        },
        "functionParameter": {
            "a": "b",
            "c": "d"
        },
        "logConfig": {
             "project": "%v",
            "logstore": "%v"
        },
        "targetConfig": null,
        "enable": true
    }
  
`, sourceStoreName, defaultProjectName, defaultStoreName), nil
			}).(pulumi.StringOutput),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

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

return await Deployment.RunAsync(() => 
{
    var @default = AliCloud.GetAccount.Invoke();

    var defaultGetRegions = AliCloud.GetRegions.Invoke(new()
    {
        Current = true,
    });

    var defaultInteger = new Random.Index.Integer("default", new()
    {
        Max = 99999,
        Min = 10000,
    });

    var defaultProject = new AliCloud.Log.Project("default", new()
    {
        ProjectName = $"example-value-{defaultInteger.Result}",
    });

    var defaultStore = new AliCloud.Log.Store("default", new()
    {
        ProjectName = defaultProject.Name,
        LogstoreName = "example-value",
    });

    var sourceStore = new AliCloud.Log.Store("source_store", new()
    {
        ProjectName = defaultProject.Name,
        LogstoreName = "example-source-store",
    });

    var defaultRole = new AliCloud.Ram.Role("default", new()
    {
        Name = $"fcservicerole-{defaultInteger.Result}",
        Document = @"  {
      ""Statement"": [
        {
          ""Action"": ""sts:AssumeRole"",
          ""Effect"": ""Allow"",
          ""Principal"": {
            ""Service"": [
              ""fc.aliyuncs.com""
            ]
          }
        }
      ],
      ""Version"": ""1""
  }
",
        Description = "this is a example",
        Force = true,
    });

    var defaultRolePolicyAttachment = new AliCloud.Ram.RolePolicyAttachment("default", new()
    {
        RoleName = defaultRole.Name,
        PolicyName = "AliyunLogFullAccess",
        PolicyType = "System",
    });

    var defaultService = new AliCloud.FC.Service("default", new()
    {
        Name = $"example-value-{defaultInteger.Result}",
        Description = "example-value",
        Role = defaultRole.Arn,
        LogConfig = new AliCloud.FC.Inputs.ServiceLogConfigArgs
        {
            Project = defaultProject.Name,
            Logstore = defaultStore.Name,
            EnableInstanceMetrics = true,
            EnableRequestMetrics = true,
        },
    });

    var defaultBucket = new AliCloud.Oss.Bucket("default", new()
    {
        BucketName = $"terraform-example-{defaultInteger.Result}",
    });

    // If you upload the function by OSS Bucket, you need to specify path can't upload by content.
    var defaultBucketObject = new AliCloud.Oss.BucketObject("default", new()
    {
        Bucket = defaultBucket.Id,
        Key = "index.py",
        Content = @"import logging 
def handler(event, context): 
logger = logging.getLogger() 
logger.info('hello world') 
return 'hello world'",
    });

    var defaultFunction = new AliCloud.FC.Function("default", new()
    {
        Service = defaultService.Name,
        Name = "terraform-example",
        Description = "example",
        OssBucket = defaultBucket.Id,
        OssKey = defaultBucketObject.Key,
        MemorySize = 512,
        Runtime = "python3.10",
        Handler = "hello.handler",
    });

    var defaultTrigger = new AliCloud.FC.Trigger("default", new()
    {
        Service = defaultService.Name,
        Function = defaultFunction.Name,
        Name = "terraform-example",
        Role = defaultRole.Arn,
        SourceArn = Output.Tuple(defaultGetRegions, @default, defaultProject.Name).Apply(values =>
        {
            var defaultGetRegions = values.Item1;
            var @default = values.Item2;
            var name = values.Item3;
            return $"acs:log:{defaultGetRegions.Apply(getRegionsResult => getRegionsResult.Regions[0]?.Id)}:{@default.Apply(getAccountResult => getAccountResult.Id)}:project/{name}";
        }),
        Type = "log",
        Config = Output.Tuple(sourceStore.Name, defaultProject.Name, defaultStore.Name).Apply(values =>
        {
            var sourceStoreName = values.Item1;
            var defaultProjectName = values.Item2;
            var defaultStoreName = values.Item3;
            return @$"    {{
        ""sourceConfig"": {{
            ""logstore"": ""{sourceStoreName}"",
            ""startTime"": null
        }},
        ""jobConfig"": {{
            ""maxRetryTime"": 3,
            ""triggerInterval"": 60
        }},
        ""functionParameter"": {{
            ""a"": ""b"",
            ""c"": ""d""
        }},
        ""logConfig"": {{
             ""project"": ""{defaultProjectName}"",
            ""logstore"": ""{defaultStoreName}""
        }},
        ""targetConfig"": null,
        ""enable"": true
    }}
  
";
        }),
    });

});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.alicloud.AlicloudFunctions;
import com.pulumi.alicloud.inputs.GetRegionsArgs;
import com.pulumi.random.integer;
import com.pulumi.random.IntegerArgs;
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.ram.Role;
import com.pulumi.alicloud.ram.RoleArgs;
import com.pulumi.alicloud.ram.RolePolicyAttachment;
import com.pulumi.alicloud.ram.RolePolicyAttachmentArgs;
import com.pulumi.alicloud.fc.Service;
import com.pulumi.alicloud.fc.ServiceArgs;
import com.pulumi.alicloud.fc.inputs.ServiceLogConfigArgs;
import com.pulumi.alicloud.oss.Bucket;
import com.pulumi.alicloud.oss.BucketArgs;
import com.pulumi.alicloud.oss.BucketObject;
import com.pulumi.alicloud.oss.BucketObjectArgs;
import com.pulumi.alicloud.fc.Function;
import com.pulumi.alicloud.fc.FunctionArgs;
import com.pulumi.alicloud.fc.Trigger;
import com.pulumi.alicloud.fc.TriggerArgs;
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 default = AlicloudFunctions.getAccount();

        final var defaultGetRegions = AlicloudFunctions.getRegions(GetRegionsArgs.builder()
            .current(true)
            .build());

        var defaultInteger = new Integer("defaultInteger", IntegerArgs.builder()        
            .max(99999)
            .min(10000)
            .build());

        var defaultProject = new Project("defaultProject", ProjectArgs.builder()        
            .projectName(String.format("example-value-%s", defaultInteger.result()))
            .build());

        var defaultStore = new Store("defaultStore", StoreArgs.builder()        
            .projectName(defaultProject.name())
            .logstoreName("example-value")
            .build());

        var sourceStore = new Store("sourceStore", StoreArgs.builder()        
            .projectName(defaultProject.name())
            .logstoreName("example-source-store")
            .build());

        var defaultRole = new Role("defaultRole", RoleArgs.builder()        
            .name(String.format("fcservicerole-%s", defaultInteger.result()))
            .document("""
  {
      "Statement": [
        {
          "Action": "sts:AssumeRole",
          "Effect": "Allow",
          "Principal": {
            "Service": [
              "fc.aliyuncs.com"
            ]
          }
        }
      ],
      "Version": "1"
  }
            """)
            .description("this is a example")
            .force(true)
            .build());

        var defaultRolePolicyAttachment = new RolePolicyAttachment("defaultRolePolicyAttachment", RolePolicyAttachmentArgs.builder()        
            .roleName(defaultRole.name())
            .policyName("AliyunLogFullAccess")
            .policyType("System")
            .build());

        var defaultService = new Service("defaultService", ServiceArgs.builder()        
            .name(String.format("example-value-%s", defaultInteger.result()))
            .description("example-value")
            .role(defaultRole.arn())
            .logConfig(ServiceLogConfigArgs.builder()
                .project(defaultProject.name())
                .logstore(defaultStore.name())
                .enableInstanceMetrics(true)
                .enableRequestMetrics(true)
                .build())
            .build());

        var defaultBucket = new Bucket("defaultBucket", BucketArgs.builder()        
            .bucket(String.format("terraform-example-%s", defaultInteger.result()))
            .build());

        // If you upload the function by OSS Bucket, you need to specify path can't upload by content.
        var defaultBucketObject = new BucketObject("defaultBucketObject", BucketObjectArgs.builder()        
            .bucket(defaultBucket.id())
            .key("index.py")
            .content("""
import logging 
def handler(event, context): 
logger = logging.getLogger() 
logger.info('hello world') 
return 'hello world'            """)
            .build());

        var defaultFunction = new Function("defaultFunction", FunctionArgs.builder()        
            .service(defaultService.name())
            .name("terraform-example")
            .description("example")
            .ossBucket(defaultBucket.id())
            .ossKey(defaultBucketObject.key())
            .memorySize("512")
            .runtime("python3.10")
            .handler("hello.handler")
            .build());

        var defaultTrigger = new Trigger("defaultTrigger", TriggerArgs.builder()        
            .service(defaultService.name())
            .function(defaultFunction.name())
            .name("terraform-example")
            .role(defaultRole.arn())
            .sourceArn(defaultProject.name().applyValue(name -> String.format("acs:log:%s:%s:project/%s", defaultGetRegions.applyValue(getRegionsResult -> getRegionsResult.regions()[0].id()),default_.id(),name)))
            .type("log")
            .config(Output.tuple(sourceStore.name(), defaultProject.name(), defaultStore.name()).applyValue(values -> {
                var sourceStoreName = values.t1;
                var defaultProjectName = values.t2;
                var defaultStoreName = values.t3;
                return """
    {
        "sourceConfig": {
            "logstore": "%s",
            "startTime": null
        },
        "jobConfig": {
            "maxRetryTime": 3,
            "triggerInterval": 60
        },
        "functionParameter": {
            "a": "b",
            "c": "d"
        },
        "logConfig": {
             "project": "%s",
            "logstore": "%s"
        },
        "targetConfig": null,
        "enable": true
    }
  
", sourceStoreName,defaultProjectName,defaultStoreName);
            }))
            .build());

    }
}

resources:
  defaultInteger:
    type: random:integer
    name: default
    properties:
      max: 99999
      min: 10000
  defaultProject:
    type: alicloud:log:Project
    name: default
    properties:
      projectName: example-value-${defaultInteger.result}
  defaultStore:
    type: alicloud:log:Store
    name: default
    properties:
      projectName: ${defaultProject.name}
      logstoreName: example-value
  sourceStore:
    type: alicloud:log:Store
    name: source_store
    properties:
      projectName: ${defaultProject.name}
      logstoreName: example-source-store
  defaultRole:
    type: alicloud:ram:Role
    name: default
    properties:
      name: fcservicerole-${defaultInteger.result}
      document: |2
          {
              "Statement": [
                {
                  "Action": "sts:AssumeRole",
                  "Effect": "Allow",
                  "Principal": {
                    "Service": [
                      "fc.aliyuncs.com"
                    ]
                  }
                }
              ],
              "Version": "1"
          }
      description: this is a example
      force: true
  defaultRolePolicyAttachment:
    type: alicloud:ram:RolePolicyAttachment
    name: default
    properties:
      roleName: ${defaultRole.name}
      policyName: AliyunLogFullAccess
      policyType: System
  defaultService:
    type: alicloud:fc:Service
    name: default
    properties:
      name: example-value-${defaultInteger.result}
      description: example-value
      role: ${defaultRole.arn}
      logConfig:
        project: ${defaultProject.name}
        logstore: ${defaultStore.name}
        enableInstanceMetrics: true
        enableRequestMetrics: true
  defaultBucket:
    type: alicloud:oss:Bucket
    name: default
    properties:
      bucket: terraform-example-${defaultInteger.result}
  # If you upload the function by OSS Bucket, you need to specify path can't upload by content.
  defaultBucketObject:
    type: alicloud:oss:BucketObject
    name: default
    properties:
      bucket: ${defaultBucket.id}
      key: index.py
      content: "import logging \ndef handler(event, context): \nlogger = logging.getLogger() \nlogger.info('hello world') \nreturn 'hello world'"
  defaultFunction:
    type: alicloud:fc:Function
    name: default
    properties:
      service: ${defaultService.name}
      name: terraform-example
      description: example
      ossBucket: ${defaultBucket.id}
      ossKey: ${defaultBucketObject.key}
      memorySize: '512'
      runtime: python3.10
      handler: hello.handler
  defaultTrigger:
    type: alicloud:fc:Trigger
    name: default
    properties:
      service: ${defaultService.name}
      function: ${defaultFunction.name}
      name: terraform-example
      role: ${defaultRole.arn}
      sourceArn: acs:log:${defaultGetRegions.regions[0].id}:${default.id}:project/${defaultProject.name}
      type: log
      config: "    {\n        \"sourceConfig\": {\n            \"logstore\": \"${sourceStore.name}\",\n            \"startTime\": null\n        },\n        \"jobConfig\": {\n            \"maxRetryTime\": 3,\n            \"triggerInterval\": 60\n        },\n        \"functionParameter\": {\n            \"a\": \"b\",\n            \"c\": \"d\"\n        },\n        \"logConfig\": {\n             \"project\": \"${defaultProject.name}\",\n            \"logstore\": \"${defaultStore.name}\"\n        },\n        \"targetConfig\": null,\n        \"enable\": true\n    }\n  \n"
variables:
  default:
    fn::invoke:
      Function: alicloud:getAccount
      Arguments: {}
  defaultGetRegions:
    fn::invoke:
      Function: alicloud:getRegions
      Arguments:
        current: true

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

const default = alicloud.getAccount({});
const defaultGetRegions = alicloud.getRegions({
    current: true,
});
const defaultInteger = new random.index.Integer("default", {
    max: 99999,
    min: 10000,
});
const defaultTopic = new alicloud.mns.Topic("default", {name: `example-value-${defaultInteger.result}`});
const defaultRole = new alicloud.ram.Role("default", {
    name: `fcservicerole-${defaultInteger.result}`,
    document: `  {
      "Statement": [
        {
          "Action": "sts:AssumeRole",
          "Effect": "Allow",
          "Principal": {
            "Service": [
              "mns.aliyuncs.com"
            ]
          }
        }
      ],
      "Version": "1"
  }
`,
    description: "this is a example",
    force: true,
});
const defaultRolePolicyAttachment = new alicloud.ram.RolePolicyAttachment("default", {
    roleName: defaultRole.name,
    policyName: "AliyunMNSNotificationRolePolicy",
    policyType: "System",
});
const defaultService = new alicloud.fc.Service("default", {
    name: `example-value-${defaultInteger.result}`,
    description: "example-value",
    internetAccess: false,
});
const defaultBucket = new alicloud.oss.Bucket("default", {bucket: `terraform-example-${defaultInteger.result}`});
// If you upload the function by OSS Bucket, you need to specify path can't upload by content.
const defaultBucketObject = new alicloud.oss.BucketObject("default", {
    bucket: defaultBucket.id,
    key: "index.py",
    content: `import logging 
def handler(event, context): 
logger = logging.getLogger() 
logger.info('hello world') 
return 'hello world'`,
});
const defaultFunction = new alicloud.fc.Function("default", {
    service: defaultService.name,
    name: `terraform-example-${defaultInteger.result}`,
    description: "example",
    ossBucket: defaultBucket.id,
    ossKey: defaultBucketObject.key,
    memorySize: 512,
    runtime: "python3.10",
    handler: "hello.handler",
});
const defaultTrigger = new alicloud.fc.Trigger("default", {
    service: defaultService.name,
    "function": defaultFunction.name,
    name: "terraform-example",
    role: defaultRole.arn,
    sourceArn: pulumi.all([defaultGetRegions, _default, defaultTopic.name]).apply(([defaultGetRegions, _default, name]) => `acs:mns:${defaultGetRegions.regions?.[0]?.id}:${_default.id}:/topics/${name}`),
    type: "mns_topic",
    configMns: `  {
    "filterTag":"exampleTag",
    "notifyContentFormat":"STREAM",
    "notifyStrategy":"BACKOFF_RETRY"
  }
`,
});

import pulumi
import pulumi_alicloud as alicloud
import pulumi_random as random

default = alicloud.get_account()
default_get_regions = alicloud.get_regions(current=True)
default_integer = random.index.Integer("default",
    max=99999,
    min=10000)
default_topic = alicloud.mns.Topic("default", name=f"example-value-{default_integer['result']}")
default_role = alicloud.ram.Role("default",
    name=f"fcservicerole-{default_integer['result']}",
    document="""  {
      "Statement": [
        {
          "Action": "sts:AssumeRole",
          "Effect": "Allow",
          "Principal": {
            "Service": [
              "mns.aliyuncs.com"
            ]
          }
        }
      ],
      "Version": "1"
  }
""",
    description="this is a example",
    force=True)
default_role_policy_attachment = alicloud.ram.RolePolicyAttachment("default",
    role_name=default_role.name,
    policy_name="AliyunMNSNotificationRolePolicy",
    policy_type="System")
default_service = alicloud.fc.Service("default",
    name=f"example-value-{default_integer['result']}",
    description="example-value",
    internet_access=False)
default_bucket = alicloud.oss.Bucket("default", bucket=f"terraform-example-{default_integer['result']}")
# If you upload the function by OSS Bucket, you need to specify path can't upload by content.
default_bucket_object = alicloud.oss.BucketObject("default",
    bucket=default_bucket.id,
    key="index.py",
    content="""import logging 
def handler(event, context): 
logger = logging.getLogger() 
logger.info('hello world') 
return 'hello world'""")
default_function = alicloud.fc.Function("default",
    service=default_service.name,
    name=f"terraform-example-{default_integer['result']}",
    description="example",
    oss_bucket=default_bucket.id,
    oss_key=default_bucket_object.key,
    memory_size=512,
    runtime="python3.10",
    handler="hello.handler")
default_trigger = alicloud.fc.Trigger("default",
    service=default_service.name,
    function=default_function.name,
    name="terraform-example",
    role=default_role.arn,
    source_arn=default_topic.name.apply(lambda name: f"acs:mns:{default_get_regions.regions[0].id}:{default.id}:/topics/{name}"),
    type="mns_topic",
    config_mns="""  {
    "filterTag":"exampleTag",
    "notifyContentFormat":"STREAM",
    "notifyStrategy":"BACKOFF_RETRY"
  }
""")

package main

import (
	"fmt"

	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/fc"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/mns"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/oss"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/ram"
	"github.com/pulumi/pulumi-random/sdk/v4/go/random"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_default, err := alicloud.GetAccount(ctx, nil, nil)
		if err != nil {
			return err
		}
		defaultGetRegions, err := alicloud.GetRegions(ctx, &alicloud.GetRegionsArgs{
			Current: pulumi.BoolRef(true),
		}, nil)
		if err != nil {
			return err
		}
		defaultInteger, err := random.NewInteger(ctx, "default", &random.IntegerArgs{
			Max: 99999,
			Min: 10000,
		})
		if err != nil {
			return err
		}
		defaultTopic, err := mns.NewTopic(ctx, "default", &mns.TopicArgs{
			Name: pulumi.String(fmt.Sprintf("example-value-%v", defaultInteger.Result)),
		})
		if err != nil {
			return err
		}
		defaultRole, err := ram.NewRole(ctx, "default", &ram.RoleArgs{
			Name: pulumi.String(fmt.Sprintf("fcservicerole-%v", defaultInteger.Result)),
			Document: pulumi.String(`  {
      "Statement": [
        {
          "Action": "sts:AssumeRole",
          "Effect": "Allow",
          "Principal": {
            "Service": [
              "mns.aliyuncs.com"
            ]
          }
        }
      ],
      "Version": "1"
  }
`),
			Description: pulumi.String("this is a example"),
			Force:       pulumi.Bool(true),
		})
		if err != nil {
			return err
		}
		_, err = ram.NewRolePolicyAttachment(ctx, "default", &ram.RolePolicyAttachmentArgs{
			RoleName:   defaultRole.Name,
			PolicyName: pulumi.String("AliyunMNSNotificationRolePolicy"),
			PolicyType: pulumi.String("System"),
		})
		if err != nil {
			return err
		}
		defaultService, err := fc.NewService(ctx, "default", &fc.ServiceArgs{
			Name:           pulumi.String(fmt.Sprintf("example-value-%v", defaultInteger.Result)),
			Description:    pulumi.String("example-value"),
			InternetAccess: pulumi.Bool(false),
		})
		if err != nil {
			return err
		}
		defaultBucket, err := oss.NewBucket(ctx, "default", &oss.BucketArgs{
			Bucket: pulumi.String(fmt.Sprintf("terraform-example-%v", defaultInteger.Result)),
		})
		if err != nil {
			return err
		}
		// If you upload the function by OSS Bucket, you need to specify path can't upload by content.
		defaultBucketObject, err := oss.NewBucketObject(ctx, "default", &oss.BucketObjectArgs{
			Bucket:  defaultBucket.ID(),
			Key:     pulumi.String("index.py"),
			Content: pulumi.String("import logging \ndef handler(event, context): \nlogger = logging.getLogger() \nlogger.info('hello world') \nreturn 'hello world'"),
		})
		if err != nil {
			return err
		}
		defaultFunction, err := fc.NewFunction(ctx, "default", &fc.FunctionArgs{
			Service:     defaultService.Name,
			Name:        pulumi.String(fmt.Sprintf("terraform-example-%v", defaultInteger.Result)),
			Description: pulumi.String("example"),
			OssBucket:   defaultBucket.ID(),
			OssKey:      defaultBucketObject.Key,
			MemorySize:  pulumi.Int(512),
			Runtime:     pulumi.String("python3.10"),
			Handler:     pulumi.String("hello.handler"),
		})
		if err != nil {
			return err
		}
		_, err = fc.NewTrigger(ctx, "default", &fc.TriggerArgs{
			Service:  defaultService.Name,
			Function: defaultFunction.Name,
			Name:     pulumi.String("terraform-example"),
			Role:     defaultRole.Arn,
			SourceArn: defaultTopic.Name.ApplyT(func(name string) (string, error) {
				return fmt.Sprintf("acs:mns:%v:%v:/topics/%v", defaultGetRegions.Regions[0].Id, _default.Id, name), nil
			}).(pulumi.StringOutput),
			Type: pulumi.String("mns_topic"),
			ConfigMns: pulumi.String(`  {
    "filterTag":"exampleTag",
    "notifyContentFormat":"STREAM",
    "notifyStrategy":"BACKOFF_RETRY"
  }
`),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

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

return await Deployment.RunAsync(() => 
{
    var @default = AliCloud.GetAccount.Invoke();

    var defaultGetRegions = AliCloud.GetRegions.Invoke(new()
    {
        Current = true,
    });

    var defaultInteger = new Random.Index.Integer("default", new()
    {
        Max = 99999,
        Min = 10000,
    });

    var defaultTopic = new AliCloud.Mns.Topic("default", new()
    {
        Name = $"example-value-{defaultInteger.Result}",
    });

    var defaultRole = new AliCloud.Ram.Role("default", new()
    {
        Name = $"fcservicerole-{defaultInteger.Result}",
        Document = @"  {
      ""Statement"": [
        {
          ""Action"": ""sts:AssumeRole"",
          ""Effect"": ""Allow"",
          ""Principal"": {
            ""Service"": [
              ""mns.aliyuncs.com""
            ]
          }
        }
      ],
      ""Version"": ""1""
  }
",
        Description = "this is a example",
        Force = true,
    });

    var defaultRolePolicyAttachment = new AliCloud.Ram.RolePolicyAttachment("default", new()
    {
        RoleName = defaultRole.Name,
        PolicyName = "AliyunMNSNotificationRolePolicy",
        PolicyType = "System",
    });

    var defaultService = new AliCloud.FC.Service("default", new()
    {
        Name = $"example-value-{defaultInteger.Result}",
        Description = "example-value",
        InternetAccess = false,
    });

    var defaultBucket = new AliCloud.Oss.Bucket("default", new()
    {
        BucketName = $"terraform-example-{defaultInteger.Result}",
    });

    // If you upload the function by OSS Bucket, you need to specify path can't upload by content.
    var defaultBucketObject = new AliCloud.Oss.BucketObject("default", new()
    {
        Bucket = defaultBucket.Id,
        Key = "index.py",
        Content = @"import logging 
def handler(event, context): 
logger = logging.getLogger() 
logger.info('hello world') 
return 'hello world'",
    });

    var defaultFunction = new AliCloud.FC.Function("default", new()
    {
        Service = defaultService.Name,
        Name = $"terraform-example-{defaultInteger.Result}",
        Description = "example",
        OssBucket = defaultBucket.Id,
        OssKey = defaultBucketObject.Key,
        MemorySize = 512,
        Runtime = "python3.10",
        Handler = "hello.handler",
    });

    var defaultTrigger = new AliCloud.FC.Trigger("default", new()
    {
        Service = defaultService.Name,
        Function = defaultFunction.Name,
        Name = "terraform-example",
        Role = defaultRole.Arn,
        SourceArn = Output.Tuple(defaultGetRegions, @default, defaultTopic.Name).Apply(values =>
        {
            var defaultGetRegions = values.Item1;
            var @default = values.Item2;
            var name = values.Item3;
            return $"acs:mns:{defaultGetRegions.Apply(getRegionsResult => getRegionsResult.Regions[0]?.Id)}:{@default.Apply(getAccountResult => getAccountResult.Id)}:/topics/{name}";
        }),
        Type = "mns_topic",
        ConfigMns = @"  {
    ""filterTag"":""exampleTag"",
    ""notifyContentFormat"":""STREAM"",
    ""notifyStrategy"":""BACKOFF_RETRY""
  }
",
    });

});