Menjalankan Pipeline

Sampai sejauh ini, pipeline masih berupa cetak biru murni. Materialisasi adalah proses yang mengubah cetak biru tersebut menjadi aktor yang berjalan dan benar-benar memindahkan data.

Tidak ada yang terjadi sampai Anda menjalankan graf secara eksplisit. Inilah yang membuat Akka Streams dapat disusun dan digunakan kembali.

Materialisasi memerlukan ActorSystem, yang menyediakan thread dan dispatcher untuk menjalankan tahap-tahap stream. Dalam Akka modern, sistem ini juga berperan sebagai materializer implisit.

Satu ActorSystem biasanya melayani seluruh aplikasi dan banyak stream yang berjalan bersamaan.

Cara paling langsung untuk menjalankan Source adalah runWith, yang memasang Sink dan mematerialisasinya dalam satu langkah, lalu mengembalikan nilai materialisasi Sink tersebut.

Di sini, hasilnya adalah Future[Int] yang selesai dengan jumlah total ketika stream berakhir.

Jika Anda sudah membuat RunnableGraph tertutup dengan to atau toMat, panggil run() untuk mematerialisasinya. Nilai yang dikembalikan adalah nilai materialisasi apa pun yang dipertahankan graf.

Hal ini memisahkan pembuatan pipeline dari eksekusi secara rapi.

Source menyediakan pintasan: runForeach, runFold, dan runReduce masing-masing memasang Sink yang sesuai lalu langsung menjalankannya.

Operator tersebut ringkas untuk operasi terminal umum pada Source.

Sink terminal mengembalikan Future yang selesai ketika stream berakhir atau gagal. Daftarkan callback dengan onComplete untuk menanggapi keberhasilan atau kesalahan.

Gunakan dispatcher milik ActorSystem sebagai ExecutionContext implisit untuk callback tersebut.

Pipeline data yang umum membaca dari Sumber, melakukan transformasi dengan Alur, menjalankan I/O asinkron dengan mapAsync, mengelompokkan dalam batch dengan grouped, lalu menulis ke Tujuan.

Setiap tahap berukuran kecil, dan seluruhnya dimaterialisasi dengan satu run.

Untuk meningkatkan ketahanan, bungkus Sumber atau Alur dengan RestartSource.withBackoff agar kegagalan sementara (seperti koneksi yang terputus) memicu mulai ulang otomatis dengan penundaan eksponensial.

Dengan demikian, pipeline penyerapan data yang berjalan lama tetap aktif tanpa pengawasan manual.

KillSwitch memungkinkan kode eksternal menghentikan aliran yang sedang berjalan dengan bersih. Sisipkan KillSwitches.single melalui viaMat, lalu simpan nilai hasil materialisasinya untuk memanggil shutdown() nanti.

Hal ini penting untuk aliran berumur panjang yang harus berhenti saat aplikasi dimatikan.

Saat aplikasi keluar, hentikan ActorSystem untuk membebaskan thread-nya. Rangkai pemanggilan terminate setelah Future penyelesaian aliran agar proses pematian berlangsung tertib.

ActorSystem yang tidak dilepaskan akan membuat JVM tetap aktif dan mempertahankan sumber daya dalam keadaan terbuka.

Mematerialisasi cetak biru yang sama beberapa kali akan membuat aliran independen yang berjalan dan berbagi sumber daya ActorSystem. Cetak biru itu sendiri tetap tidak dapat diubah dan bebas efek samping.

Dengan demikian, Anda dapat mendefinisikan sebuah pipeline sekali, lalu menjalankannya sesuai kebutuhan untuk setiap pekerjaan yang masuk.

Pertimbangkan hal-hal yang diperlukan agar suatu aliran benar-benar memproses elemen.

Menjalankan pipeline berarti mematerialisasi cetak biru dengan sebuah ActorSystem melalui run, runWith, atau operator praktis, yang masing-masing mengembalikan hasil Future.

Anda telah mempelajari pipeline realistis dengan beberapa tahap, mulai ulang otomatis dengan penundaan, pematian dengan anggun melalui KillSwitch, pembersihan sumber daya dengan system.terminate(), serta penggunaan kembali cetak biru yang tidak dapat diubah secara aman dalam beberapa proses independen.