View a markdown version of this page

Jalankan aliran Amazon Bedrock secara asinkron dengan eksekusi aliran - Amazon Bedrock
Izin yang diperlukan untuk menjalankan eksekusi aliranMembuat dan mengelola eksekusi alurStatus eksekusi aliranPraktik terbaik untuk eksekusi aliran

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

Jalankan aliran Amazon Bedrock secara asinkron dengan eksekusi aliran

Dengan eksekusi aliran, Anda dapat menjalankan aliran Amazon Bedrock secara asinkron. Ini memungkinkan alur Anda berjalan untuk durasi yang lebih lama dan juga menghasilkan kontrol sehingga aplikasi Anda dapat melakukan tugas lain.

Saat Anda menjalankan aliran dengan menggunakan konsol Amazon Bedrock atau dengan InvokeFlow operasi, aliran berjalan hingga selesai atau habis waktu pada satu jam (mana yang lebih dulu). Saat Anda menjalankan eksekusi aliran, alur Anda dapat berjalan lebih lama: Node individual dapat berjalan hingga lima menit, dan seluruh aliran Anda dapat berjalan hingga 24 jam.

catatan

Eksekusi aliran sedang dalam rilis pratinjau untuk Amazon Bedrock dan dapat berubah.

Izin yang diperlukan untuk menjalankan eksekusi aliran

Membuat dan mengelola eksekusi alur

Anda dapat membuat eksekusi aliran di konsol atau dengan menggunakan StartFlowExecution operasi.

Console

  1. Buat alur dengan mengikuti instruksi diBuat dan rancang alur di Amazon Bedrock.

  2. Buat alias untuk alur dengan mengikuti instruksi diBuat alias aliran di Amazon Bedrock.

  3. Jika Anda belum menggunakan pembuat Flow, lakukan hal berikut:

    1. Masuk ke Konsol Manajemen AWS dengan identitas IAM yang memiliki izin untuk menggunakan konsol Amazon Bedrock. Kemudian, buka konsol Amazon Bedrock di https://console.aws.amazon.com/bedrock.

    2. Pilih Amazon Bedrock Flows dari panel navigasi kiri, lalu pilih alur Anda.

  4. Pilih tab Ek sek usi, lalu pilih Buat eksekusi.

  5. Dalam dialog Buat eksekusi, masukkan yang berikut ini

    1. Untuk Nama, masukkan nama untuk eksekusi alur.

    2. Untuk Pilih alias, pilih alias alur yang ingin Anda gunakan.

    3. Untuk input Prompt, masukkan prompt yang ingin Anda gunakan untuk memulai alur.

    4. Pilih Buat untuk membuat eksekusi aliran dan mulai menjalankannya.

  6. Pada halaman detail alur, pilih tab Eksekusi dan catat status eksekusi alur di Status eksekusi.

  7. (Opsional) Pilih eksekusi untuk membuka alur dan melihat ringkasan eksekusi.

    Dalam output eksekusi, Anda melihat output dari aliran.

  8. (Opsional) Untuk menghentikan eksekusi aliran, pilih eksekusi dan pilih Stop.

API
Mulai eksekusi aliran

Untuk menjalankan eksekusi alur, kirim StartFlowExecution permintaan dengan titik akhir runtime Ag ents for Amazon Bedrock. Dalam permintaan, tentukan ID alur dan ID alias aliran dari alur yang ingin Anda jalankan. Anda juga dapat menentukan yang berikut:

  • input — Sebuah array yang berisi simpul input yang Anda inginkan untuk memulai alirannya. Anda menentukan input untuk dikirim ke simpul input aliran prompt di content lapangan.

  • name — Nama untuk eksekusi aliran.

{
    "inputs": [{
        "nodeName": "FlowInputNode",
        "nodeOutputName": "document",
        "content": {
            "document": "Test"
        }
    }],
    "name": "MyExecution"
}

Responsnya adalah Amazon Resource Name (ARN) dari eksekusi aliran. Anda dapat menggunakan executionArn to poll untuk status arus saat ini, seperti saat eksekusi aliran selesai atau node kondisi mengevaluasi kondisinya.

{
      "executionArn": "arn:aws:bedrock:us-west-2:111122223333:flow/FLOWID/alias/TSTALIASID/execution/MyExecution"
}
Melacak kemajuan eksekusi aliran

Gunakan GetFlowExecution operasi untuk mendapatkan status arus saat ini yang Anda identifikasi dengan eksekusi ARN. Status aliran adalahRunning,,Succeeded, FailedTimedOut, atauAborted.

{
      "endedAt": null,
      "errors": null,
      "executionArn": "arn:aws:bedrock:us-west-2:111122223333:flow/FLOWID/alias/TSTALIASID/execution/MyExecution",
      "flowAliasIdentifier": "TSTALIASID",
      "flowIdentifier": "FLOWID",
      "flowVersion": "DRAFT",
      "startedAt": "2025-03-20T23:32:28.899221162Z",
      "status": "Running"
}

Kesalahan (seperti node Lambda yang timeout) dikembalikan dalam errors array seperti contoh berikut:

"errors": [{
    "nodeName": "LambdaNode1",
    "errorType": "ExecutionTimedOut",
    "message": "Call to lambda function timed out"
}],
Dapatkan hasil eksekusi aliran

Amazon Bedrock menulis output aliran ke node keluaran aliran. Anda bisa mendapatkan output setelah aliran selesai atau saat aliran berjalan (tergantung pada kasus penggunaan Anda).

Jika Anda ingin alur selesai terlebih dahulu, lakukan panggilan ke GetFlowExecution dan pastikan bahwa nilai status bidang dalam respons adalahSucceeded.

Untuk mendapatkan daftar peristiwa keluaran dari eksekusi aliran, buat panggilan ke ListFlowExecutionEvents. Dalam tanggapan, periksa flowOutputEvent objek di dalamnyaflowExecutionEvents. Misalnya, Anda bisa mendapatkan output aliran di content bidang:

{
      "flowOutputEvent": {
        "content": {
          "document": "The model response."
        },
        "nodeName": "FlowOutputNode"
      }
}

Anda dapat membatasi output dari hanya ListFlowExecutions simpul input dan output dengan mengatur parameter eventType kueri keFlow.

Melihat peristiwa

Untuk membantu men-debug eksekusi alur Anda, Anda dapat menggunakan ListFlowExecutionEvents operasi untuk melihat peristiwa yang dihasilkan node saat aliran berjalan. Atur eventType parameter kueri Node untuk melihat input dan output dari semua node (termasuk node perantara) dalam respons yang mirip dengan contoh berikut:

{
    "flowExecutionEvents": [{
            "nodeOutputEvent": {
                "fields": [{
                    "content": {
                        "document": "History book"
                    },
                    "name": "document"
                }],
                "nodeName": "FlowInputNode",
                "timestamp": "2025-05-05T18:38:56.637867516Z"
            }
        },
        {
            "nodeInputEvent": {
                "fields": [{
                    "content": {
                        "document": "History book"
                    },
                    "name": "book"
                }],
                "nodeName": "Prompt_1",
                "timestamp": "2025-05-05T18:38:57.434600163Z"
            }
        },
        {
            "nodeOutputEvent": {
                "fields": [{
                    "content": {
                        "document": "Here's a summary of the history book."
                    },
                    "name": "modelCompletion"
                }],
                "nodeName": "Prompt_1",
                "timestamp": "2025-05-05T18:39:06.034157077Z"
            }
        },
        {
            "nodeInputEvent": {
                "fields": [{
                    "content": {
                        "document": "Here's a summary of the history book."
                    },
                    "name": "document"
                }],
                "nodeName": "FlowOutputNode",
                "timestamp": "2025-05-05T18:39:06.453128251Z"
            }
        }
    ]
}
Dapatkan snapshot eksekusi alur Anda

Amazon Bedrock secara otomatis mengambil snapshot dari definisi aliran dan metadata saat eksekusi aliran dimulai. Ini sangat membantu karena aliran dapat diperbarui saat berjalan secara asinkron. Untuk mengambil snapshot ini, panggil GetExecutionFlowSnapshot operasi. Responsnya mencakup bidang aliran berikut:

{
      "customerEncryptionKeyArn": null,
      "definition": "{flow-definition}",
      "executionRoleArn": "arn:aws:iam::111122223333:role/name",
      "flowAliasIdentifier": "TSTALIASID",
      "flowIdentifier": "FLOWID",
      "flowVersion": "DRAFT"
}
Daftar eksekusi alur Anda

Anda bisa mendapatkan daftar eksekusi alur Anda dengan memanggil ListFlowExecutions operasi. Respons menyertakan flowExecutionSummaries array dengan informasi tentang setiap eksekusi alur Anda dalam arus Wilayah AWS untuk aliran atau alias aliran. Setiap elemen mencakup informasi seperti eksekusi ARN, waktu mulai, dan status arus saat ini.

{
    "flowExecutionSummaries": [{
        "createdAt": "2025-03-11T23:21:02.875598966Z",
        "endedAt": null,
        "executionArn": "arn:aws:bedrock:us-west-2:111122223333:flow/FLOWID/alias/TSTALIASID/execution/MyExecution",
        "flowAliasIdentifier": "TSTALIASID",
        "flowIdentifier": "FLOWID",
        "flowVersion": "DRAFT",
        "status": "Running"
    }]
}
Menghentikan eksekusi alur yang sedang berjalan

Jika Anda perlu menghentikan eksekusi aliran yang sedang berjalan, panggil StopFlowExecution operasi dan berikan ID aliran, ID alias aliran, dan ID eksekusi aliran untuk eksekusi yang ingin Anda hentikan.

Status eksekusi aliran

Eksekusi aliran dapat memiliki salah satu status berikut:

  • Menjalankan — Eksekusi alur sedang berlangsung.

  • Berhasil — Eksekusi alur berhasil diselesaikan.

  • Gag al — Eksekusi alur gagal karena kesalahan.

  • TimedOut— Eksekusi aliran melebihi runtime maksimum 24 jam.

  • Dibatalkan — Eksekusi aliran dihentikan secara manual menggunakan StopFlowExecution operasi.

Eksekusi alur yang tidak lagi berjalan akan dihapus secara otomatis setelah 90 hari.

Praktik terbaik untuk eksekusi aliran

Pertimbangkan hal berikut saat menggunakan eksekusi aliran:

  • Jajak pendapat secara teratur status eksekusi aliran Anda menggunakan GetFlowExecution sampai aliran Anda mencapai status terminal (yang merupakan apa pun selainRunning).

  • Ketika eksekusi aliran Anda mencapai status terminal, gunakan ListFlowExecutionEvents untuk mendapatkan hasil aliran Anda. Misalnya, Anda dapat menggunakan hasil ini untuk membangun beberapa logika di sekitar aliran Anda.

  • Dapatkan snapshot eksekusi alur Anda menggunakan GetExecutionFlowSnapshot untuk membantu debugging jika masalah muncul dengan eksekusi.