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

Menangani kesalahan dalam alur kerja Step Functions

Semua status, kecuali Pass dan Wait status, dapat mengalami kesalahan runtime. Kesalahan dapat terjadi karena berbagai alasan, termasuk yang berikut:

Ketika status melaporkan kesalahan, Step Functions default gagal seluruh eksekusi mesin status. Step Functions juga memiliki fitur penanganan kesalahan yang lebih canggih. Anda dapat mengatur mesin status Anda untuk menangkap kesalahan, mencoba lagi status gagal, dan menerapkan protokol penanganan kesalahan dengan anggun.

Penangkap Step Functions tersedia untuk status Tugas, Paralel, dan Peta, tetapi tidak untuk kegagalan eksekusi mesin status tingkat atas. Untuk menangani eksekusi yang Anda antisipasi mungkin gagal, penelepon Anda dapat menangani kesalahan, atau Anda mungkin menempatkan eksekusi tersebut di dalam alur kerja anak untuk menangkap kesalahan di dalam alur kerja induk Anda. Atau, Anda dapat memilih untuk mendengarkan TIMED_OUT peristiwa dari alur kerja Standar dengan EventBridge bus dan menjalankan tindakan untuk menangani eksekusi yang gagal.

Nama kesalahan

Step Functions mengidentifikasi kesalahan menggunakan string case-sensitive, yang dikenal sebagai nama kesalahan. Bahasa Status Amazon menentukan satu set string built-in yang menamai kesalahan terkenal, semua dimulai dengan prefiks States..

Status dapat melaporkan kesalahan dengan nama lain. Namun, nama kesalahan tidak dapat dimulai dengan States. awalan.

Pastikan kode produksi Anda dapat menangani pengecualian AWS Lambda layanan (Lambda.ServiceExceptiondanLambda.SdkClientException). Untuk informasi selengkapnya, lihat cara melakukannya Menangani pengecualian layanan Lambda sementara di Praktik terbaik.

Mencoba kembali setelah kesalahan

Task,Parallel, dan Map status dapat memiliki bidang bernamaRetry, yang nilainya harus berupa array objek yang dikenal sebagai retrier. Retrier individu mewakili sejumlah upaya coba lagi, biasanya dengan interval waktu yang meningkat.

Ketika salah satu status ini melaporkan kesalahan dan ada Retry bidang, Step Functions memindai melalui retrier dalam urutan yang tercantum dalam array. Ketika nama kesalahan muncul di nilai ErrorEquals bidang retrier, mesin status melakukan upaya coba lagi seperti yang didefinisikan di Retry bidang.

Jika redriven eksekusi Anda menjalankan ulang statusStatus alur kerja tugas,Status alur kerja paralel, atau Peta Sebaris, yang telah Anda tetapkan percobaan ulang, jumlah upaya coba lagi untuk status ini disetel ulang ke 0 untuk memungkinkan jumlah upaya maksimum. redrive Untuk redriven eksekusi, Anda dapat melacak upaya percobaan ulang individual dari status ini menggunakan konsol. Untuk informasi selengkapnya, lihat Coba lagi perilaku eksekusi redriven di Memulai ulang eksekusi mesin status dengan redrive in Step Functions.

Retrier berisi bidang-bidang berikut:

Coba lagi contoh bidang

Bagian ini mencakup contoh Retry bidang berikut.

Contoh 1 — Coba lagi dengan BackoffRate

Contoh berikut ini Retry membuat dua percobaan lagi dengan percobaan ulang pertama terjadi setelah menunggu selama tiga detik. Berdasarkan yang BackoffRate Anda tentukan, Step Functions meningkatkan interval antara setiap percobaan ulang hingga jumlah maksimum percobaan ulang tercapai. Dalam contoh berikut, upaya coba lagi kedua dimulai setelah menunggu selama tiga detik setelah percobaan ulang pertama.

"Retry": [ {
   "ErrorEquals": [ "States.Timeout" ],
   "IntervalSeconds": 3,
   "MaxAttempts": 2,
   "BackoffRate": 1
} ]

Contoh 2 — Coba lagi dengan MaxDelaySeconds

Contoh berikut membuat tiga upaya coba lagi dan membatasi waktu tunggu yang dihasilkan dari BackoffRate 5 detik. Upaya coba lagi yang pertama dilakukan setelah menunggu selama tiga detik. Upaya coba lagi kedua dan ketiga dilakukan setelah menunggu selama lima detik setelah upaya coba lagi sebelumnya karena batas waktu tunggu maksimum yang ditetapkan oleh MaxDelaySeconds.

"Retry": [ {
    "ErrorEquals": [ "States.Timeout" ],
    "IntervalSeconds": 3,
    "MaxAttempts": 3,
    "BackoffRate":2,
    "MaxDelaySeconds": 5,
    "JitterStrategy": "FULL"
} ]

Tanpa MaxDelaySeconds, upaya coba lagi kedua akan dilakukan enam detik setelah upaya coba lagi yang pertama, dan upaya coba lagi ketiga akan dilakukan 12 detik setelah upaya coba lagi kedua.

Contoh 3 - Coba lagi semua kesalahan kecuali States.Timeout

Nama terpesan States.ALL yang muncul di bidang ErrorEquals adalah wildcard yang cocok dengan setiap nama kesalahan. Ini harus muncul sendirian di array ErrorEquals dan harus muncul dalam retrier terakhir di array Retry. Nama States.TaskFailed juga bertindak wildcard dan cocok dengan kesalahan kecuali untukStates.Timeout.

Contoh Retry bidang berikut mencoba ulang kesalahan apa pun kecualiStates.Timeout.

"Retry": [ {
   "ErrorEquals": [ "States.Timeout" ],
   "MaxAttempts": 0
}, {
   "ErrorEquals": [ "States.ALL" ]
} ]

Contoh 4 - Skenario coba lagi yang kompleks

Parameter retrier A ini berlaku di semua kunjungan ke retrier dalam konteks eksekusi status tunggal.

Pertimbangkan status Task berikut.

"X": {
   "Type": "Task",
   "Resource": "arn:aws:states:region:123456789012:task:X",
   "Next": "Y",
   "Retry": [ {
      "ErrorEquals": [ "ErrorA", "ErrorB" ],
      "IntervalSeconds": 1,
      "BackoffRate": 2.0,
      "MaxAttempts": 2
   }, {
      "ErrorEquals": [ "ErrorC" ],
      "IntervalSeconds": 5
   } ],
   "Catch": [ {
      "ErrorEquals": [ "States.ALL" ],
      "Next": "Z"
   } ]
}

Tugas ini gagal empat kali berturut-turut, mengeluarkan nama kesalahan ini:ErrorA,, ErrorBErrorC, dan. ErrorB Berikut ini terjadi sebagai hasilnya:

Status fallback

Task, Map dan Parallel negara masing-masing dapat memiliki bidang bernamaCatch. Nilai bidang ini harus berupa array obyek, yang dikenal sebagai penangkap.

Penangkap berisi bidang berikut.

Ketika status melaporkan kesalahan dan tidak ada bidang Retry, atau jika mencoba ulang gagal untuk menyelesaikan kesalahan, Step Functions memindai penangkap dalam urutan yang tercantum dalam array. Ketika nama kesalahan muncul dalam nilai bidang ErrorEquals penangkap, mesin status bertransisi ke status bernama dalam bidang Next.

Nama terpesan States.ALL yang muncul di bidang ErrorEquals penangkap adalah wildcard yang cocok dengan nama kesalahan. Ini harus muncul sendirian di array ErrorEquals dan harus muncul di penangkap terakhir di array Catch. Nama States.TaskFailed juga bertindak wildcard dan cocok dengan kesalahan kecuali untuk States.Timeout.

Contoh berikut dari bidang transisi Catch ke status bernama RecoveryState ketika fungsi Lambda meng-output pengecualian Java yang tidak tertangani. Jika tidak, bidang bertransisi ke status EndState.

"Catch": [ {
   "ErrorEquals": [ "java.lang.Exception" ],
   "ResultPath": "$.error-info",
   "Next": "RecoveryState"
}, {
   "ErrorEquals": [ "States.ALL" ],
   "Next": "EndState"
} ]

Output kesalahan

Ketika Step Functions bertransisi ke status yang ditentukan dalam nama penangkapan, objek biasanya berisi bidang Cause. Nilai bidang ini adalah deskripsi yang dapat dibaca manusia dari kesalahan. Objek ini dikenal sebagai output kesalahan.

Pada JSONPath contoh sebelumnya, penangkap pertama berisi ResultPath bidang. Ini bekerja sama dengan ResultPath di tingkat atas status, menghasilkan dua kemungkinan:

Jadi, untuk penangkap pertama dalam contoh, penangkap menambahkan output kesalahan ke input sebagai bidang bernama error-info jika belum ada bidang dengan nama ini di input. Kemudian, penangkap mengirimkan seluruh input keRecoveryState. Untuk penangkap kedua, output kesalahan menimpa input dan penangkap hanya mengirimkan output kesalahan ke. EndState

Untuk JSONPath alur kerja, jika Anda tidak menentukan ResultPath bidang, itu defaultnya$, yang memilih dan menimpa seluruh input.

Ketika status memiliki keduanya Retry dan Catch bidang, Step Functions menggunakan retrier yang sesuai terlebih dahulu. Jika kebijakan coba lagi gagal menyelesaikan kesalahan, Step Functions akan menerapkan transisi penangkap yang cocok.

Muatan penyebab dan integrasi layanan

Sebuah penangkap mengembalikan muatan string sebagai output. Saat bekerja dengan integrasi layanan seperti Amazon Athena AWS CodeBuild atau, Anda mungkin ingin mengonversi string ke Cause JSON. Contoh berikut dari Pass keadaan dengan fungsi intrinsik menunjukkan bagaimana untuk mengkonversi Cause string ke JSON.

"Handle escaped JSON with JSONtoString": {
  "Type": "Pass",
  "Parameters": {
    "Cause.$": "States.StringToJson($.Cause)"
  },
  "Next": "Pass State with Pass Processing"
},

Contoh mesin negara menggunakan Coba Ulang dan Tangkap

Mesin-mesin status yang ditentukan dalam contoh berikut memakai dua fungsi Lambda: salah satu yang selalu gagal dan satu yang menunggu cukup lama untuk mengizinkan batas waktu yang ditentukan dalam mesin status terjadi.

Ini adalah definisi dari fungsi Lambda Node.js yang selalu gagal, mengembalikan pesan. error Dalam contoh mesin status yang mengikuti, fungsi Lambda ini bernama FailFunction. Untuk informasi tentang membuat fungsi Lambda, lihat Langkah 1: Membuat fungsi Lambda bagian.

exports.handler = (event, context, callback) => {
    callback("error");
};

Ini adalah definisi dari fungsi Lambda Node.js yang tidur selama 10 detik. Dalam contoh mesin status yang mengikuti, fungsi Lambda ini bernama sleep10.

exports.handler = (event, context, callback) => {
    setTimeout(function(){
    }, 11000);
};

Menangani kegagalan menggunakan Coba Lagi

Mesin status ini menggunakan Retry untuk mencoba kembali fungsi yang gagal dan output nama kesalahan HandledError. Ini mencoba ulang fungsi ini dua kali dengan backoff eksponensial antara percobaan ulang.

{
   "Comment": "A Hello World example invoking Lambda function",
   "StartAt": "HelloWorld",
   "States": {
      "HelloWorld": {
         "Type": "Task",
         "Resource": "arn:aws:lambda:region:123456789012:function:FailFunction",
         "Retry": [ {
            "ErrorEquals": ["HandledError"],
            "IntervalSeconds": 1,
            "MaxAttempts": 2,
            "BackoffRate": 2.0
         } ],
      "End": true
      }
   }
}

Varian ini menggunakan kode kesalahan yang telah ditentukan States.TaskFailed, yang cocok dengan kesalahan yang fungsi Lambda output.

{
   "Comment": "Hello World example which invokes a AWS Lambda function",
   "StartAt": "HelloWorld",
   "States": {
      "HelloWorld": {
         "Type": "Task",
         "Resource": "arn:aws:lambda:region:123456789012:function:FailFunction",
         "Retry": [ {
            "ErrorEquals": ["States.TaskFailed"],
            "IntervalSeconds": 1,
            "MaxAttempts": 2,
            "BackoffRate": 2.0
         } ],
         "End": true
      }
   }
}

Menangani kegagalan menggunakan Catch

Contoh ini menggunakan bidang Catch. Ketika fungsi Lambda mengeluarkan kesalahan, ia menangkap kesalahan dan mesin status bertransisi ke status. fallback

{
   "Comment": "Hello World example which invokes a AWS Lambda function",
   "StartAt": "HelloWorld",
   "States": {
      "HelloWorld": {
         "Type": "Task",
         "Resource": "arn:aws:lambda:region:123456789012:function:FailFunction",
         "Catch": [ {
            "ErrorEquals": ["HandledError"],
            "Next": "fallback"
         } ],
         "End": true
      },
      "fallback": {
         "Type": "Pass",
         "Result": "Hello, AWS Step Functions!",
         "End": true
      }
   }
}

Varian ini menggunakan kode kesalahan yang telah ditetapkan States.TaskFailed, yang cocok dengan kesalahan yang fungsi Lambda output.

{
   "Comment": "Hello World example which invokes a AWS Lambda function",
   "StartAt": "HelloWorld",
   "States": {
      "HelloWorld": {
         "Type": "Task",
         "Resource": "arn:aws:lambda:region:123456789012:function:FailFunction",
         "Catch": [ {
            "ErrorEquals": ["States.TaskFailed"],
            "Next": "fallback"
         } ],
      "End": true
      },
      "fallback": {
         "Type": "Pass",
         "Result": "Hello, AWS Step Functions!",
         "End": true
      }
   }
}

Menangani batas waktu menggunakan Retry

Mesin status ini menggunakan Retry bidang untuk mencoba kembali Task status yang habis waktu, berdasarkan nilai batas waktu yang ditentukan dalam. TimeoutSeconds Step Functions mencoba ulang pemanggilan fungsi Lambda dalam status Task ini dua kali, dengan backoff eksponensial di antara percobaan ulang.

{
   "Comment": "Hello World example which invokes a AWS Lambda function",
   "StartAt": "HelloWorld",
   "States": {
      "HelloWorld": {
         "Type": "Task",
         "Resource": "arn:aws:lambda:region:123456789012:function:sleep10",
         "TimeoutSeconds": 2,
         "Retry": [ {
            "ErrorEquals": ["States.Timeout"],
            "IntervalSeconds": 1,
            "MaxAttempts": 2,
            "BackoffRate": 2.0
         } ],
         "End": true
      }
   }
}

Menangani batas waktu menggunakan Catch

Contoh ini menggunakan bidang Catch. Ketika batas waktu terjadi, mesin status bertransisi ke status fallback.

{
   "Comment": "Hello World example which invokes a AWS Lambda function",
   "StartAt": "HelloWorld",
   "States": {
      "HelloWorld": {
         "Type": "Task",
         "Resource": "arn:aws:lambda:region:123456789012:function:sleep10",
         "TimeoutSeconds": 2,
         "Catch": [ {
            "ErrorEquals": ["States.Timeout"],
            "Next": "fallback"
         } ],
         "End": true
      },
      "fallback": {
         "Type": "Pass",
         "Result": "Hello, AWS Step Functions!",
         "End": true
      }
   }
}