awscdk中通过添加VPC配置来配置KinesisDataAnalytic应用程序
创始人
2024-09-24 03:30:26
0

我们可以使用AWS CDK构建基础设施即代码,包括配置Kinesis Data Analytic应用程序的VPC设置。以下是一些示例代码:

import * as cdk from 'aws-cdk-lib';
import * as kinesis from 'aws-cdk-lib/aws-kinesis';
import * as kda from 'aws-cdk-lib/aws-kinesisanalytics';
import * as ec2 from 'aws-cdk-lib/aws-ec2';

const app = new cdk.App();

const stack = new cdk.Stack(app, 'my-stack');

// 创建VPC
const vpc = new ec2.Vpc(stack, 'my-vpc');

// 创建Kinesis Data Stream
const inputStream = new kinesis.Stream(stack, 'my-input-stream', {
  streamName: 'my-input-stream',
  shardCount: 1,
});

// 创建Kinesis Data Analytics应用
const kdaApp = new kda.CfnApplicationV2(stack, 'my-kda-app', {
  applicationName: 'my-kda-app',
  runtimeEnvironment: 'SQL-1_0',
  serviceExecutionRole: 'arn:aws:iam::123456789012:role/my-kda-app-service-role',
  applicationConfiguration: {
    inputs: [{
      namePrefix: 'input',
      inputSchema: {
        recordColumns: [{
          name: 'value',
          mapping: '$.value.N',
          sqlType: 'DOUBLE',
        }],
        recordFormat: {
          recordFormatType: 'JSON',
          mappingParameters: {
            jsonMappingParameters: {
              recordRowPath: '$',
            },
          },
        },
      },
      kinesisStreamsInput: {
        resourceArn: inputStream.streamArn,
        roleArn: 'arn:aws:iam::123456789012:role/my-kda-app-kinesis-streams-input-role',
      },
      inputParallelism: {
        count: 1,
      },
      inputProcessingConfiguration: {
        inputLambdaProcessor: {
          resourceArn: processFunction.functionArn,
          roleArn: 'arn:aws:iam::123456789012:role/my-kda-app-lambda-function-role',
        },
      },
      kinesisFirehoseInput: {
        resourceArn: firehoseStream.streamArn,
        roleArn: 'arn:aws:iam::123456789012:role/my-kda-app-firehose-input-role',
      },
    }],
  },
});

// 更新Kinesis Data Analytics应用的VPC配置
kdaApp.addPropertyOverride('vpcConfiguration', {
  subnetIds: vpc.privateSubnets.map(subnet => subnet.subnetId),
  securityGroupIds: [vpc.vpcDefaultSecurityGroup

相关内容

热门资讯

开挂辅助平台"wep... 开挂辅助平台"wepokerplus辅助"开挂(透视)辅助下载(有挂透视)>>您好:软件加13670...
辅助开挂!新道游辅助软件下载,... 辅助开挂!新道游辅助软件下载,wepoker怎么挂底牌(透视)开挂辅助插件(有挂方针);新道游辅助软...
开挂辅助插件"hhp... 开挂辅助插件"hhpoker哪个俱乐部靠谱"开挂(透视)辅助工具(有挂功能) 了解更多开挂安装加(1...
辅助开挂!闲逸辅助软件下载苹果... 辅助开挂!闲逸辅助软件下载苹果,hhpoker底牌透视脚本(透视)开挂辅助脚本(有挂方略),闲逸辅助...
开挂辅助插件"拱趴大... 大家好,今天小编来为大家解答拱趴大菠萝万能挂图解这个问题咨询软件客服可以免费测试直接加微信(1367...
辅助开挂!wepoker专用辅... 辅助开挂!wepoker专用辅助程序,epoker透视底牌(透视)开挂辅助安装(有挂分享);1、超多...
开挂辅助脚本"wep... 您好:这款wepoker透视脚本免费app游戏是可以开挂的,确实是有挂的,很多玩家在这款wepoke...
辅助开挂!手机科乐辅助,pok... 辅助开挂!手机科乐辅助,pokemmo手机辅助软件(透视)开挂辅助脚本(新版有挂);手机科乐辅助是一...
开挂辅助下载"hhp... 开挂辅助下载"hhpoker真的有透视吗"开挂(透视)辅助安装(有人有挂)《详细加薇13670430...
辅助开挂!闲逸碰胡辅助器,we... 辅助开挂!闲逸碰胡辅助器,wejoker辅助软件价格(透视)开挂辅助脚本(有挂教程);闲逸碰胡辅助器...