Using Python with Kinesis Data Analytics
Apache Flink version 1.15.2 includes support for creating applications using Python version 3.8, using the
PyFlink
Create your Python application code as a text file with a
main
method.Bundle your application code file and any Python or Java dependencies into a zip file, and upload it to an Amazon S3 bucket.
Create your Kinesis Data Analytics application, specifying your Amazon S3 code location, application properties, and application settings.
At a high level, the Python Table API is a wrapper around the Java Table API. For information about the Python Table API, see
Intro to the Python Table API