constructor()

in src/modules/insights/cdk/lib/iot-twin-maker-kda-stack.ts [11:166]

• 147 lines of code
• 1 McCabe index (conditional complexity)

  constructor(scope: cdk.App, id: string, props?: cdk.StackProps) {
    super(scope, id, props);

    const stack = cdk.Stack.of(this);
    const stackName = stack.stackName;
    const region = stack.region;
    const accountId = stack.account;

    const glueDatabase = new glue.CfnDatabase(this, "glueDatabase", {
      catalogId: cdk.Fn.ref("AWS::AccountId"),
      databaseInput: {
        description: "My glue database"
      }
    });

    const logGroup = new LogGroup(this, `kda-flink-LogGroup`, {
      retention: RetentionDays.INFINITE,
    });

    const logStream = new LogStream(this, `kda-clink-LogStream`, {
      logGroup: logGroup,
    });

    const serviceExecutionRole = new iam.CfnRole(this, "serviceExecutionRole", {
      assumeRolePolicyDocument: {
            "Version": "2012-10-17",
                "Statement": [{
                "Sid": "",
                "Effect": "Allow",
                "Principal": {
                    "Service": "kinesisanalytics.amazonaws.com"
                },
                "Action": "sts:AssumeRole"
            },
            {
                "Effect": "Allow",
                "Principal": {
                "Service": "iottwinmaker.amazonaws.com"
                },
                "Action": "sts:AssumeRole"
            },
        ]
      },
      path: "/",
      managedPolicyArns: [
        "arn:aws:iam::aws:policy/CloudWatchFullAccess",
        "arn:aws:iam::aws:policy/CloudWatchLogsFullAccess"
      ],
      policies: [
        {
          policyName: "data-access",
          policyDocument: {
            "Version": "2012-10-17",
            "Statement": [
              {
                "Effect": "Allow",
                "Resource": ["*"],
                "Action": [
                  "glue:*",
                  "s3:*",
                  "iotsitewise:*",
                  "sts:*",
                  "kinesisanalyticsv2:*",
                  "kinesisanalytics:*",
                  "iottwinmaker:*",
                  "sagemaker:*",
                ]
              }
            ]
          }
        }
      ]
    });

    const zeppelinRole = iam.Role.fromRoleArn(this, 'zeppelinRole', serviceExecutionRole.attrArn);

    const zeppelinAppName = `ZeppelinGettingStartedApp-${this.stackName}`
    const zeppelinApplication = new kda.CfnApplicationV2(this, zeppelinAppName, {
      applicationName: zeppelinAppName,
      applicationMode: "INTERACTIVE",
      runtimeEnvironment: "ZEPPELIN-FLINK-2_0",
      serviceExecutionRole: zeppelinRole.roleArn,
      applicationConfiguration: {
        flinkApplicationConfiguration: {
          parallelismConfiguration: {
            parallelism: 4,
            configurationType: "CUSTOM"
          },
          monitoringConfiguration: {
            configurationType: "CUSTOM",
            metricsLevel: 'APPLICATION',
            logLevel: "INFO"
          }
        },
        zeppelinApplicationConfiguration: {
          catalogConfiguration: {
            glueDataCatalogConfiguration: {
              databaseArn: cdk.Fn.sub(`arn:aws:glue:\${AWS::Region}:\${AWS::AccountId}:database/\${${glueDatabase.logicalId}}`)
            }
          },
          monitoringConfiguration: {
            logLevel: "INFO"
          },
          customArtifactsConfiguration: [
            {
              artifactType: "DEPENDENCY_JAR",
              mavenReference: {
                groupId: "org.apache.flink",
                artifactId: "flink-sql-connector-kinesis_2.12",
                version: "1.13.2"
              }
            },
            {
              artifactType: "DEPENDENCY_JAR",
              mavenReference: {
                groupId: "software.amazon.msk",
                artifactId: "aws-msk-iam-auth",
                version: "1.1.0"
              }
            },
            {
              artifactType: "DEPENDENCY_JAR",
              mavenReference: {
                groupId: "org.apache.flink",
                artifactId: "flink-connector-kafka_2.12",
                version: "1.13.2"
              }
            },
            {
              artifactType: "DEPENDENCY_JAR",
              s3ContentLocation: {
                bucketArn: 'arn:aws:s3:::aws-iot-twinmaker-flink-downloads-us-east-1',
                fileKey: 'aws-iot-twinmaker-flink-1.13.0.jar'
              }
            }
          ]
        }
      }
    });

    const kdaLogGroup = new kda.CfnApplicationCloudWatchLoggingOptionV2(
        this,
        `${zeppelinAppName}LoggingOptionId`,
        {
          applicationName: zeppelinAppName,
          cloudWatchLoggingOption: {
            logStreamArn: `arn:aws:logs:${region}:${accountId}:log-group:${logGroup.logGroupName}:log-stream:${logStream.logStreamName}`
          }
        }
    );
    kdaLogGroup.node.addDependency(zeppelinApplication)

    new cdk.CfnOutput(this, "ZeppelinAppName", {
      value: zeppelinAppName,
    });
  }