Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

# Contoh Python untuk Managed Service untuk Apache Flink
<a name="examples-new-python"></a>

Contoh berikut menunjukkan cara membuat aplikasi yang ditulis dengan Python.

**catatan**  
Sebagian besar contoh dirancang untuk dijalankan secara lokal, di mesin pengembangan dan IDE pilihan Anda, dan di Amazon Managed Service untuk Apache Flink. Mereka mendemonstrasikan mekanisme sederhana yang dapat Anda gunakan untuk meneruskan parameter aplikasi, dan cara mengatur ketergantungan dengan benar untuk menjalankan aplikasi di kedua lingkungan tanpa perubahan.

**Ketergantungan proyek**

Sebagian besar PyFlink contoh memerlukan satu atau lebih dependensi sebagai file JAR, misalnya untuk konektor Flink. Dependensi ini kemudian harus dikemas dengan aplikasi saat digunakan di Amazon Managed Service untuk Apache Flink. 

Contoh berikut sudah menyertakan perkakas yang memungkinkan Anda menjalankan aplikasi secara lokal untuk pengembangan dan pengujian, dan untuk mengemas dependensi yang diperlukan dengan benar. Perkakas ini membutuhkan penggunaan Java JDK11 dan Apache Maven. Lihat README yang terkandung dalam setiap contoh untuk instruksi spesifik.

**Contoh**

## Memulai dengan PyFlink
<a name="getting-started-pyflink"></a>

Contoh ini menunjukkan struktur dasar PyFlink aplikasi menggunakan SQL tertanam dalam kode Python. Proyek ini juga menyediakan kerangka untuk PyFlink aplikasi apa pun yang mencakup dependensi JAR seperti konektor. Bagian README memberikan panduan terperinci tentang cara menjalankan aplikasi Python Anda secara lokal untuk pengembangan. Contoh ini juga menunjukkan cara menyertakan dependensi JAR tunggal, konektor Kinesis SQL dalam contoh ini, dalam aplikasi Anda. PyFlink

Contoh kode: [GettingStarted](https://github.com/dzikosc/amazon-managed-service-for-apache-flink-examples/tree/main/python/GettingStarted)

## Tambahkan dependensi Python
<a name="add-python-dependencies"></a>

Contoh ini menunjukkan cara menambahkan dependensi Python ke PyFlink aplikasi Anda dengan cara yang paling umum. Metode ini berfungsi untuk dependensi sederhana, seperti Boto3, atau dependensi kompleks yang berisi pustaka C seperti. PyArrow

Contoh kode: [PythonDependencies](https://github.com/aws-samples/amazon-managed-service-for-apache-flink-examples/tree/main/python/PythonDependencies)

## Gunakan agregasi windowing (API) DataStream
<a name="windowing-aggregations-python"></a>

Contoh ini menunjukkan empat jenis agregasi windowing di SQL tertanam dalam aplikasi Python.

1. Jendela Geser berdasarkan waktu pemrosesan

1. Jendela Geser berdasarkan waktu acara

1. Tumbling Window berdasarkan waktu pemrosesan

1. Jatuh Jendela berdasarkan waktu acara

Contoh kode: [Windowing](https://github.com/aws-samples/amazon-managed-service-for-apache-flink-examples/tree/main/python/Windowing)

## Gunakan wastafel S3
<a name="s3-sink-python"></a>

Contoh ini menunjukkan cara menulis output Anda ke Amazon S3 sebagai file JSON, menggunakan SQL yang disematkan dalam aplikasi Python. Anda harus mengaktifkan pos pemeriksaan untuk wastafel S3 untuk menulis dan memutar file ke Amazon S3. 

Contoh kode: [S3Sink](https://github.com/aws-samples/amazon-managed-service-for-apache-flink-examples/tree/main/python/S3Sink)

## Menggunakan User Defined Function (UDF)
<a name="UDF-python"></a>

Contoh ini menunjukkan bagaimana mendefinisikan User Defined Function, mengimplementasikannya dengan Python, dan menggunakannya dalam kode SQL yang berjalan dalam aplikasi Python. 

Contoh kode: [UDF](https://github.com/aws-samples/amazon-managed-service-for-apache-flink-examples/tree/main/python/UDF)

## Menggunakan wastafel Amazon Data Firehose
<a name="Firehose-sink-python"></a>

Contoh ini menunjukkan cara mengirim data ke Amazon Data Firehose menggunakan SQL. 

Contoh kode: [FirehoseSink](https://github.com/aws-samples/amazon-managed-service-for-apache-flink-examples/tree/main/python/FirehoseSink)