Mengonfigurasi kelas MWAA lingkungan Amazon - Amazon Managed Workflows for Apache Airflow (MWAA)

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

Mengonfigurasi kelas MWAA lingkungan Amazon

Kelas lingkungan yang Anda pilih untuk MWAA lingkungan Amazon menentukan ukuran AWS Fargate container AWS-managed tempat Celery Executor berjalan, dan database SQL metadata Amazon AWS Aurora Postgre yang dikelola tempat penjadwal Apache Airflow membuat instance tugas. Topik ini menjelaskan setiap kelas MWAA lingkungan Amazon, dan cara memperbarui kelas lingkungan di MWAA konsol Amazon.

Kemampuan lingkungan

Bagian berikut berisi tugas default Apache Airflow bersamaan, Random Access Memory (RAM), dan unit pemrosesan terpusat virtual (vCPUs) untuk setiap kelas lingkungan. Tugas bersamaan yang tercantum mengasumsikan bahwa konkurensi tugas tidak melebihi kapasitas Apache Airflow Worker di lingkungan.

Dalam tabel berikut, DAG kapasitas mengacu pada DAG definisi, bukan eksekusi, dan mengasumsikan bahwa Anda DAGs dinamis dalam satu file Python dan ditulis dengan praktik terbaik Apache Airflow.

Eksekusi tugas bergantung pada berapa banyak yang dijadwalkan secara bersamaan, dan mengasumsikan bahwa DAG jumlah proses yang ditetapkan untuk memulai pada saat yang sama tidak melebihi default max_dagruns_per_loop_to_schedule, serta ukuran dan jumlah pekerja sebagaimana dirinci dalam topik ini.

mw1.micro
  • DAGKapasitas hingga 25

  • 3 tugas bersamaan (secara default)

  • Komponen:

    • Server web: 1 vCPU, 3GB RAM

    • Pekerja dan penjadwal: 1 vCPU, 3GB RAM

    • Basis Data: 2 vCPU, 4GB RAM

      catatan

      mw1.micro tidak mendukung auto-scaling.

mw1.small
  • DAGKapasitas hingga 50

  • 5 tugas bersamaan (secara default)

  • Komponen:

    • Server web: 1 vCPU, masing-masing 2GB RAM

    • Pekerja: 1 vCPU, masing-masing 2GB RAM

    • Penjadwal: 1 vCPU, masing-masing 2GB RAM

    • Basis Data: 2 vCPU, 4GB RAM

mw1.medium
  • DAGKapasitas hingga 250

  • 10 tugas bersamaan (secara default)

  • Komponen:

    • Server web: masing-masing 1 v CPU 2GB RAM

    • Pekerja: 2 v CPU 4GB masing-masing RAM

    • Penjadwal: 2 v CPU 4GB masing-masing RAM

    • Basis Data: 2 v CPU 8GB RAM

mw1.large
  • DAGKapasitas hingga 1000

  • 20 tugas bersamaan (secara default)

  • Komponen:

    • Server web: masing-masing 2 v CPU 4GB RAM

    • Pekerja: 4 v CPU 8GB masing-masing RAM

    • Penjadwal: 4 v CPU 8GB masing-masing RAM

    • Basis Data: 2 v CPU 8GB RAM

mw1.xlarge
  • DAGKapasitas hingga 2000

  • 40 tugas bersamaan (secara default)

  • Komponen:

    • Server web: 4 v CPU 12GB masing-masing RAM

    • Pekerja: 8 v CPU 24GB masing-masing RAM

    • Penjadwal: masing-masing 8 v 24GB CPU RAM

    • Basis Data: 4 v CPU 32GB RAM

mw1.2xlarge
  • DAGKapasitas hingga 4000

  • 80 tugas bersamaan (secara default)

  • Komponen:

    • Server web: masing-masing 8 v CPU 24GB RAM

    • Pekerja: 16 v CPU 48GB masing-masing RAM

    • Penjadwal: masing-masing 16 v 48GB CPU RAM

    • Basis Data: 8 v CPU 64GB RAM

Anda dapat menggunakan celery.worker_autoscale untuk meningkatkan tugas per pekerja. Untuk informasi selengkapnya, lihat Contoh kasus penggunaan kinerja tinggi.

Penjadwal Aliran Udara Apache

Bagian berikut berisi opsi penjadwal Apache Airflow yang tersedia di AmazonMWAA, dan bagaimana jumlah penjadwal memengaruhi jumlah pemicu.

Di Apache Airflow, pemicu mengelola tugas-tugas yang ditunda sampai kondisi tertentu yang ditentukan menggunakan pemicu telah terpenuhi. Di AmazonMWAA, pemicu berjalan bersama penjadwal pada tugas Fargate yang sama. Meningkatkan jumlah penjadwal juga meningkatkan jumlah pemicu yang tersedia, mengoptimalkan cara lingkungan mengelola tugas yang ditangguhkan. Ini memastikan penanganan tugas yang efisien, segera menjadwalkannya untuk dijalankan ketika kondisi terpenuhi.

Apache Airflow v2
  • v2 - Untuk lingkungan yang lebih besar dari mw1.micro, menerima nilai dari ke. 2 5 Default untuk 2 semua ukuran lingkungan kecuali mw1.micro, yang defaultnya. 1