Memproses data dari antrian dengan status Peta di Step Functions - AWS Step Functions
Langkah 1: Buat mesin negaraLangkah 2: Berlangganan SNS topik AmazonLangkah 3: Tambahkan pesan ke SQS antrian AmazonLangkah 4: Jalankan mesin negara

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

Memproses data dari antrian dengan status Peta di Step Functions

Dalam alur kerja contoh ini, Memetakan status alur kerja status memproses data dari antrian, mengirim pesan ke pelanggan, dan menyimpannya dalam database.

Step Functions menggunakan integrasi yang dioptimalkan untuk menarik pesan dari SQS antrian Amazon. Ketika pesan tersedia, Pilihan status meneruskan array JSON pesan ke Peta status untuk diproses. Untuk setiap pesan, mesin status menulis pesan ke DynamoDB, menghapus pesan dari antrian, dan menerbitkan pesan ke topik Amazon. SNS

Proyek sampel ini mencakup sumber daya berikut:

  • Sesi AWS Step Functions mesin status

  • SQSAntrian Amazon dari mana status Peta membaca dan menghapus pesan secara berulang.

  • Sebuah tabel DynamoDB dimana status Peta menulis pesan secara iteratif.

  • SNSTopik Amazon tempat Step Functions menerbitkan pesan yang dibacanya dari SQS antrian Amazon.

  • Terkait AWS Identity and Access Management (IAM) peran

Langkah 1: Buat mesin negara

  1. Buka Konsol Step Functions dan pilih Buat mesin status.

  2. Temukan dan pilih Proses data secara dinamis dengan status Peta. Pilih Next untuk melanjutkan.

  3. Pilih Jalankan demo untuk membuat read-only dan ready-to-deploy alur kerja, atau pilih Bangun di atasnya untuk membuat definisi mesin status yang dapat diedit yang dapat Anda buat dan kemudian terapkan.

  4. Pilih Gunakan templat untuk melanjutkan pilihan Anda.

Langkah selanjutnya tergantung pada pilihan Anda sebelumnya:

  1. Jalankan demo - Anda dapat meninjau mesin status sebelum membuat proyek hanya-baca dengan sumber daya yang digunakan oleh AWS CloudFormation untuk Anda Akun AWS.

    Anda dapat melihat definisi mesin status, dan ketika Anda siap, pilih Deploy dan jalankan untuk menyebarkan proyek dan membuat sumber daya.

    Penyebaran dapat memakan waktu hingga 10 menit untuk membuat sumber daya dan izin. Anda dapat menggunakan tautan Stack ID untuk memantau kemajuan AWS CloudFormation.

    Setelah penerapan selesai, Anda akan melihat mesin status baru Anda di konsol.

  2. Bangun di atasnya - Anda dapat meninjau dan mengedit definisi alur kerja. Anda mungkin perlu menetapkan nilai untuk placeholder dalam proyek sampel sebelum mencoba untuk menjalankan alur kerja kustom Anda.

catatan

Biaya standar mungkin berlaku untuk layanan yang diterapkan ke akun Anda.

Langkah 2: Berlangganan SNS topik Amazon

Tip

Berlangganan SNS topik Amazon dan tambahkan item ke SQS antrian Amazon sebelum Anda menjalankan mesin status Anda.

  1. Buka SNSkonsol Amazon.

  2. Pilih Topik dan temukan topik yang dibuat oleh proyek sampel.

  3. Pilih Buat langganan, dan untuk Protokol, pilih Email.

  4. Di bawah Endpoint, masukkan alamat email Anda untuk berlangganan topik.

  5. Pilih Buat langganan.

  6. Konfirmasikan langganan di email Anda untuk mengaktifkan langganan.

Langkah 3: Tambahkan pesan ke SQS antrian Amazon

  1. Buka SQSkonsol Amazon.

  2. Pilih antrian yang dibuat oleh proyek sampel.

  3. Pilih Kirim dan terima pesan, masukkan pesan dan pilih Kirim pesan. Ulangi langkah ini untuk menambahkan beberapa pesan ke antrian.

Langkah 4: Jalankan mesin negara

Tip

Antrian di Amazon pada akhirnya SNS konsisten. Anda mungkin perlu menunggu beberapa menit setelah mengirim pesan ke antrian sebelum menjalankan mesin status Anda.

  1. Pada halaman mesin Negara, pilih proyek sampel Anda.

  2. Pada halaman proyek sampel, pilih Mulai eksekusi.

  3. 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. (Opsional) Dalam Input kotak, masukkan nilai masukan sebagaiJSON. Anda dapat melewati langkah ini jika Anda menjalankan demo.

    3. Pilih Mulai Eksekusi.

    Konsol Step Functions akan mengarahkan Anda ke halaman Rincian Eksekusi di mana Anda dapat memilih status dalam tampilan Grafik untuk menjelajahi informasi terkait di Detail langkah panel.

Selamat!

Anda sekarang harus memiliki demo yang sedang berjalan atau definisi mesin status yang dapat Anda sesuaikan.