Menerapkan kode sebelum atau sesudah snapshot fungsi Lambda

Anda dapat menggunakan kait runtime untuk mengimplementasikan kode sebelum Lambda membuat snapshot atau setelah Lambda melanjutkan fungsi dari snapshot. Runtime hook tersedia sebagai bagian dari proyek Coordinated Restore at Checkpoint (cRAC) open-source. CRAC sedang dalam pengembangan untuk Open Java Development Kit (OpenJDK). Untuk contoh cara menggunakan cRAC dengan aplikasi referensi, lihat repositori cRAC aktif. GitHub CraC menggunakan tiga elemen utama:

• ResourceAntarmuka dengan dua metode, beforeCheckpoint() danafterRestore(). Gunakan metode ini untuk mengimplementasikan kode yang ingin Anda jalankan sebelum snapshot dan setelah pemulihan.

• Context <R extends Resource>— Untuk menerima pemberitahuan untuk pos pemeriksaan dan pemulihan, a Resource harus terdaftar dengan a. Context

• Core— Layanan koordinasi, yang menyediakan global default Context melalui metode statisCore.getGlobalContext().

Untuk informasi selengkapnya tentang Context danResource, lihat Package org.crac di dokumentasi cRAC.

Gunakan langkah-langkah berikut untuk mengimplementasikan kait runtime dengan paket org.crac. Runtime Lambda berisi implementasi konteks cRAC khusus yang memanggil kait runtime Anda sebelum checkpointing dan setelah memulihkan.

Langkah 1: Perbarui konfigurasi build

Tambahkan org.crac dependensi ke konfigurasi build. Contoh berikut menggunakan Gradle. Untuk contoh untuk sistem build lainnya, lihat dokumentasi Apache Maven.

dependencies {
    compile group: 'com.amazonaws', name: 'aws-lambda-java-core', version: '1.2.1'
    # All other project dependecies go here:
    # ...
    # Then, add the org.crac dependency:
 implementation group: 'org.crac', name: 'crac', version: '1.4.0'
}

Langkah 2: Perbarui penangan Lambda

Handler fungsi Lambda Anda adalah metode dalam kode fungsi Anda yang memproses peristiwa. Saat fungsi Anda diaktifkan, Lambda menjalankan metode handler. Fungsi Anda berjalan sampai handler mengembalikan respons, keluar, atau waktu habis.

Untuk informasi selengkapnya, lihat Tentukan penangan fungsi Lambda di Java.

Contoh handler berikut menunjukkan cara menjalankan kode sebelum checkpointing (beforeCheckpoint()) dan setelah restoring (). afterRestore() Handler ini juga mendaftarkan Resource ke global yang dikelola runtime. Context

catatan

Saat Lambda membuat snapshot, kode inisialisasi Anda dapat berjalan hingga 15 menit. Batas waktu adalah 130 detik atau batas waktu fungsi yang dikonfigurasi (maksimum 900 detik), mana yang lebih tinggi. Kait beforeCheckpoint() runtime Anda dihitung terhadap batas waktu kode inisialisasi. Saat Lambda mengembalikan snapshot, runtime (JVM) harus dimuat dan kait afterRestore() runtime harus selesai dalam batas waktu tunggu (10 detik). Jika tidak, Anda akan mendapatkan SnapStartTimeoutException.

...
  import org.crac.Resource;
  import org.crac.Core;
  ... 
public class CRaCDemo implements RequestStreamHandler, Resource {
    public CRaCDemo() {
      Core.getGlobalContext().register(this);
    }
    public String handleRequest(String name, Context context) throws IOException {
      System.out.println("Handler execution");
      return "Hello " + name;
    }
    @Override
    public void beforeCheckpoint(org.crac.Context<? extends Resource> context)
        throws Exception {
      System.out.println("Before checkpoint");
    }
    @Override
    public void afterRestore(org.crac.Context<? extends Resource> context)
        throws Exception {
      System.out.println("After restore");

Contexthanya mempertahankan a WeakReferenceke objek terdaftar. Jika sampah Resourcedikumpulkan, kait runtime tidak berjalan. Kode Anda harus mempertahankan referensi yang kuat Resource untuk menjamin bahwa hook runtime berjalan.

Berikut adalah dua contoh pola yang harus dihindari:

contoh — Objek tanpa referensi yang kuat

Core.getGlobalContext().register( new MyResource() );

contoh — Objek kelas anonim

Core.getGlobalContext().register( new Resource() {
   
   @Override
   public void afterRestore(Context<? extends Resource> context) throws Exception {
    // ...
   }
   
   @Override
   public void beforeCheckpoint(Context<? extends Resource> context) throws Exception {
    // ...
   }

} );

Sebaliknya, pertahankan referensi yang kuat. Dalam contoh berikut, sumber daya terdaftar bukan sampah yang dikumpulkan dan kait runtime berjalan secara konsisten.

contoh — Objek dengan referensi yang kuat

Resource myResource = new MyResource(); // This reference must be maintained to prevent the registered resource from being garbage collected
Core.getGlobalContext().register( myResource );