Tutorial: Kirim acara ke Amazon Kinesis menggunakan skema EventBridge - Amazon EventBridge
PrasyaratLangkah 1: Buat aliran Amazon KinesisLangkah 2: Buat aturanLangkah 3: Uji aturanLangkah 4: Verifikasi bahwa kejadian telah dikirimLangkah 5: Membersihkan sumber daya Anda

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

Tutorial: Kirim acara ke Amazon Kinesis menggunakan skema EventBridge

Anda dapat mengirim peristiwa AWS API panggilan EventBridge ke aliran Amazon Kinesis, membuat aplikasi Kinesis Data Streams, dan memproses data dalam jumlah besar. Dalam tutorial ini, Anda membuat aliran Kinesis, dan kemudian membuat aturan di EventBridge konsol yang mengirimkan peristiwa ke aliran tersebut ketika EC2 instance Amazon berhenti.

Prasyarat

Dalam tutorial ini, Anda akan menggunakan yang berikut:

catatan

Tutorial ini menggunakan AWS acara dan registri aws.events skema bawaan. Anda juga dapat membuat EventBridge aturan berdasarkan skema peristiwa kustom Anda dengan menambahkannya ke registri skema kustom secara manual, atau dengan menggunakan penemuan skema.

Untuk informasi selengkapnya tentang skema, lihat EventBridge Skema Amazon. Untuk informasi selengkapnya tentang membuat aturan menggunakan opsi pola acara lainnya, lihatMembuat aturan yang bereaksi terhadap peristiwa di Amazon EventBridge.

Langkah 1: Buat aliran Amazon Kinesis

Untuk membuat aliran, pada prompt perintah, gunakan create-stream AWS CLI perintah.

aws kinesis create-stream --stream-name test --shard-count 1

Ketika status aliran adalah ACTIVE, aliran sudah siap. Untuk memeriksa status aliran, gunakan perintah describe-stream.

aws kinesis describe-stream --stream-name test

Langkah 2: Buat aturan

Buat aturan untuk mengirim acara ke streaming saat Anda menghentikan EC2 instans Amazon.

Untuk membuat tabel

  1. Buka EventBridge konsol Amazon di https://console.aws.amazon.com/events/.

  2. Di panel navigasi, pilih Aturan.

  3. Pilih Buat aturan.

  4. Masukkan nama dan deskripsi aturan. Misalnya, beri nama aturan TestRule

  5. Untuk bus Acara, pilih default.

  6. Untuk Tipe aturan, pilih Aturan dengan pola peristiwa.

  7. Pilih Selanjutnya.

  8. Untuk sumber Acara, pilih AWS acara atau acara EventBridge mitra.

  9. Untuk metode Creation, pilih Use schema.

  10. Untuk Pola peristiwa, lakukan hal berikut:

    1. Untuk jenis Skema, pilih Pilih skema dari registri Skema.

    2. Untuk registri Schema, pilih aws.events dari daftar drop-down.

    3. Untuk Schema, pilih aws.ec2@ EC2InstanceStateChangeNotification dari daftar drop-down.

      EventBridge menampilkan skema acara di bawah Model.

      EventBridge menampilkan tanda bintang merah di samping properti apa pun yang diperlukan untuk acara tersebut, bukan untuk pola acara.

    4. Dalam Model, atur properti filter peristiwa berikut:

      1. Pilih + Edit di samping properti negara.

        Biarkan hubungan kosong. Untuk Nilai, masukkan running. Pilih Set.

      2. Pilih + Edit di sebelah properti sumber.

        Biarkan hubungan kosong. Untuk Nilai, masukkan aws.ec2. Pilih Set.

      3. Pilih + Edit di samping properti detail-type.

        Biarkan hubungan kosong. Untuk Nilai, masukkan EC2 Instance State-change Notification. Pilih Set.

    5. Untuk melihat pola acara yang telah Anda buat, pilih Hasilkan pola acara di JSON

      EventBridge menampilkan pola acara diJSON:

      {
  "detail": {
    "state": ["running"]
  },
  "detail-type": ["EC2 Instance State-change Notification"],
  "source": ["aws.ec2"]
}

  11. Pilih Selanjutnya.

  12. Untuk Jenis target, pilih Layanan AWS .

  13. Untuk Pilih target, pilih Kinesis stream dari daftar drop-down.

  14. Untuk Stream, pilih aliran Kinesis yang Anda buat di bagian Langkah 1: Buat aliran Amazon Kinesis. Dalam contoh ini, pilihtest.

  15. Untuk peran Eksekusi, pilih Buat peran baru untuk sumber daya khusus ini.

  16. Pilih Selanjutnya.

  17. Pilih Selanjutnya.

  18. Tinjau detail aturan dan pilih Buat aturan.

Langkah 3: Uji aturan

Untuk menguji aturan Anda, hentikan EC2 instans Amazon. Tunggu beberapa menit hingga instans berhenti, lalu periksa CloudWatch metrik Anda untuk memverifikasi bahwa fungsi Anda berjalan.

Untuk menguji aturan Anda dengan pemfilteran stopword instans

  1. Buka EC2 konsol Amazon di https://console.aws.amazon.com/ec2/.

  2. Luncurkan sebuah instans. Untuk informasi selengkapnya, lihat Meluncurkan Instans Anda di Panduan EC2 Pengguna Amazon.

  3. Buka EventBridge konsol Amazon di https://console.aws.amazon.com/events/.

  4. Di panel navigasi, pilih Aturan.

    Pilih nama aturan yang Anda buat dan pilihMetrik untuk aturan.

  5. (Opsional) Setelah selesai, akhiri instans tersebut. Untuk informasi selengkapnya, lihat Menghentikan Instans Anda di Panduan EC2 Pengguna Amazon.

Langkah 4: Verifikasi bahwa kejadian telah dikirim

Anda dapat menggunakan AWS CLI file untuk mendapatkan catatan dari aliran untuk memverifikasi bahwa acara telah dikirim.

Untuk mendapatkan catatan

  1. Untuk mulai membaca dari aliran Kinesis Anda, pada prompt perintah, gunakan perintah get-shard-iterator.

    aws kinesis get-shard-iterator --shard-id shardId-000000000000 --shard-iterator-type TRIM_HORIZON --stream-name test

    Berikut ini adalah contoh output.

    {
    "ShardIterator": "AAAAAAAAAAHSywljv0zEgPX4NyKdZ5wryMzP9yALs8NeKbUjp1IxtZs1Sp+KEd9I6AJ9ZG4lNR1EMi+9Md/nHvtLyxpfhEzYvkTZ4D9DQVz/mBYWRO6OTZRKnW9gd+efGN2aHFdkH1rJl4BL9Wyrk+ghYG22D2T1Da2EyNSH1+LAbK33gQweTJADBdyMwlo5r6PqcP2dzhg="
}

  2. Untuk mendapatkan catatan, gunakan berikut perintah get-records. Gunakan serpihan iterator dari output pada langkah sebelumnya.

    aws kinesis get-records --shard-iterator AAAAAAAAAAHSywljv0zEgPX4NyKdZ5wryMzP9yALs8NeKbUjp1IxtZs1Sp+KEd9I6AJ9ZG4lNR1EMi+9Md/nHvtLyxpfhEzYvkTZ4D9DQVz/mBYWRO6OTZRKnW9gd+efGN2aHFdkH1rJl4BL9Wyrk+ghYG22D2T1Da2EyNSH1+LAbK33gQweTJADBdyMwlo5r6PqcP2dzhg=

    Jika perintah berhasil, perintah akan meminta catatan dari aliran Anda untuk shard yang ditentukan. Anda dapat menerim nol atau beberapa catatan. Catatan apa pun yang dikembalikan mungkin tidak mewakili semua catatan di aliran Anda. Jika Anda tidak menerima data yang Anda harapkan, pangill get-records secara terus menerus.

  3. Catatan dalam Kinesis dikodekan dalam Base64. Gunakan decoder Base64 untuk memecahkan kode data sehingga Anda dapat memverifikasi bahwa itu adalah peristiwa yang dikirim ke aliran dalam bentuk. JSON

Langkah 5: Membersihkan sumber daya Anda

Sekarang Anda dapat menghapus sumber daya yang Anda buat untuk tutorial ini, kecuali Anda ingin mempertahankannya. Dengan menghapus AWS sumber daya yang tidak lagi Anda gunakan, Anda mencegah tagihan yang tidak perlu ke AWS akun Anda.

Untuk menghapus EventBridge aturan

  1. Buka halaman Aturan EventBridge konsol.

  2. Pilih aturan yang Anda buat.

  3. Pilih Hapus.

  4. Pilih Hapus.

Untuk menghapus aliran Kinesis

  1. Buka Halaman data streams dari konsol Kinesis.

  2. Pilih aliran yang Anda buat.

  3. Pilih Tindakan, Hapus.

  4. Masukkan menghapus di fiekd dan pilih Hapus.