Membuat Layanan Terkelola Anda untuk aplikasi Apache Flink Python

Menentukan 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: File JAR Java yang berisi fungsi yang ditetapkan 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"
          }
        },