Managed Service for Apache Flink code examples for the SDK for Python

Overview

Shows how to use the AWS SDK for Python (Boto3) to work with Amazon Managed Service for Apache Flink.

Managed Service for Apache Flink processes and analyzes streaming data using SQL or Java.

⚠ Important

• Running this code might result in charges to your AWS account. For more details, see AWS Pricing and Free Tier.
• Running the tests might result in charges to your AWS account.
• We recommend that you grant your code least privilege. At most, grant only the minimum permissions required to perform the task. For more information, see Grant least privilege.
• This code is not tested in every AWS Region. For more information, see AWS Regional Services.

Code examples

Prerequisites

For prerequisites, see the README in the python folder.

Install the packages required by these examples by running the following in a virtual environment:

python -m pip install -r requirements.txt

Single actions

Code excerpts that show you how to call individual service functions.

• AddApplicationInput
• AddApplicationOutput
• CreateApplication
• DeleteApplication
• DescribeApplication
• DescribeApplicationSnapshot
• DiscoverInputSchema
• StartApplication
• StopApplication
• UpdateApplication

Data generator

• Generate a stream with a referrer
• Generate a stream with blood pressure anomalies
• Generate a stream with data in columns
• Generate a stream with heart rate anomalies
• Generate a stream with hotspots
• Generate a stream with log entries
• Generate a stream with stagger data
• Generate a stream with stock ticker data
• Generate a stream with two data types
• Generate a stream with web log data

Run the examples

Instructions

The action examples in this section are demonstrated as part of a scenario that reads data from an input stream, uses SQL code to transform the data, and writes it to an output stream. Run the scenario at a command prompt with the following command:

python kinesisanalyticsv2_demo.py

Tests

⚠ Running tests might result in charges to your AWS account.

To find instructions for running these tests, see the README in the python folder.

Additional resources

• Managed Service for Apache Flink Developer Guide
• Managed Service for Apache Flink API Reference
• SDK for Python Managed Service for Apache Flink reference

Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.

SPDX-License-Identifier: Apache-2.0