Membuat mesin status Aktivitas menggunakan Step Functions

Di konsol Step Functions, di panel navigasi yang ada di sebelah kiri, pilih Aktivitas.

Pilih Buat aktivasi.

Masukkan Nama untuk aktivitas, misalnyaget-greeting, lalu pilih Buat aktivitas.

Saat tugas aktivitas Anda dibuat, catat tugasnyaARN, seperti yang ditunjukkan pada contoh berikut.

arn:aws:states:us-east-1:123456789012:activity:get-greeting

Di dalam konsol Step Functions, di panel navigasi yang ada di sebelah kiri, pilih Mesin status.

Pada halaman State Machines, pilih Create state machine.

Dalam kotak dialog Pilih templat, pilih Kosong.

Pilih Pilih untuk membuka Workflow Studio diMode desain.

Untuk tutorial ini, Anda akan menulis definisi Amazon States Language (ASL) dari mesin status Anda di editor kode. Untuk melakukan ini, pilih Kode.

Hapus kode boilerplate yang ada dan tempel kode berikut. Ingatlah untuk mengganti contoh ARN dalam kode ini dengan tugas aktivitas yang Anda buat sebelumnya di Resource bidang. ARN

{
  "Comment": "An example using a Task state.",
  "StartAt": "getGreeting",
  "Version": "1.0",
  "TimeoutSeconds": 300,
  "States":
  {
    "getGreeting": {
      "Type": "Task",
      "Resource": "arn:aws:states:us-east-1:123456789012:activity:get-greeting",
      "End": true
    }
  }
}

Ini adalah deskripsi mesin negara Anda menggunakan Amazon States Language (ASL). ARN menentukan satu status Task bernama getGreeting. Untuk informasi selengkapnya, lihat Struktur Mesin Status.

PadaVisualisasi grafik, pastikan grafik alur kerja untuk ASL definisi yang Anda tambahkan terlihat mirip dengan grafik berikut.

Tentukan nama untuk mesin negara Anda. Untuk melakukan ini, pilih ikon edit di sebelah nama mesin status default MyStateMachine. Kemudian, dalam konfigurasi mesin Negara, tentukan nama di kotak Nama mesin Negara.

Untuk tutorial ini, masukkan nama ActivityStateMachine.

(Opsional) Dalam konfigurasi mesin State, tentukan pengaturan alur kerja lainnya, seperti jenis mesin status dan peran pelaksanaannya.

Untuk tutorial ini, simpan semua pilihan default di pengaturan mesin State.

Jika sebelumnya Anda telah membuat IAM peran dengan izin yang benar untuk mesin status dan ingin menggunakannya, di Izin, pilih Pilih peran yang ada, lalu pilih peran dari daftar. Atau pilih Masukkan peran ARN dan kemudian berikan IAM peran ARN untuk itu.

Dalam kotak dialog Konfirmasi pembuatan peran, pilih Konfirmasi untuk melanjutkan.

Anda juga dapat memilih Lihat pengaturan peran untuk kembali ke konfigurasi mesin Status.

Buat file bernama GreeterActivities.java.

Tambahkan kode berikut ke file tersebut.

import com.amazonaws.ClientConfiguration;
import com.amazonaws.auth.EnvironmentVariableCredentialsProvider;
import com.amazonaws.regions.Regions;
import com.amazonaws.services.stepfunctions.AWSStepFunctions;
import com.amazonaws.services.stepfunctions.AWSStepFunctionsClientBuilder;
import com.amazonaws.services.stepfunctions.model.GetActivityTaskRequest;
import com.amazonaws.services.stepfunctions.model.GetActivityTaskResult;
import com.amazonaws.services.stepfunctions.model.SendTaskFailureRequest;
import com.amazonaws.services.stepfunctions.model.SendTaskSuccessRequest;
import com.amazonaws.util.json.Jackson;
import com.fasterxml.jackson.databind.JsonNode;
import java.util.concurrent.TimeUnit;


public class GreeterActivities {

    public String getGreeting(String who) throws Exception {
        return "{\"Hello\": \"" + who + "\"}";
    }

    public static void main(final String[] args) throws Exception {
        GreeterActivities greeterActivities = new GreeterActivities();
        ClientConfiguration clientConfiguration = new ClientConfiguration();
        clientConfiguration.setSocketTimeout((int)TimeUnit.SECONDS.toMillis(70));

        AWSStepFunctions client = AWSStepFunctionsClientBuilder.standard()
                .withRegion(Regions.US_EAST_1)
                .withCredentials(new EnvironmentVariableCredentialsProvider())
                .withClientConfiguration(clientConfiguration)
                .build();

        while (true) {
            GetActivityTaskResult getActivityTaskResult =
                    client.getActivityTask(
                            new GetActivityTaskRequest().withActivityArn(ACTIVITY_ARN));

            if (getActivityTaskResult.getTaskToken() != null) {
                try {
                    JsonNode json = Jackson.jsonNodeOf(getActivityTaskResult.getInput());
                    String greetingResult =
                            greeterActivities.getGreeting(json.get("who").textValue());
                    client.sendTaskSuccess(
                            new SendTaskSuccessRequest().withOutput(
                                    greetingResult).withTaskToken(getActivityTaskResult.getTaskToken()));
                } catch (Exception e) {
                    client.sendTaskFailure(new SendTaskFailureRequest().withTaskToken(
                            getActivityTaskResult.getTaskToken()));
                }
            } else {
                Thread.sleep(1000);
            }
        }
    }
}

Dalam daftar parameter GetActivityTaskRequest().withActivityArn() konstruktor, ganti ACTIVITY_ARN nilai dengan tugas ARN aktivitas yang Anda buat sebelumnya.

Pada ActivityStateMachinehalaman, pilih Mulai eksekusi.

Kotak dialog Mulai eksekusi ditampilkan.

Dalam kotak dialog Mulai eksekusi, lakukan hal berikut:

1. (Opsional) Masukkan nama eksekusi khusus untuk mengganti default yang dihasilkan.

   Non- ASCII nama dan logging

   Step Functions menerima nama untuk mesin negara, eksekusi, aktivitas, dan label yang berisi ASCII non-karakter. Karena karakter seperti itu tidak akan berfungsi dengan Amazon CloudWatch, kami sarankan hanya menggunakan ASCII karakter sehingga Anda dapat melacak metrik. CloudWatch

2. Dalam kotak Input, masukkan JSON input berikut untuk menjalankan alur kerja Anda.

   {
     "who": "AWS Step Functions"
   }

3. Pilih Mulai Eksekusi.

4. Konsol Step Functions mengarahkan Anda ke halaman yang berjudul dengan ID eksekusi Anda. Halaman ini dikenal sebagai halaman Detail Eksekusi. Di halaman ini, Anda dapat meninjau hasil eksekusi saat eksekusi berlangsung atau setelah selesai.

   Untuk meninjau hasil eksekusi, pilih status individual pada tampilan Grafik, lalu pilih tab individual di Detail langkah panel untuk melihat detail setiap status termasuk input, output, dan definisi masing-masing. Untuk detail tentang informasi eksekusi yang dapat Anda lihat di halaman Rincian Eksekusi, lihatIkhtisar detail eksekusi.

Pada baris perintah, navigasikan ke direktori tempat Anda membuatGreeterActivities.java.

Untuk menggunakan AWS SDK, tambahkan path lengkap third-party direktori lib dan ke dependensi file build Anda dan ke Java Anda. CLASSPATH Untuk informasi selengkapnya, lihat Mengunduh dan Mengekstrak SDK di AWS SDK for Java Panduan Pengembang.

Kompilasikan file.

$ javac GreeterActivities.java

Jalankan file.

$ java GreeterActivities

Pada konsol Step Functions, navigasikan ke halaman Execution Details.

Ketika eksekusi selesai, periksa hasil eksekusi Anda.

Hentikan pekerja.