Buat Layanan Terkelola Anda untuk aplikasi Apache Flink Python - Layanan Terkelola untuk Apache Flink
Tentukan file kode Anda

Amazon Managed Service untuk Apache Flink sebelumnya dikenal sebagai Amazon Kinesis Data Analytics untuk Apache Flink.

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

Buat Layanan Terkelola Anda untuk aplikasi Apache Flink Python

Tentukan file kode Anda

Setelah Anda telah membuat paket kode aplikasi, Anda mengunggahnya ke bucket Amazon S3. Anda kemudian membuat aplikasi Anda menggunakan konsol atau CreateApplicationtindakan.

Ketika Anda membuat aplikasi Anda menggunakan CreateApplicationtindakan, Anda menentukan file kode dan arsip dalam file zip Anda menggunakan grup properti aplikasi khusus yang disebutkinesis.analytics.flink.run.options. Anda dapat menentukan file tipe berikut:

  • python: File teks yang berisi metode utama Python.

  • jarfile: JAR File Java yang berisi fungsi yang ditentukan pengguna Java.

  • pyFiles: File sumber daya Python yang berisi sumber daya yang akan digunakan oleh aplikasi.

  • pyArchives: File zip yang berisi file sumber daya untuk aplikasi.

Untuk informasi selengkapnya tentang jenis file kode Apache Flink Python, lihat Antarmuka Baris Perintah di Dokumentasi Apache Flink.

catatan

Layanan Terkelola untuk Apache Flink tidak mendukungpyModule,pyExecutable, atau jenis pyRequirements file. Semua kode, persyaratan, dan dependensi harus dalam file zip Anda. Anda tidak dapat menentukan dependensi yang akan diinstal menggunakan pip.

Cuplikan json contoh berikut menunjukkan cara menentukan lokasi file dalam file zip aplikasi Anda:

"ApplicationConfiguration": {
    "EnvironmentProperties": {
      "PropertyGroups": [
        {
          "PropertyGroupId": "kinesis.analytics.flink.run.options",
          "PropertyMap": {
            "python": "MyApplication/main.py",
            "jarfile": "MyApplication/lib/myJarFile.jar",
            "pyFiles": "MyApplication/lib/myDependentFile.py",
            "pyArchives": "MyApplication/lib/myArchive.zip"
          }
        },