aws-cdk.aws-kinesisanalytics-flink-alpha

What it is and what it does

This package is an AWS CDK construct library that abstracts the creation and configuration of managed Apache Flink applications running on AWS Kinesis Analytics. It lets you define Flink jobs as infrastructure-as-code in Python, specifying runtime version, code location (from S3 or local assets), and operational parameters like checkpointing intervals, parallelism, and VPC placement.

It wraps the underlying Kinesis Analytics Flink service, exposing configuration for job startup parameters, property groups (runtime configuration passed to your Flink code), monitoring via CloudWatch metrics, and auto-scaling behavior. The package is marked experimental, meaning its APIs may change in future releases without backward compatibility guarantees.

Use it for:

• Define a Flink streaming job as part of a larger CDK stack, specifying code location and runtime in one construct.
• Configure checkpointing and parallelism for a Flink application without writing CloudFormation templates directly.
• Deploy multiple Flink applications with different runtime versions (1.15, 1.18, 1.19, 1.20) in the same stack.
• Pass runtime properties to a Flink application via property groups, retrieved by your Flink code at job startup.
• Set up CloudWatch alarms on Flink metrics like full restarts as part of your infrastructure definition.

Worth the install?

AI-flagged interpretation of the facts on this page — verify before relying

Provides AWS CDK constructs for defining and deploying managed Apache Flink applications on Kinesis Analytics, with support for multiple Flink runtime versions and configuration of checkpointing, parallelism, and VPC deployment.

Yes, if you are already using AWS CDK to manage infrastructure and need to deploy Kinesis Analytics Flink applications. The low install friction and active maintenance make it straightforward to adopt. However, accept that the experimental status means you may need to update code when upgrading versions—plan for this in your release cycle.

Install

aws-cdk-aws-kinesisanalytics-flink-alpha on PyPI

pip install aws-cdk-aws-kinesisanalytics-flink-alpha

uv add aws-cdk-aws-kinesisanalytics-flink-alpha

poetry add aws-cdk-aws-kinesisanalytics-flink-alpha

Installing aws-cdk.aws-kinesisanalytics-flink-alpha

Before you install

Active maintenance with a recent release; low install friction from pure-Python packaging. Marked as experimental and subject to breaking changes across versions, so upgrades may require code updates.

License in practice

Licensed under Apache-2.0 (permissive), allowing commercial use and modification with standard attribution requirements.

Quickstart

pip install aws-cdk.aws-kinesisanalytics-flink-alpha

import aws_cdk as core
import aws_cdk.aws_kinesisanalytics_flink_alpha as flink

stack = core.Stack(app, "FlinkStack")
app = flink.Application(stack, "MyApp",
    code=flink.ApplicationCode.from_bucket(bucket, "my-app.jar"),
    runtime=flink.Runtime.FLINK_1_20
)

Requires aws-cdk-lib and its transitive dependencies; Python 3.10 or later; a Flink application JAR file in S3 or as a local asset.

Verify before relying

• Whether breaking changes between alpha versions occur frequently enough to affect production deployments.
• Performance characteristics and scaling limits for large Flink applications deployed via these constructs.
• Whether all Flink runtime versions listed (1.15, 1.18, 1.19, 1.20) remain actively supported by AWS.

Package facts

Evidence: aws_cdk_aws_kinesisanalytics_flink_alpha-2.265.0a0-py3-none-any.whl

Tags

More Application Frameworks packages