使用ROS CDK创建函数计算服务与函数

import * as ros from '@alicloud/ros-cdk-core';
import * as fc from '@alicloud/ros-cdk-fc3';
import * as ROS from '@alicloud/ros-cdk-ros';

export class DemoStack extends ros.Stack {
  constructor(scope: ros.Construct, id: string, props?: ros.StackProps) {
    super(scope, id, props);
    new ros.RosInfo(this, ros.RosInfo.description, "This is the simple ros cdk app example.");
    // The code that defines your stack goes here

    const x = new ros.RosParameter(this, 'X', {
      type: ros.RosParameterType.NUMBER,
    });
    const y = new ros.RosParameter(this, 'Y', {
      type: ros.RosParameterType.NUMBER,
    });

    const function1 = new fc.Function(this, 'Function', {
      functionName: 'mytest',
      handler: 'index.handler',
      runtime: 'python3',
      code: {
        sourceCode: `import time\nimport json\nimport urllib.request\nimport logging\n\ndef handler(event, context):\n    logger = logging.getLogger()\n    logger.setLevel(logging.INFO)\n    event = json.loads(event)\n    logger.info('receive request: %s', event)\n\n    res_props = event['ResourceProperties']\n\n    result = {\n        'RequestId': event['RequestId'],\n        'LogicalResourceId': event['LogicalResourceId'],\n        'StackId': event['StackId'],\n        'Status': 'SUCCESS',\n        'PhysicalResourceId': 'MyCustomResourceId',\n        'Data': {}\n    }\n\n    if event['RequestType'] != 'Delete':\n        result['Data']['z'] = res_props['X'] + res_props['Y']\n\n    headers = {\n        'Content-type': 'application/json',\n        'Accept': 'application/json',\n        'Date': time.strftime('%a, %d %b %Y %X GMT', time.gmtime()),\n        'User-Agent': 'MyCustomUserAgent'\n    }\n\n    req = urllib.request.Request(event['ResponseURL'], data=json.dumps(result).encode('utf-8'), headers=headers)\n    resp = urllib.request.urlopen(req)\n    resp_content = resp.read().decode('utf-8')\n    logger.info('response: %s', resp_content)\n\n    if resp.getcode() != 200:\n        logger.error('Failed to send response, status code: %s', resp.getcode())\n    else:\n        logger.info('Response sent successfully')\n`
      }
    });

    const customResource = new ROS.CustomResource(this, 'SimpleTest', {
      timeout: 60,
      serviceToken: function1.attrArn,
      parameters: {
        X: x.valueAsNumber,
        Y: y.valueAsNumber
      }
    });
    new ros.RosOutput(this, 'SimpleTestOutputs', {
      value: customResource.attrOutputs
    });
  }
}

const ros = require('@alicloud/ros-cdk-core');
const ROS = require('@alicloud/ros-cdk-ros');
const fc = require('@alicloud/ros-cdk-fc3');

class DemoStack extends ros.Stack {
  /**
   *
   * @param {ros.Construct} scope
   * @param {string} id
   * @param {ros.StackProps} props
   */
  constructor(scope, id, props) {
    super(scope, id, props);
    new ros.RosInfo(this, ros.RosInfo.description, "This is the simple ros cdk app example.");
    // The code that defines your stack goes here
    const x = new ros.RosParameter(this, 'X', {
      type: ros.RosParameterType.NUMBER
    });
    const y = new ros.RosParameter(this, 'Y', {
      type: ros.RosParameterType.NUMBER,
    });

    const function1 = new fc.Function(this, 'Function', {
      functionName: 'mytest',
      handler: 'index.handler',
      runtime: 'python3',
      code: {
        sourceCode: `import time\nimport json\nimport urllib.request\nimport logging\n\ndef handler(event, context):\n    logger = logging.getLogger()\n    logger.setLevel(logging.INFO)\n    event = json.loads(event)\n    logger.info('receive request: %s', event)\n\n    res_props = event['ResourceProperties']\n\n    result = {\n        'RequestId': event['RequestId'],\n        'LogicalResourceId': event['LogicalResourceId'],\n        'StackId': event['StackId'],\n        'Status': 'SUCCESS',\n        'PhysicalResourceId': 'MyCustomResourceId',\n        'Data': {}\n    }\n\n    if event['RequestType'] != 'Delete':\n        result['Data']['z'] = res_props['X'] + res_props['Y']\n\n    headers = {\n        'Content-type': 'application/json',\n        'Accept': 'application/json',\n        'Date': time.strftime('%a, %d %b %Y %X GMT', time.gmtime()),\n        'User-Agent': 'MyCustomUserAgent'\n    }\n\n    req = urllib.request.Request(event['ResponseURL'], data=json.dumps(result).encode('utf-8'), headers=headers)\n    resp = urllib.request.urlopen(req)\n    resp_content = resp.read().decode('utf-8')\n    logger.info('response: %s', resp_content)\n\n    if resp.getcode() != 200:\n        logger.error('Failed to send response, status code: %s', resp.getcode())\n    else:\n        logger.info('Response sent successfully')\n`
      }
    });

    const customResource = new ROS.CustomResource(this, 'SimpleTest', {
      timeout: 60,
      serviceToken: function1.attrArn,
      parameters: {
        X: x.valueAsNumber,
        Y: y.valueAsNumber
      }
    });
    new ros.RosOutput(this, 'SimpleTestOutputs', {
      value: customResource.attrOutputs
    });
  }
}

module.exports = { DemoStack }

package com.myorg;


import com.aliyun.ros.cdk.core.RosParameter;
import com.aliyun.ros.cdk.core.RosOutput;
import com.aliyun.ros.cdk.core.RosOutputProps;
import com.aliyun.ros.cdk.core.RosParameterType;
import com.aliyun.ros.cdk.core.Construct;
import com.aliyun.ros.cdk.core.StackProps;
import com.aliyun.ros.cdk.core.Stack;
import com.aliyun.ros.cdk.ros.CustomResource;
import com.aliyun.ros.cdk.ros.CustomResourceProps;
import com.aliyun.ros.cdk.fc3.*;
import java.util.Map;

public class DemoStack extends Stack {
    public DemoStack(final Construct scope, final String id) {
        this(scope, id, null);
    }

    public DemoStack(final Construct scope, final String id, final StackProps props) {
        super(scope, id, props);

        // The code that defines your stack goes here

        RosParameter x = RosParameter.Builder.create(this, "X")
                .type(RosParameterType.NUMBER)
                .build();

        RosParameter y = RosParameter.Builder.create(this, "Y")
                .type(RosParameterType.NUMBER)
                .build();

        // 创建函数
        Function function = new Function(this, "Function", FunctionProps.builder()
                .functionName("mytest")
                .handler("index.handler")
                .runtime("python3")
                .code(RosFunction.CodeProperty.builder()
                        .sourceCode("" +
                                "import time\n" +
                                "import json\n" +
                                "import urllib.request\n" +
                                "import logging\n\n" +
                                "def handler(event, context):\n" +
                                "    logger = logging.getLogger()\n" +
                                "    logger.setLevel(logging.INFO)\n" +
                                "    event = json.loads(event)\n" +
                                "    logger.info('receive request: %s', event)\n\n" +
                                "    res_props = event['ResourceProperties']\n\n" +
                                "    result = {\n" +
                                "        'RequestId': event['RequestId'],\n" +
                                "        'LogicalResourceId': event['LogicalResourceId'],\n" +
                                "        'StackId': event['StackId'],\n" +
                                "        'Status': 'SUCCESS',\n" +
                                "        'PhysicalResourceId': 'MyCustomResourceId',\n" +
                                "        'Data': {}\n" +
                                "    }\n\n" +
                                "    if event['RequestType'] != 'Delete':\n" +
                                "        result['Data']['z'] = res_props['X'] + res_props['Y']\n\n" +
                                "    headers = {\n" +
                                "        'Content-type': 'application/json',\n" +
                                "        'Accept': 'application/json',\n" +
                                "        'Date': time.strftime('%a, %d %b %Y %X GMT', time.gmtime()),\n" +
                                "        'User-Agent': 'MyCustomUserAgent'\n" +
                                "    }\n\n" +
                                "    req = urllib.request.Request(event['ResponseURL'], data=json.dumps(result).encode('utf-8'), headers=headers)\n" +
                                "    resp = urllib.request.urlopen(req)\n" +
                                "    resp_content = resp.read().decode('utf-8')\n" +
                                "    logger.info('response: %s', resp_content)\n\n" +
                                "    if resp.getcode() != 200:\n" +
                                "        logger.error('Failed to send response, status code: %s', resp.getcode())\n" +
                                "    else:\n" +
                                "        logger.info('Response sent successfully')\n"
                        )
                        .build())
                .build());

        // 创建自定义资源
        CustomResource customResource = new CustomResource(this, "SimpleTest", CustomResourceProps.builder()
                .timeout(60)
                .serviceToken(function.getAttrArn())
                .parameters(Map.of(
                        "X", x.getValueAsNumber(),
                        "Y", y.getValueAsNumber()
                ))
                .build());

        // 输出
        new RosOutput(this, "SimpleTestOutputs", RosOutputProps.builder()
                .value(customResource.getAttrOutputs())
                .build());
    }
}

import ros_cdk_core as core
import ros_cdk_fc3 as fc
import ros_cdk_ros as ros


class DemoStack(core.Stack):

    def __init__(self, scope: core.Construct, construct_id: str, **kwargs) -> None:
        super().__init__(scope, construct_id, **kwargs)

        # The code that defines your stack goes here

        x = core.RosParameter(self, "X", type=core.RosParameterType.NUMBER)

        y = core.RosParameter(self, "Y", type=core.RosParameterType.NUMBER)

        function = fc.Function(self, "Function", fc.FunctionProps(
            function_name='mytest',
            handler='index.handler',
            runtime='python3',
            code={
                'sourceCode': "import time\nimport json\nimport urllib.request\nimport logging\n\ndef handler(event, context):\n    logger = logging.getLogger()\n    logger.setLevel(logging.INFO)\n    event = json.loads(event)\n    logger.info('receive request: %s', event)\n\n    res_props = event['ResourceProperties']\n\n    result = {\n        'RequestId': event['RequestId'],\n        'LogicalResourceId': event['LogicalResourceId'],\n        'StackId': event['StackId'],\n        'Status': 'SUCCESS',\n        'PhysicalResourceId': 'MyCustomResourceId',\n        'Data': {}\n    }\n\n    if event['RequestType'] != 'Delete':\n        result['Data']['z'] = res_props['X'] + res_props['Y']\n\n    headers = {\n        'Content-type': 'application/json',\n        'Accept': 'application/json',\n        'Date': time.strftime('%a, %d %b %Y %X GMT', time.gmtime()),\n        'User-Agent': 'MyCustomUserAgent'\n    }\n\n    req = urllib.request.Request(event['ResponseURL'], data=json.dumps(result).encode('utf-8'), headers=headers)\n    resp = urllib.request.urlopen(req)\n    resp_content = resp.read().decode('utf-8')\n    logger.info('response: %s', resp_content)\n\n    if resp.getcode() != 200:\n        logger.error('Failed to send response, status code: %s', resp.getcode())\n    else:\n        logger.info('Response sent successfully')\n"
            }
        ))

        custom_resource = ros.CustomResource(self, "SimpleTest", ros.CustomResourceProps(
            timeout=60,
            service_token=function.attr_arn,
            parameters={
                "X": x.value_as_number,
                "Y": y.value_as_number
            }
        ))

        core.RosOutput(self, "SimpleTestOutputs", value=custom_resource.attr_outputs)

using System.Collections.Generic;
using AlibabaCloud.SDK.ROS.CDK.Core;
using AlibabaCloud.SDK.ROS.CDK.Fc3;
using AlibabaCloud.SDK.ROS.CDK.Ros;
using Stack = AlibabaCloud.SDK.ROS.CDK.Core.Stack;
using IStackProps = AlibabaCloud.SDK.ROS.CDK.Core.IStackProps;
using RosOutput = AlibabaCloud.SDK.ROS.CDK.Core.RosOutput;
using RosOutputProps = AlibabaCloud.SDK.ROS.CDK.Core.RosOutputProps;


namespace Demo
{
    public class DemoStack : Stack
    {
        public DemoStack(Construct scope, string id, IStackProps props = null) : base(scope, id, props)
                {
            new RosInfo(this, RosInfo.Description, "This is the simple ros cdk app example.");

            var x = new RosParameter(this, "X", new RosParameterProps
            {
                Type = RosParameterType.NUMBER
            });

            var y = new RosParameter(this, "Y", new RosParameterProps
            {
                Type = RosParameterType.NUMBER
            });

            var function1 = new Function(this, "Function", new FunctionProps
            {
                FunctionName = "mytest",
                Handler = "index.handler",
                Runtime = "python3",
                Code = new RosFunction.CodeProperty
                {
                    SourceCode = @"import time
import json
import urllib.request
import logging

def handler(event, context):
    logger = logging.getLogger()
    logger.setLevel(logging.INFO)
    event = json.loads(event)
    logger.info('receive request: %s', event)

    res_props = event['ResourceProperties']

    result = {
        'RequestId': event['RequestId'],
        'LogicalResourceId': event['LogicalResourceId'],
        'StackId': event['StackId'],
        'Status': 'SUCCESS',
        'PhysicalResourceId': 'MyCustomResourceId',
        'Data': {}
    }

    if event['RequestType'] != 'Delete':
        result['Data']['z'] = res_props['X'] + res_props['Y']

    headers = {
        'Content-type': 'application/json',
        'Accept': 'application/json',
        'Date': time.strftime('%a, %d %b %Y %X GMT', time.gmtime()),
        'User-Agent': 'MyCustomUserAgent'
    }

    req = urllib.request.Request(event['ResponseURL'], data=json.dumps(result).encode('utf-8'), headers=headers)
    resp = urllib.request.urlopen(req)
    resp_content = resp.read().decode('utf-8')
    logger.info('response: %s', resp_content)

    if resp.getcode() != 200:
        logger.error('Failed to send response, status code: %s', resp.getcode())
    else:
        logger.info('Response sent successfully')
"
                }
            });

            var customResource = new CustomResource(this, "SimpleTest", new CustomResourceProps
            {
                Timeout = 60,
                ServiceToken = function1.AttrArn,
                Parameters = new Dictionary<string, object>
                {
                    { "X", x.ValueAsNumber },
                    { "Y", y.ValueAsNumber }
                }
            });

            new RosOutput(this, "SimpleTestOutputs", new RosOutputProps
            {
                Value = customResource.AttrOutputs
            });
        }
    }
}