View a markdown version of this page

Membuat EventBridge pipa Amazon - Amazon EventBridge
Menentukan sumberMengkonfigurasi penyaringanMendefinisikan pengayaanMengonfigurasi targetMengkonfigurasi pengaturan pipaMemvalidasi parameter konfigurasi

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

Membuat EventBridge pipa Amazon

EventBridge Pipes memungkinkan Anda membuat integrasi point-to-point antara sumber dan target, termasuk transformasi dan pengayaan peristiwa tingkat lanjut.

Untuk membuat EventBridge pipa, Anda melakukan langkah-langkah berikut:

  1. Menentukan sumber

  2. Mengkonfigurasi pemfilteran acara (opsional)

  3. Mendefinisikan pengayaan acara (opsional)

  4. Mengonfigurasi target

  5. Mengonfigurasi pengaturan alur

Untuk menyiapkan pipa sampel dengan cepat, lihatMemulai: Buat EventBridge pipa Amazon. Topik ini CloudFormation digunakan untuk menyebarkan pipa dan sumber daya terkaitnya, dan memandu Anda melalui ikhtisar kemampuan pipa.

Untuk informasi tentang cara membuat pipa menggunakan AWS CLI, lihat bu at-pipa di Referensi Perintah AWS CLI.

Menentukan sumber

Untuk memulai, tentukan sumber dari mana Anda ingin pipa menerima peristiwa.

Untuk menentukan sumber pipa dengan menggunakan konsol

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

  2. Pada panel navigasi, pilih Pi pa.

  3. Pilih Buat pipa.

  4. Masukkan nama untuk pipa.

  5. (Opsional) Tambahkan deskripsi untuk pipa.

  6. Pada tab Build pipe, untuk Source, pilih jenis sumber yang ingin Anda tentukan untuk pipa ini, dan konfigurasikan sumbernya.

    Properti konfigurasi berbeda berdasarkan jenis sumber yang Anda pilih:

    Confluent
    Untuk mengkonfigurasi aliran Confluent Cloud sebagai sumber, dengan menggunakan konsol

    1. Untuk Sumber, pilih Confluent Cloud.

    2. Untuk server Bootstrap, masukkan alamat host:port pasangan broker Anda.

    3. Untuk Nama Topik, masukkan nama topik yang akan dibaca pipa.

    4. (Opsional) Untuk VPC, pilih VPC yang Anda inginkan. Kemudian, untuk subnet VPC, pilih subnet yang diinginkan. Untuk grup keamanan VPC, pilih grup keamanan.

    5. Untuk O tentikasi - opsional, aktifkan Gunakan Otentikasi dan lakukan hal berikut:

      1. Untuk Metode otentikasi, pilih jenis otentikasi.

      2. Untuk kunci rahasia, pilih kunci rahasia.

      Untuk informasi selengkapnya, lihat Men gotentikasi ke sumber daya Confluent Cloud dalam dokumentasi Confluent.

    6. (Opsional) Untuk pengaturan tambahan - opsional, lakukan hal berikut:

      1. Untuk Posisi awal, pilih salah satu dari berikut ini:

        • Ter baru — Mulai membaca streaming dengan catatan terbaru di pecahan.

        • Potong horizon — Mulai membaca aliran dengan catatan terakhir yang belum dipangkas di pecahan. Ini adalah catatan tertua di pecahan.

      2. Untuk Ukuran batch - opsional, masukkan jumlah maksimum catatan untuk setiap batch. Nilai default-nya adalah 100.

      3. Untuk jendela Batch - opsional, masukkan jumlah detik maksimum untuk mengumpulkan catatan sebelum melanjutkan.

    DynamoDB

    1. Untuk Sumber, pilih DynamoDB.

    2. Untuk aliran DynamoDB, pilih aliran yang ingin Anda gunakan sebagai sumber.

    3. Untuk Posisi awal, pilih salah satu dari berikut ini:

      • Ter baru — Mulai membaca streaming dengan catatan terbaru di pecahan.

      • Potong horizon — Mulai membaca aliran dengan catatan terakhir yang belum dipangkas di pecahan. Ini adalah catatan tertua di pecahan.

    4. (Opsional) Untuk pengaturan tambahan - opsional, lakukan hal berikut:

      1. Untuk Ukuran batch - opsional, masukkan jumlah maksimum catatan untuk setiap batch. Nilai default adalah 10.

      2. Untuk jendela Batch - opsional, masukkan jumlah detik maksimum untuk mengumpulkan catatan sebelum melanjutkan.

      3. Untuk Batch bersamaan per pecahan - opsional, masukkan jumlah batch dari pecahan yang sama yang dapat dibaca pada saat yang sama.

      4. Untuk Pada kegagalan item batch sebagian, pilih yang berikut ini:

        • AUTOMATIC_BISECT — Belah dua setiap batch dan coba lagi setiap setengah sampai semua catatan diproses atau ada satu pesan gagal yang tersisa dalam batch.

        catatan

        Jika Anda tidak memilih AUTOMATIC_BISECT, Anda dapat mengembalikan catatan gagal tertentu dan hanya catatan yang dicoba ulang.

    Kinesis
    Untuk mengkonfigurasi sumber Kinesis dengan menggunakan konsol

    1. Untuk Sumber, pilih Kinesis.

    2. Untuk streaming Kinesis, pilih aliran yang ingin Anda gunakan sebagai sumber.

    3. Untuk Posisi awal, pilih salah satu dari berikut ini:

      • Ter baru — Mulai membaca streaming dengan catatan terbaru di pecahan.

      • Potong horizon — Mulai membaca aliran dengan catatan terakhir yang belum dipangkas di pecahan. Ini adalah catatan tertua di pecahan.

      • Pada stempel waktu — Mulai membaca streaming dari waktu yang ditentukan. Di bawah Timestamp, masukkan data dan waktu menggunakan format YYYY/MM/DD dan hh:mm:ss.

    4. (Opsional) Untuk pengaturan tambahan - opsional, lakukan hal berikut:

      1. Untuk Ukuran batch - opsional, masukkan jumlah maksimum catatan untuk setiap batch. Nilai default adalah 10.

      2. (Opsional) Untuk jendela Batch - opsional, masukkan jumlah detik maksimum untuk mengumpulkan catatan sebelum melanjutkan.

      3. Untuk Batch bersamaan per pecahan - opsional, masukkan jumlah batch dari pecahan yang sama yang dapat dibaca pada saat yang sama.

      4. Untuk Pada kegagalan item batch sebagian, pilih yang berikut ini:

        • AUTOMATIC_BISECT — Belah dua setiap batch dan coba lagi setiap setengah sampai semua catatan diproses atau ada satu pesan gagal yang tersisa dalam batch.

        catatan

        Jika Anda tidak memilih AUTOMATIC_BISECT, Anda dapat mengembalikan catatan gagal tertentu dan hanya catatan yang dicoba ulang.

    Amazon MQ
    Untuk mengkonfigurasi sumber Amazon MQ dengan menggunakan konsol

    1. Untuk Sumber, pilih Amazon MQ.

    2. Untuk broker Amazon MQ, pilih streaming yang ingin Anda gunakan sebagai sumber.

    3. Untuk Nama antrian, masukkan nama antrian yang akan dibaca pipa.

    4. Untuk Metode O tentikasi, pilih BASIC _AUTH.

    5. Untuk kunci rahasia, pilih kunci rahasia.

    6. (Opsional) Untuk pengaturan tambahan - opsional, lakukan hal berikut:

      1. Untuk Ukuran batch - opsional, masukkan jumlah maksimum pesan untuk setiap batch. Nilai default-nya adalah 100.

      2. Untuk jendela Batch - opsional, masukkan jumlah detik maksimum untuk mengumpulkan catatan sebelum melanjutkan.

    Amazon MSK
    Cara mengonfigurasi sumber Amazon MSK dengan menggunakan konsol

    1. Untuk Sumber, pilih Amazon MSK.

    2. Untuk cluster Amazon MSK, pilih cluster yang ingin Anda gunakan.

    3. Untuk Nama Topik, masukkan nama topik yang akan dibaca pipa.

    4. (Opsional) Untuk ID Grup Konsumen - opsional, masukkan ID grup konsumen yang ingin dihubungkan oleh pipa tersebut.

    5. (Opsional) Untuk O tentikasi - opsional, aktifkan Gunakan Otentikasi dan lakukan hal berikut:

      1. Untuk metode otentikasi, pilih jenis yang Anda inginkan.

      2. Untuk kunci rahasia, pilih kunci rahasia.

    6. (Opsional) Untuk pengaturan tambahan - opsional, lakukan hal berikut:

      1. Untuk Ukuran batch - opsional, masukkan jumlah maksimum catatan untuk setiap batch. Nilai default-nya adalah 100.

      2. Untuk jendela Batch - opsional, masukkan jumlah detik maksimum untuk mengumpulkan catatan sebelum melanjutkan.

      3. Untuk Posisi awal, pilih salah satu dari berikut ini:

        • Ter baru — Mulai membaca topik dengan catatan terbaru di pecahan.

        • Potong horizon — Mulai membaca topik dengan catatan terakhir yang belum dipangkas di pecahan. Ini adalah catatan tertua di pecahan.

          catatan

          Trim horizon sama dengan Earthly untuk Apache Kafka.

    Self managed Apache Kafka
    Untuk mengkonfigurasi sumber Apache Kafka yang dikelola sendiri dengan menggunakan konsol

    1. Untuk Sumber, pilih Self-managed Apache Kafka.

    2. Untuk server Bootstrap, masukkan alamat host:port pasangan broker Anda.

    3. Untuk Nama Topik, masukkan nama topik yang akan dibaca pipa.

    4. (Opsional) Untuk VPC, pilih VPC yang Anda inginkan. Kemudian, untuk subnet VPC, pilih subnet yang diinginkan. Untuk grup keamanan VPC, pilih grup keamanan.

    5. (Opsional) Untuk O tentikasi - opsional, aktifkan Gunakan Otentikasi dan lakukan hal berikut:

      1. Untuk Metode otentikasi, pilih jenis otentikasi.

      2. Untuk kunci rahasia, pilih kunci rahasia.

    6. (Opsional) Untuk pengaturan tambahan - opsional, lakukan hal berikut:

      1. Untuk Posisi awal, pilih salah satu dari berikut ini:

        • Ter baru — Mulai membaca streaming dengan catatan terbaru di pecahan.

        • Potong horizon — Mulai membaca aliran dengan catatan terakhir yang belum dipangkas di pecahan. Ini adalah catatan tertua di pecahan.

      2. Untuk Ukuran batch - opsional, masukkan jumlah maksimum catatan untuk setiap batch. Nilai default-nya adalah 100.

      3. Untuk jendela Batch - opsional, masukkan jumlah detik maksimum untuk mengumpulkan catatan sebelum melanjutkan.

    Amazon SQS
    Untuk mengonfigurasi sumber Amazon SQS dengan menggunakan konsol

    1. Untuk Sumber, pilih SQS.

    2. Untuk antrian SQS, pilih antrian yang ingin Anda gunakan.

    3. (Opsional) Untuk pengaturan tambahan - opsional, lakukan hal berikut:

      1. Untuk Ukuran batch - opsional, masukkan jumlah maksimum catatan untuk setiap batch. Nilai default-nya adalah 100.

      2. Untuk jendela Batch - opsional, masukkan jumlah detik maksimum untuk mengumpulkan catatan sebelum melanjutkan.

Mengkonfigurasi pemfilteran acara (opsional)

Anda dapat menambahkan pemfilteran ke pipa sehingga Anda hanya mengirim sebagian peristiwa dari sumber Anda ke target.

Untuk mengkonfigurasi penyaringan dengan menggunakan konsol

  1. Pilih Pen yaringan.

  2. Di bawah Contoh acara - opsional, Anda akan melihat contoh acara yang dapat Anda gunakan untuk membangun pola acara Anda, atau Anda dapat memasukkan acara Anda sendiri dengan memilih Masukkan sendiri.

  3. Di bawah Pola peristiwa, masukkan pola peristiwa yang ingin Anda gunakan untuk memfilter peristiwa. Untuk informasi selengkapnya tentang membuat filter, lihatPemfilteran acara di Amazon Pipes EventBridge.

    Berikut ini adalah contoh pola peristiwa yang hanya mengirimkan peristiwa dengan nilai Seattle di bidang Kota.

    {
  "data": {
    "City": ["Seattle"]
  }
}

Sekarang peristiwa sedang difilter, Anda dapat menambahkan pengayaan opsional dan target untuk pipa.

Mendefinisikan pengayaan acara (opsional)

Anda dapat mengirim data peristiwa untuk pengayaan ke fungsi Lambda, mesin AWS Step Functions status, Amazon API Gateway, atau tujuan API.

Untuk memilih pengayaan

  1. Pilih Pengayaan.

  2. Di bawah Detail, untuk Layanan, pilih layanan dan pengaturan terkait yang ingin Anda gunakan untuk pengayaan.

Anda juga dapat mengubah data sebelum mengirimkannya untuk ditingkatkan.

(Opsional) Untuk menentukan transformator input

  1. Pilih Transformator Input Peng ayaan - opsional.

  2. Untuk Mu events/Event atan Sam pel, pilih jenis acara sampel.

  3. Untuk Transformer, masukkan sintaks transformator, seperti "Event happened at <$.detail.field>." di mana <$.detail.field> adalah referensi ke bidang dari peristiwa sampel. Anda juga dapat mengklik dua kali bidang dari acara sampel untuk menambahkannya ke transformator.

  4. Untuk Output, verifikasi bahwa output terlihat seperti yang Anda inginkan.

Sekarang data telah difilter dan ditingkatkan, Anda harus menentukan target untuk mengirim data acara.

Mengonfigurasi target

Untuk mengkonfigurasi target

  1. Pilih Target.

  2. Di bawah Detail, untuk layanan Target, pilih target. Bidang yang ditampilkan bervariasi tergantung pada target yang Anda pilih. Masukkan informasi khusus untuk jenis target ini, sesuai kebutuhan.

Anda juga dapat mengubah data sebelum mengirimkannya ke target.

(Opsional) Untuk menentukan transformator input

  1. Pilih Target Input Transformer - opsional.

  2. Untuk Mu events/Event atan Sam pel, pilih jenis acara sampel.

  3. Untuk Transformer, masukkan sintaks transformator, seperti "Event happened at <$.detail.field>." di mana <$.detail.field> adalah referensi ke bidang dari peristiwa sampel. Anda juga dapat mengklik dua kali bidang dari acara sampel untuk menambahkannya ke transformator.

  4. Untuk Output, verifikasi bahwa output terlihat seperti yang Anda inginkan.

Sekarang pipa dikonfigurasi, pastikan pengaturannya dikonfigurasi dengan benar.

Mengonfigurasi pengaturan alur

Pipa aktif secara default, tetapi Anda dapat menonaktifkannya. Anda juga dapat menentukan izin pipa, mengatur logging pipa, dan menambahkan tag.

Untuk mengkonfigurasi pengaturan pipa

  1. Pilih tab Pengaturan pipa.

  2. Secara default, pipa yang baru dibuat aktif segera setelah dibuat. Jika Anda ingin membuat pipa tidak aktif, di bawah Aktivasi, untuk Aktifkan pipa, matikan Aktif.

  3. Di bawah Iz in, untuk Peran Ek sekusi, lakukan salah satu hal berikut:

    1. Untuk EventBridge membuat peran eksekusi baru untuk pipa ini, pilih Buat peran baru untuk sumber daya spesifik ini. Di bawah Nama peran, Anda dapat mengedit nama peran secara opsional.

    2. Untuk menggunakan peran eksekusi yang ada, pilih Gunakan peran yang ada. Di bawah Nama peran, pilih peran.

    Manajer peran diaktifkan

    Jika manajer peran diaktifkan di akun Anda, EventBridge lampirkan peran untuk Anda. EventBridge menggantikan opsi Buat peran baru untuk sumber daya spesifik ini dan Gunakan peran yang ada dengan opsi Ku stom isasi. Untuk menggunakan peran yang berbeda, pilih Sesuaikan. Untuk informasi selengkapnya, lihat Pembuatan peran IAM dalam Panduan Pengguna IAM.

  4. (Opsional) Jika Anda telah menentukan DynamoDB aliran Kinesis atau sebagai sumber pipa, Anda dapat mengonfigurasi kebijakan coba ulang dan antrean huruf mati (DLQ).

    Untuk kebijakan Coba ulang dan Dead-letter antrian - opsional, lakukan hal berikut:

    Di bawah Kebijakan Coba Ul ang, lakukan hal berikut:

    1. Jika Anda ingin mengaktifkan kebijakan coba lagi, aktifkan Coba lagi. Secara default, pipa yang baru dibuat tidak mengaktifkan kebijakan coba ulang.

    2. Untuk Masa peristiwa maksimal, masukkan nilai antara satu menit (00:01) dan 24 jam (24:00).

    3. Untuk Upaya coba lagi, masukkan angka antara 0 dan 185.

    4. Jika Anda ingin menggunakan antrean huruf mati (DLQ), aktifkan Dead-letter antrian, pilih metode pilihan Anda, dan pilih antrian atau topik yang ingin Anda gunakan. Secara default, pipa yang baru dibuat tidak menggunakan DLQ.

  5. Pilih KMS key EventBridge untuk digunakan saat mengenkripsi data pipa.

    Untuk informasi lebih lanjut tentang cara EventBridge penggunaan KMS keys, lihatEnkripsi saat diam.

    • Pilih Gunakan Kunci milik AWS EventBridge untuk mengenkripsi data menggunakan Kunci milik AWS.

      Ini Kunci milik AWS adalah KMS key yang EventBridge memiliki dan mengelola untuk digunakan di beberapa AWS akun. Secara umum, kecuali Anda diminta untuk mengaudit atau mengontrol kunci enkripsi yang melindungi sumber daya Anda, an Kunci milik AWS adalah pilihan yang baik.

      Ini adalah opsi default.

    • Pilih Gunakan kunci yang dikelola pelanggan EventBridge untuk mengenkripsi data menggunakan kunci yang dikelola pelanggan yang Anda tentukan atau buat.

      Kunci yang dikelola pelanggan ada KMS keys di AWS akun Anda yang Anda buat, miliki, dan kelola. Anda memiliki kontrol penuh atas ini KMS keys.

      1. Tentukan yang sudah ada kunci yang dikelola pelanggan, atau pilih Buat yang baru KMS key.

        EventBridge menampilkan status kunci dan alias kunci apa pun yang telah dikaitkan dengan yang ditentukan kunci yang dikelola pelanggan.

  6. (Opsional) Di bawah Log - opsional, Anda dapat mengatur cara P EventBridge ipes mengirimkan informasi logging ke layanan yang didukung, termasuk cara mengonfigurasi log tersebut.

    Untuk informasi selengkapnya tentang pencatatan pipa logging, lihatPencatatan kinerja Amazon EventBridge Pipes.

    CloudWatch log dipilih sebagai tujuan log secara default, seperti tingkat ERROR log. Jadi, secara default EventBridge , Pipes CloudWatch membuat grup log baru yang mengirimkan catatan log yang berisi ERROR tingkat detail.

    Agar P EventBridge ipes mengirim catatan log ke salah satu tujuan log yang didukung, lakukan hal berikut:

    1. Di bawah Log - opsional, pilih tujuan yang ingin Anda kirimkan catatan log.

    2. Untuk tingkat log, pilih tingkat informasi yang akan EventBridge disertakan dalam catatan log. Tingkat ERROR log dipilih secara default.

      Untuk informasi selengkapnya, lihat Menentukan tingkat log EventBridge Pipa.

    3. Pilih Sertakan data eksekusi jika Anda EventBridge ingin menyertakan informasi muatan peristiwa dan permintaan layanan dan informasi respons dalam catatan log.

      Untuk informasi selengkapnya, lihat Termasuk data eksekusi di log EventBridge Pipes.

    4. Konfigurasikan setiap tujuan log yang Anda pilih:

      Untuk CloudWatch Logs log, di bawah CloudWatch log lakukan hal berikut:

      • Untuk grup CloudWatch log, pilih apakah akan EventBridge membuat grup log baru, atau Anda dapat memilih grup log yang ada atau menentukan ARN dari grup log yang ada.

      • Untuk grup log baru, edit nama grup log sesuai keinginan.

      CloudWatch log dipilih secara default.

      Untuk log Firehose aliran, di bawah log Firehose aliran, pilih Firehose aliran.

      Untuk Amazon S3 log, di bawah log S3 lakukan hal berikut:

      • Masukkan nama bucket yang akan digunakan sebagai tujuan log.

      • Masukkan ID AWS akun pemilik bucket.

      • Masukkan teks awalan apa pun yang ingin Anda gunakan EventBridge saat membuat objek S3.

        Untuk informasi selengkapnya, lihat Mengatur objek menggunakan aw alan di Panduan Amazon Simple Storage Service Pengguna.

      • Pilih cara Anda ingin EventBridge memformat catatan log S3:

  7. (Opsional) Di bawah Tag - opsional, pilih Tam bah tag baru dan masukkan satu atau lebih tag untuk aturan. Untuk informasi selengkapnya, lihat Menandai sumber daya di Amazon EventBridge.

  8. Pilih Buat pipa.

Memvalidasi parameter konfigurasi

Setelah pipa dibuat, EventBridge memvalidasi parameter konfigurasi berikut:

  • Peran IAM — Karena sumber pipa tidak dapat diubah setelah pipa dibuat, EventBridge memverifikasi bahwa peran IAM yang disediakan dapat mengakses sumber.

    catatan

    EventBridge tidak melakukan validasi yang sama untuk pengayaan atau target karena mereka dapat diperbarui setelah pipa dibuat.

  • Batching — EventBridge memvalidasi bahwa ukuran batch sumber tidak melebihi ukuran batch maksimum target. Jika ya, EventBridge membutuhkan ukuran batch yang lebih rendah. Selain itu, jika target tidak mendukung batching, Anda tidak dapat mengonfigurasi batching EventBridge untuk sumber.

  • Pengayaan — EventBridge memvalidasi bahwa ukuran batch untuk API Gateway dan pengayaan tujuan API adalah 1 karena hanya ukuran batch 1 yang didukung.