Deskripsi Parameter
Semua kelas parameter diubah menjadi objek kamus yang berisi informasi atribut.
Parameter | Tipe | Deskripsi |
job_desc | Objek JobDescription, str, dict | Deskripsi sederhana dari pekerjaan, deskripsi setiap tugas dari objek pekerjaan, dan dependensi DAG antar tugas |
Deskripsi Respon
Metode create_job mengembalikan objek CreateResponse. Berikut adalah daftar atribut dari objek CreateResponse. Anda dapat menggunakan response.Id untuk mendapatkan ID pekerjaan baru.
Atribut | Tipe | Deskripsi |
Id | str | ID pekerjaan baru |
Contoh:
try:
# Inisialisasi objek Client.
client = ...
# Lihat JobDescription.
job_desc = JobDescription(...)
job = client.create_job(job_desc)
# Cetak ID pekerjaan.
print (job.Id)
except ClientError, e:
print (e)Kelas JobDescription
Deskripsi Parameter
Parameter | Tipe | Deskripsi |
properties | dict, str, Objek JobDescription | Objek yang berisi deskripsi pekerjaan |
Deskripsi Atribut
Atribut | Tipe | Deskripsi |
Nama | str | Nama pekerjaan |
Deskripsi | str | Deskripsi singkat pekerjaan |
Prioritas | int | Nilainya adalah bilangan bulat mulai dari 0 hingga 1.000. Prioritas meningkat seiring dengan nilai. |
Notifikasi | dict | Konfigurasi notifikasi. Anda dapat mengonfigurasi topik atau acara terkait pekerjaan MNS. |
JobFailOnInstanceFail | bool | Menentukan apakah kegagalan suatu instance akan menyebabkan kegagalan pekerjaan terkait. |
AutoRelease | boolean | Menentukan apakah sistem secara otomatis melepaskan (menghapus) pekerjaan setelah pekerjaan berhasil dijalankan. Nilai default: False |
Tipe | str | Saat ini, tugas hanya dapat dijelaskan dalam bentuk grafik asiklik terarah (DAG). |
DAG | dict, objek DAG | Deskripsi DAG |
2. Kelas DAG
Deskripsi Parameter
Parameter | Tipe | Deskripsi |
properties | dict, str, objek DAG | Deskripsi pemetaan tugas dan dependensi antar semua tugas |
Deskripsi Atribut
Atribut | Tipe | Deskripsi |
Tugas | dict | Pemetaan antara semua nama tugas dan deskripsi tugas |
Dependensi | dict | Dependensi antar semua tugas |
Deskripsi Metode
Metode | Deskripsi |
add_task(task_name, task) | Menambahkan tugas |
get_task(task_name) | Mendapatkan informasi tentang tugas, berdasarkan nama tugas |
delete_task(task_name) | Menghapus tugas |
Contoh:
# Lihat kelas TaskDescription.
find_task = TaskDescription(...)
task_dag = DAG()
task_dag.add_task(task_name='Find', task=find_task)
task_dag.Dependencies = {}3. Kelas TaskDescription
Deskripsi Parameter
Parameter | Tipe | Deskripsi |
properties | dict, str, objek TaskDescription | Deskripsi satu tugas |
Deskripsi Atribut
Atribut | Tipe | Deskripsi |
Parameter | dict, objek Parameter | Rincian parameter tugas |
InputMapping | dict | Pemetaan dari direktori OSS ke direktori lokal |
OutputMapping | dict | Pemetaan dari direktori lokal ke direktori OSS |
LogMapping | dict | Pemetaan dari direktori log lokal ke direktori OSS |
Timeout | int | Waktu habis tugas |
InstanceCount | int | Jumlah instance dalam sebuah tugas. Ini adalah bilangan bulat positif. |
MaxRetryCount | int | Jumlah maksimum percobaan ulang. Nilai default: 0 |
ClusterId | str | ID Cluster |
Mounts | dict, objek Mounts | Konfigurasi pemasangan jaringan instance, yang dijelaskan oleh Mounts. Saat ini, pemasangan NAS dan OSS didukung. |
AutoCluster | dict, objek AutoCluster | Anda hanya dapat memilih salah satu dari autoCluster dan clusterId |
Contoh:
echo_task = TaskDescription()
# Buat tugas map.
# Lihat dokumentasi Parameter.
echo_task.Parameters.Command.CommandLine = "echo Batchcompute Service"
echo_task.Parameters.Command.PackagePath = ""
echo_task.Parameters.StdoutRedirectPath = "oss://xxx/xxx/"
echo_task.Parameters.StderrRedirectPath = "oss://xxx/xxx/"
echo_task.Timeout = 86400 # 1 hari
echo_task.InstanceCount = 3
echo_task.MaxRetryCount = 1
# cluster_id adalah kluster yang dibuat dalam layanan batchcompute sebelumnya.
echo_task.ClusterId = cluster_id
# Sekarang Anda dapat menambahkan deskripsi tugas ini ke objek DAG melalui metode add_task.4. Kelas Parameters
Deskripsi Parameter
Parameter | Tipe | Deskripsi |
properties | dict, str, objek Parameters | Deskripsi parameter tugas |
Deskripsi Atribut
Atribut | Tipe | Deskripsi |
Command | dict, objek Command | Parameter baris perintah terkait program pengguna |
InputMappingConfig | dict, objek InputMappingConfig | Konfigurasi layanan pemasangan NFS |
StdoutRedirectPath | str | Direktori OSS tempat keluaran standar dialihkan |
StderrRedirectPath | str | Direktori OSS tempat kesalahan standar dialihkan |
5. Kelas AutoCluster
Deskripsi Parameter
Parameter | Tipe | Deskripsi |
properties | dict, str, objek AutoCluster | Informasi AutoCluster |
Deskripsi Atribut
Atribut | Tipe | Deskripsi |
ECSImageId | str | ID citra ECS. Citra yang disediakan oleh sistem dapat digunakan. |
InstanceType | str | Tipe instance |
ResourceType | str | Tipe sumber daya. Saat ini, jenis OnDemand dan Spot didukung. Nilai default: OnDemand |
UserData | dict | Pemetaan Key-Value, yang ditentukan oleh pengguna dan diperoleh menggunakan metaserver dari instance ECS |
Configs | objek Configs | Konfigurasi kluster. Untuk informasi lebih lanjut, lihat pengenalan ClusterDescription di Bagian 4.13. |
SpotStrategy | str | Strategi spot untuk instance. Ini berlaku hanya ketika ResourceType adalah Spot.Values: SpotWithPriceLimit (Tetapkan harga maksimum untuk instance spot) dan SpotAsPriceGo (Sistem memberikan harga secara otomatis, dan nilai maksimumnya adalah harga Pay-As-You-Go). |
SpotPriceLimit | float | Harga maksimum instance per jam (harga setiap tipe instance, bukan harga per core*jam). Nilainya dapat berisi hingga tiga desimal. Ini berlaku ketika SpotStrategy adalah SpotWithPriceLimit. |
ReserveOnFail | bool | Ketika tugas gagal, VM terkait tidak dilepaskan, dan biaya untuk sumber daya ini masih dikenakan sampai pengguna menghapus pekerjaan. Nilai defaultnya adalah False. Ini hanya digunakan dalam survei. |
6. Kelas Command
Deskripsi Parameter
Parameter | Tipe | Deskripsi |
properties | dict, str, objek InputMappingConfig | Konfigurasi layanan pemasangan NFS |
Deskripsi Atribut
Atribut | Tipe | Deskripsi |
CommandLine | str | Menentukan perintah untuk menjalankan program pengguna |
PackagePath | str | Direktori OSS tempat program pengguna berada |
EnvVars | dict | Variabel lingkungan untuk eksekusi program pengguna |
7. Kelas InputMappingConfig
Deskripsi Parameter
Parameter | Tipe | Deskripsi |
properties | dict, str, objek InputMappingConfig | Konfigurasi layanan pemasangan NFS |
Deskripsi Atribut
Atribut | Tipe | Deskripsi |
Locale | str | Set karakter yang digunakan ketika objek OSS dipasang ke server lokal. Nilai opsional termasuk GBK, GB2312-80, BIG5, ANSI, EUC-JP, EUC-TW, EUC-KR, SHIFT-JIS, dan KSC5601. |
Lock | bool | Menentukan apakah layanan pemasangan NFS mendukung kunci file jaringan. |
8. Kelas Notification
Deskripsi Parameter
Parameter | Tipe | Deskripsi |
properties | dict, str, objek Command | Parameter baris perintah terkait program pengguna |
Deskripsi Atribut
Atribut | Tipe | Deskripsi |
Topic | Objek Topic | Topik pesan |
9. Kelas Topic
Deskripsi Parameter
Parameter | Tipe | Deskripsi |
properties | dict, str, objek Command | Parameter baris perintah terkait program pengguna |
Deskripsi Atribut
Atribut | Tipe | Deskripsi |
Endpoint | str | Titik akhir wilayah MNS. Formatnya adalah http://${your_user_id}.mns.${region}-internal.aliyuncs.com/. Gunakan titik akhir intranet jika memungkinkan. |
Nama | str | Nama topik |
Events | list | Daftar acara. Pastikan Anda memasukkan acara terkait kluster. |
10. Kelas Mounts
Deskripsi Parameter
Parameter | Tipe | Deskripsi |
properties | dict, str, objek Command | Konfigurasi pemasangan disk jaringan saat kluster dibuat |
Deskripsi Atribut
Atribut | Tipe | Deskripsi |
Entries | array | Daftar titik pemasangan disk jaringan, yang dijelaskan oleh MountPoint. |
Locale | str | Bahasa yang digunakan saat penyimpanan OSS atau NAS dipasang |
Lock | bool | Menentukan apakah kunci file didukung saat penyimpanan OSS atau NAS dipasang |
NAS | dict | Konfigurasi NAS |
OSS | dict | Konfigurasi OSS |
11. Kelas MountPoint
Deskripsi Parameter
Parameter | Tipe | Deskripsi |
properties | dict, str, objek Command | Titik pemasangan jaringan |
Deskripsi Atribut
Atribut | Tipe | Deskripsi |
Source | str | Direktori sumber untuk pemasangan disk jaringan. Bisa berupa string yang dimulai dengan “nas://“ atau “oss://“. |
Destination | str | Direktori titik pemasangan lokal disk jaringan |
WriteSupport | bool | Menentukan apakah titik pemasangan dapat ditulis. |
12. Kelas NAS
Deskripsi Parameter
Parameter | Tipe | Deskripsi |
properties | dict, str, objek Command | Konfigurasi NAS |
Deskripsi Atribut
Atribut | Tipe | Deskripsi |
AccessGroup | list | Grup akses NAS tempat instance kluster harus ditambahkan |
FileSystem | list | Sistem file yang akan diakses |
13. Kelas OSS
Deskripsi Parameter
Parameter | Tipe | Deskripsi |
properties | dict, str, objek Command | Konfigurasi OSS |
Deskripsi Atribut
Atribut | Tipe | Deskripsi |
AccessKeyId | str | ID AccessKey yang digunakan untuk pemasangan OSS |
AccessKeySecret | str | AccessKeySecret yang digunakan untuk pemasangan OSS |
SecurityToken | str | Token keamanan yang digunakan untuk pemasangan OSS |
Catatan: Perhatikan hal berikut untuk Mounts: Konfigurasi Mounts tingkat Pekerjaan menimpa konfigurasi Mounts tingkat Kluster. Setelah kluster dimodifikasi, antarmuka RecreateInstance harus dipanggil agar konfigurasi Mounts baru berlaku. Selama pemasangan NAS, direktori sumber harus dimulai dengan “nas:”. Jika tidak, kesalahan akan terjadi.