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

Status alur kerja tugas

Status Task ("Type": "Task") mewakili satu unit kerja yang dilakukan oleh mesin status. Tugas melakukan pekerjaan dengan menggunakan aktivitas atau AWS Lambda fungsi, dengan mengintegrasikan dengan dukungan lain Layanan AWS, atau dengan memanggil HTTPSAPI, seperti Stripe.

Amazon States Language mewakili tugas dengan menyetel jenis status ke Task dan dengan menyediakan tugas dengan Amazon Resource Name (ARN) aktivitas, fungsi Lambda, atau titik akhir HTTPSAPI.

Memanggil fungsi dengan Argumen JSONata

Definisi status Tugas berikut (JSONata) memanggil fungsi Lambda bernama. priceWatcher

Perhatikan penggunaan JSONata ekspresi untuk menanyakan data masukan yang akan digunakan dalam Argumen dan hasil tugas di bidang penetapan.

"Get Current Price": {
  "Type": "Task",
  "QueryLanguage" : "JSONata",
  "Resource": "arn:aws:states:::lambda:invoke",
  "Next": "Check Price",
  "Arguments": {
    "Payload": {
    "product": "{% $states.context.Execution.Input.product %}"
    },
    "FunctionName": "arn:aws:lambda:<region>:123456789012:function:priceWatcher:$LATEST"
  },
  "Assign": {
    "currentPrice": "{% $states.result.Payload.current_price %}"
  }
}

Memanggil fungsi dengan Parameter JSONPath

Definisi status Tugas berikut (JSONPath) memanggil fungsi Lambda bernama. HelloFunction

"Lambda Invoke": {
  "Type": "Task",
  "Resource": "arn:aws:states:::lambda:invoke",
  "Parameters": {
    "Payload.$": "$",
    "FunctionName": "arn:aws:lambda:us-east-2:123456789012:function:HelloFunction:$LATEST"
  },
  "End": true
}

Tipe tugas

Step Functions mendukung jenis tugas berikut yang dapat Anda tentukan dalam definisi status Tugas:

Anda menentukan jenis tugas dengan menyediakannya ARN di Resource bidang definisi status Tugas. Contoh berikut menunjukkan sintaks Resource bidang. Semua jenis Tugas kecuali salah satu yang memanggil HTTPSAPI, gunakan sintaks berikut. Untuk informasi tentang sintaks HTTP Tugas, lihatPanggilan HTTPS APIs dalam alur kerja Step Functions.

Dalam definisi status Tugas Anda, ganti teks yang dicetak miring dalam sintaks berikut dengan informasi khusus sumber daya. AWS

arn:partition:service:region:account:task_type:name

Daftar berikut menjelaskan komponen individual dalam sintaks ini:

Bagian berikut menyediakan detail selengkapnya tentang setiap tipe tugas.

Aktifitas

Aktivitas menunjukkan pekerja (proses atau thread), diimplementasikan dan di-hosting oleh Anda, yang melakukan tugas tertentu. Aktivitas hanya didukung oleh Alur Kerja standar, tidak Alur Kerja Ekspres.

Aktivitas Resource ARNs menggunakan sintaks berikut.

arn:partition:states:region:account:activity:name

Untuk informasi selengkapnya tentang cara membuat aktivitas dan mengimplementasikan pekerja, lihat Aktivitas.

Fungsi Lambda

Tugas Lambda menjalankan fungsi menggunakan. AWS Lambda Untuk menentukan fungsi Lambda, gunakan fungsi Lambda di lapangan. ARN Resource

Bergantung pada jenis integrasi (Integrasi atau AWS SDKintegrasi yang dioptimalkan) yang Anda gunakan untuk menentukan fungsi Lambda, sintaks bidang fungsi Lambda Anda bervariasi. Resource

Sintaks Resource bidang berikut adalah contoh integrasi yang dioptimalkan dengan fungsi Lambda.

"arn:aws:states:::lambda:invoke"

Sintaks Resource bidang berikut adalah contoh AWS SDK integrasi dengan fungsi Lambda.

"arn:aws:states:::aws-sdk:lambda:invoke"

Definisi Task status berikut menunjukkan contoh integrasi yang dioptimalkan dengan fungsi Lambda bernama. HelloWorld

"LambdaState": {
  "Type": "Task",
  "Resource": "arn:aws:states:::lambda:invoke",
  "OutputPath": "$.Payload",
  "Parameters": {
    "Payload.$": "$",
    "FunctionName": "arn:aws:lambda:us-east-1:function:HelloWorld:$LATEST"
  },
  "Next": "NextState"
}

Setelah fungsi Lambda yang ditentukan di Resource bidang selesai, outputnya dikirim ke status yang diidentifikasi di Next bidang (” “). NextState

A didukung Layanan AWS

Saat Anda mereferensikan sumber daya yang terhubung, Step Functions langsung memanggil API tindakan layanan yang didukung. Tentukan layanan dan tindakan di bidang Resource.

Layanan yang terhubung Resource ARNs menggunakan sintaks berikut.

arn:partition:states:region:account:servicename:APIname

Sebagai contoh:

{
 "StartAt": "BATCH_JOB",
 "States": {
   "BATCH_JOB": {
     "Type": "Task",
     "Resource": "arn:aws:states:::batch:submitJob.sync",
     "Parameters": {  
       "JobDefinition": "preprocessing",
       "JobName": "PreprocessingBatchJob",
       "JobQueue": "SecondaryQueue",
       "Parameters.$": "$.batchjob.parameters",
       "RetryStrategy": {
          "attempts": 5
        }
     },
     "End": true
    }
  }
}

Bidang status tugas

Selain bidang status umum, status Task mempunyai bidang berikut.

Status Task harus mengatur salah satu bidang End ke true jika status mengakhiri eksekusi, atau harus memberikan status di bidang Next yang dijalankan ketika status Task selesai.

Contoh definisi status tugas

Contoh berikut menunjukkan bagaimana Anda dapat menentukan definisi status Tugas berdasarkan kebutuhan Anda.

Interval waktu habis dan heartbeat status tugas

Ini adalah praktik terbaik untuk mengatur nilai waktu habis dan interval heartbeat untuk aktivitas yang berjalan lama. Hal ini dapat dilakukan dengan menentukan nilai batas waktu dan heartbeat, atau dengan mengaturnya secara dinamis.

Contoh notifikasi waktu habis dan heartbeat statis

Saat HelloWorld selesai, status berikutnya (di sini disebut NextState) akan dijalankan.

Jika tugas ini gagal diselesaikan dalam waktu 300 detik, atau tidak mengirim notifikasi heartbeat dalam interval 60 detik, tugas ditandai sebagai failed.

"ActivityState": {
  "Type": "Task",
  "Resource": "arn:aws:states:us-east-1:123456789012:activity:HelloWorld",
  "TimeoutSeconds": 300,
  "HeartbeatSeconds": 60,
  "Next": "NextState"
}

Contoh notifikasi waktu habis dan heartbeat tugas dinamis

Dalam contoh ini, ketika AWS Glue pekerjaan selesai, status berikutnya akan dijalankan.

Jika tugas ini gagal diselesaikan dalam interval yang ditetapkan secara dinamis oleh AWS Glue pekerjaan, tugas ditandai sebagaifailed.

"GlueJobTask": {
  "Type": "Task",
  "Resource": "arn:aws:states:::glue:startJobRun.sync",
  "Parameters": {
    "JobName": "myGlueJob"
  },
  "TimeoutSecondsPath": "$.params.maxTime",
  "Next": "NextState"
}

Contoh bidang Kredensial status tugas

Menentukan peran hard-code IAM ARN

Contoh berikut menentukan IAM peran target yang harus diasumsikan oleh peran eksekusi mesin status untuk mengakses fungsi Lambda lintas akun bernama. Echo Dalam contoh ini, peran target ARN ditentukan sebagai nilai hard-code.

{
  "StartAt": "Cross-account call",
  "States": {
    "Cross-account call": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Credentials": {
        "RoleArn": "arn:aws:iam::111122223333:role/LambdaRole"
      },
      "Parameters": {
        "FunctionName": "arn:aws:lambda:us-east-2:111122223333:function:Echo"
      },
      "End": true
    }
  }
}

Menentukan JSONPath sebagai peran IAM ARN

Contoh berikut menentukan JSONPath nilai, yang akan menyelesaikan IAM peran ARN saat runtime.

{
  "StartAt": "Lambda",
  "States": {
    "Lambda": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Credentials": {
        "RoleArn.$": "$.roleArn"
      },
      ...
    }
  }
}

Menentukan fungsi intrinsik sebagai peran IAM ARN

Contoh berikut menggunakan fungsi States.Formatintrinsik, yang menyelesaikan peran saat runtime. IAM ARN

{
  "StartAt": "Lambda",
  "States": {
    "Lambda": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Credentials": {
        "RoleArn.$": "States.Format('arn:aws:iam::{}:role/ROLENAME', $.accountId)"
      },
      ...
    }
  }
}