معرفی شرکت ها

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

توضیحات

A CDK Construct Library for Kinesis Analytics Flink applications

ویژگی	مقدار
سیستم عامل	-
نام فایل	aws-cdk.aws-kinesisanalytics-flink-alpha-2.9.0a0
نام	aws-cdk.aws-kinesisanalytics-flink-alpha
نسخه کتابخانه	2.9.0a0
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	Amazon Web Services
ایمیل نویسنده	-
آدرس صفحه اصلی	https://github.com/aws/aws-cdk
آدرس اینترنتی	https://pypi.org/project/aws-cdk.aws-kinesisanalytics-flink-alpha/
مجوز	Apache-2.0

# Kinesis Analytics Flink --- ![cdk-constructs: Experimental](https://img.shields.io/badge/cdk--constructs-experimental-important.svg?style=for-the-badge) > The APIs of higher level constructs in this module are experimental and under active development. > They are subject to non-backward compatible changes or removal in any future version. These are > not subject to the [Semantic Versioning](https://semver.org/) model and breaking changes will be > announced in the release notes. This means that while you may use them, you may need to update > your source code when upgrading to a newer version of this package. ---  This package provides constructs for creating Kinesis Analytics Flink applications. To learn more about using using managed Flink applications, see the [AWS developer guide](https://docs.aws.amazon.com/kinesisanalytics/latest/java/). ## Creating Flink Applications To create a new Flink application, use the `Application` construct: ```python import path as path import aws_cdk.aws_cloudwatch as cloudwatch import aws_cdk as core import aws_cdk.aws_kinesisanalytics_flink_alpha as flink app = core.App() stack = core.Stack(app, "FlinkAppTest") flink_app = flink.Application(stack, "App", code=flink.ApplicationCode.from_asset(path.join(__dirname, "code-asset")), runtime=flink.Runtime.FLINK_1_11 ) cloudwatch.Alarm(stack, "Alarm", metric=flink_app.metric_full_restarts(), evaluation_periods=1, threshold=3 ) app.synth() ``` The `code` property can use `fromAsset` as shown above to reference a local jar file in s3 or `fromBucket` to reference a file in s3. ```python import path as path import aws_cdk.aws_s3_assets as assets import aws_cdk as core import aws_cdk.aws_kinesisanalytics_flink_alpha as flink app = core.App() stack = core.Stack(app, "FlinkAppCodeFromBucketTest") asset = assets.Asset(stack, "CodeAsset", path=path.join(__dirname, "code-asset") ) bucket = asset.bucket file_key = asset.s3_object_key flink.Application(stack, "App", code=flink.ApplicationCode.from_bucket(bucket, file_key), runtime=flink.Runtime.FLINK_1_11 ) app.synth() ``` The `propertyGroups` property provides a way of passing arbitrary runtime properties to your Flink application. You can use the aws-kinesisanalytics-runtime library to [retrieve these properties](https://docs.aws.amazon.com/kinesisanalytics/latest/java/how-properties.html#how-properties-access). ```python # bucket: s3.Bucket flink_app = flink.Application(self, "Application", property_groups={ "FlinkApplicationProperties": { "input_stream_name": "my-input-kinesis-stream", "output_stream_name": "my-output-kinesis-stream" } }, # ... runtime=flink.Runtime.FLINK_1_15, code=flink.ApplicationCode.from_bucket(bucket, "my-app.jar") ) ``` Flink applications also have specific configuration for passing parameters when the Flink job starts. These include parameters for checkpointing, snapshotting, monitoring, and parallelism. ```python # bucket: s3.Bucket flink_app = flink.Application(self, "Application", code=flink.ApplicationCode.from_bucket(bucket, "my-app.jar"), runtime=flink.Runtime.FLINK_1_15, checkpointing_enabled=True, # default is true checkpoint_interval=Duration.seconds(30), # default is 1 minute min_pause_between_checkpoints=Duration.seconds(10), # default is 5 seconds log_level=flink.LogLevel.ERROR, # default is INFO metrics_level=flink.MetricsLevel.PARALLELISM, # default is APPLICATION auto_scaling_enabled=False, # default is true parallelism=32, # default is 1 parallelism_per_kpu=2, # default is 1 snapshots_enabled=False, # default is true log_group=logs.LogGroup(self, "LogGroup") ) ``` Flink applications can optionally be deployed in a VPC: ```python # bucket: s3.Bucket # vpc: ec2.Vpc flink_app = flink.Application(self, "Application", code=flink.ApplicationCode.from_bucket(bucket, "my-app.jar"), runtime=flink.Runtime.FLINK_1_15, vpc=vpc ) ```

نیازمندی

مقدار	نام
==2.78.0	aws-cdk-lib
<11.0.0,>=10.0.0	constructs
<2.0.0,>=1.78.1	jsii
>=0.0.3	publication
~=2.13.3	typeguard

زبان مورد نیاز

مقدار	نام
~=3.7	Python

نحوه نصب

نصب پکیج whl aws-cdk.aws-kinesisanalytics-flink-alpha-2.9.0a0:

pip install aws-cdk.aws-kinesisanalytics-flink-alpha-2.9.0a0.whl

نصب پکیج tar.gz aws-cdk.aws-kinesisanalytics-flink-alpha-2.9.0a0:

pip install aws-cdk.aws-kinesisanalytics-flink-alpha-2.9.0a0.tar.gz