AWS Data Pipeline tidak lagi tersedia untuk pelanggan baru. Pelanggan yang sudah ada dari AWS Data Pipeline dapat terus menggunakan layanan seperti biasa. Pelajari selengkapnya
Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Mengakhiri
Tindakan untuk memicu pembatalan aktivitas, sumber daya, atau node data yang tertunda atau belum selesai. AWS Data Pipeline mencoba untuk menempatkan aktivitas, sumber daya, atau node data ke dalam CANCELLED status jika tidak dimulai dengan lateAfterTimeout
nilai.
Anda tidak dapat mengakhiri tindakan yang menyertakan sumber daya onSuccess
, OnFail
, atau onLateAction
.
Contoh
Berikut adalah contoh dari jenis objek ini. Dalam contoh ini, bidang onLateAction
dari MyActivity
berisi referensi untuk tindakan DefaultAction1
. Saat Anda memberikan tindakan untuk onLateAction
, Anda juga harus menyediakan nilai lateAfterTimeout
untuk menunjukkan periode waktu sejak awal dijadwalkan dari alur setelah aktivitas dianggap terlambat.
{ "name" : "MyActivity", "id" : "DefaultActivity1", "schedule" : { "ref" : "MySchedule" }, "runsOn" : { "ref" : "MyEmrCluster" }, "lateAfterTimeout" : "1 Hours", "type" : "EmrActivity", "onLateAction" : { "ref" : "DefaultAction1" }, "step" : [ "s3://myBucket/myPath/myStep.jar,firstArg,secondArg", "s3://myBucket/myPath/myOtherStep.jar,anotherArg" ] }, { "name" : "TerminateTasks", "id" : "DefaultAction1", "type" : "Terminate" }
Sintaks
Bidang Opsional | Deskripsi | Jenis Slot |
---|---|---|
induk | Induk dari objek saat ini dari mana slot diwariskan. | Objek Referensi, misalnya “induk”: {"ref”:” myBaseObject Id "} |
Bidang Runtime | Deskripsi | Jenis Slot |
---|---|---|
simpul | Simpul untuk tempat tindakan ini sedang dilakukan. | Objek Referensi, misalnya “node”: {"ref”:” myRunnableObject Id "} |
@version | Versi alur tempat objek dibuat. | String |
Bidang Sistem | Deskripsi | Jenis Slot |
---|---|---|
@error | Galat menggambarkan objek yang tidak terbentuk. | String |
@pipelineId | ID dari alur tempat objek ini berada. | String |
@sphere | Lingkup objek menunjukkan tempatnya dalam siklus hidup: Component Objects memunculkan Instance Objects, yang mengeksekusi Attempt Objects. | String |