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

相关内容

热门资讯

第4分钟实锤!德州ai辅助有用... 第4分钟实锤!德州ai辅助有用(德州app)切实真的有挂(详细辅助科技教程);1、上手简单,内置详细...
第6分钟实锤!智星德州菠萝(德... 第6分钟实锤!智星德州菠萝(德扑)果然真的有挂(详细辅助必备教程)1)智星德州菠萝辅助挂:进一步探索...
第5分钟实锤!德扑之星作弊(w... 第5分钟实锤!德扑之星作弊(wpk德州)果然是有挂(详细辅助必赢教程)1)德扑之星作弊辅助挂:进一步...
一分钟实锤!德州ai辅助有用(... 一分钟实锤!德州ai辅助有用(德扑ai)原来真的是有挂(详细辅助新版2025教程);1、打开软件启动...
第2分钟实锤!德扑之星作弊(来... 第2分钟实锤!德扑之星作弊(来玩德州)一直真的有挂(详细辅助玩家教程)1、上手简单,内置详细流程视频...
六分钟实锤!德州ai辅助软件(... 六分钟实锤!德州ai辅助软件(手机德州)其实有挂(详细辅助科技教程)1、玩家可以在德州ai辅助软件软...
3分钟实锤!德扑数据软件(德扑... 3分钟实锤!德扑数据软件(德扑之星)本来有挂(详细辅助攻略教程)进入游戏-大厅左侧-新手福利-激活码...
第1分钟实锤!智星德州菠萝外挂... 第1分钟实锤!智星德州菠萝外挂(德州wpk)总是存在有挂(详细辅助教你教程)暗藏猫腻,小编详细说明智...
9分钟实锤!德扑起手牌胜率图(... 9分钟实锤!德扑起手牌胜率图(德州)确实是有挂(详细辅助AA德州教程);1、金币登录送、破产送、升级...
第1分钟实锤!德扑之星ai代打... 第1分钟实锤!德扑之星ai代打(德州wpk)竟然真的有挂(详细辅助曝光教程)1、玩家可以在德扑之星a...