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 point-to-point integrasi antara sumber dan target, termasuk transformasi dan pengayaan acara lanjutan.
Untuk membuat EventBridge pipa, Anda melakukan langkah-langkah berikut:
1. [Menentukan sumber](#pipes-configure-source)
1. [Mengkonfigurasi penyaringan acara (opsional)](#pipes-configure-filtering)
1. [Mendefinisikan pengayaan acara (opsional)](#pipes-define-enrichment)
1. [Mengkonfigurasi target](#pipes-configure-target)
1. [Mengkonfigurasi pengaturan pipa](#pipes-configure-pipe-settings)
Untuk mengatur pipa sampel dengan cepat, lihat[Memulai: Buat EventBridge pipa Amazon](pipes-get-started.md). Topik ini digunakan CloudFormation untuk menyebarkan pipa dan sumber daya terkait, dan memandu Anda melalui ikhtisar kemampuan pipa.
*Untuk informasi tentang cara membuat pipa menggunakan CLI, lihat [create-pipe](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/pipes/create-pipe.html) di AWS CLI Command Reference.AWS *
## Menentukan sumber
Untuk memulai, tentukan sumber dari mana Anda ingin pipa menerima acara.
**Untuk menentukan sumber pipa dengan menggunakan konsol**
1. Buka EventBridge konsol Amazon di [https://console.aws.amazon.com/events/](https://console.aws.amazon.com/events/).
1. Pada panel navigasi, pilih **Pipa**.
1. Pilih **Buat pipa**.
1. Masukkan nama untuk pipa.
1. (Opsional) Tambahkan deskripsi untuk pipa.
1. 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 mengonfigurasi aliran Confluent Cloud sebagai sumber, dengan menggunakan konsol**
1. Untuk **Sumber**, pilih **Confluent Cloud.**
1. Untuk **server Bootstrap**, masukkan alamat `host:port` pasangan broker Anda.
1. Untuk **nama Topik**, masukkan nama topik yang akan dibaca pipa.
1. (Opsional) Untuk **VPC**, pilih VPC yang Anda inginkan. Kemudian, untuk subnet **VPC, pilih subnet** yang diinginkan. Untuk **grup keamanan VPC, pilih grup** keamanan.
1. Untuk **Otentikasi - opsional**, aktifkan **Gunakan Otentikasi** dan lakukan hal berikut:
1. Untuk **metode otentikasi**, pilih jenis otentikasi.
1. Untuk **kunci Rahasia**, pilih kunci rahasia.
Untuk informasi selengkapnya, lihat [Mengautentikasi ke sumber daya Confluent Cloud di dokumentasi](https://docs.confluent.io/cloud/current/access-management/authenticate/overview.html) Confluent.
1. (Opsional) Untuk **pengaturan tambahan - opsional**, lakukan hal berikut:
1. Untuk **posisi awal**, pilih salah satu dari berikut ini:
+ **Terbaru** - Mulailah membaca aliran dengan catatan terbaru di pecahan.
+ **Potong cakrawala** - Mulailah membaca aliran dengan catatan terakhir yang belum dipangkas di pecahan. Ini adalah rekor tertua di pecahan.
1. Untuk **ukuran Batch - opsional**, masukkan jumlah maksimum catatan untuk setiap batch. Nilai default-nya adalah 100.
1. Untuk **jendela Batch - opsional**, masukkan jumlah maksimum detik untuk mengumpulkan catatan sebelum melanjutkan.
------
#### [ DynamoDB ]
1. Untuk **Sumber**, pilih **DynamoDB**.
1. Untuk aliran **DynamoDB**, pilih aliran yang ingin Anda gunakan sebagai sumber.
1. Untuk **posisi awal**, pilih salah satu dari berikut ini:
+ **Terbaru** - Mulailah membaca aliran dengan catatan terbaru di pecahan.
+ **Potong cakrawala** - Mulailah membaca aliran dengan catatan terakhir yang belum dipangkas di pecahan. Ini adalah rekor tertua di pecahan.
1. (Opsional) Untuk **pengaturan tambahan - opsional**, lakukan hal berikut:
1. Untuk **ukuran Batch - opsional**, masukkan jumlah maksimum catatan untuk setiap batch. Nilai default adalah 10.
1. Untuk **jendela Batch - opsional**, masukkan jumlah maksimum detik untuk mengumpulkan catatan sebelum melanjutkan.
1. Untuk **batch bersamaan per pecahan - opsional**, masukkan jumlah batch dari pecahan yang sama yang dapat dibaca pada saat yang sama.
1. Untuk **Kegagalan item batch sebagian**, pilih yang berikut ini:
+ **AUTOMATIC\_BISECT** — Potong dua setiap batch dan coba lagi setiap setengahnya sampai semua catatan diproses atau ada satu pesan gagal yang tersisa di batch.
**catatan**
Jika Anda tidak memilih **AUTOMATIC\_BISECT**, Anda dapat mengembalikan catatan gagal tertentu dan hanya yang dicoba ulang.
------
#### [ Kinesis ]
**Untuk mengkonfigurasi sumber Kinesis dengan menggunakan konsol**
1. Untuk **Sumber**, pilih **Kinesis**.
1. Untuk **aliran Kinesis**, pilih aliran yang ingin Anda gunakan sebagai sumber.
1. Untuk **posisi awal**, pilih salah satu dari berikut ini:
+ **Terbaru** - Mulailah membaca aliran dengan catatan terbaru di pecahan.
+ **Potong cakrawala** - Mulailah membaca aliran dengan catatan terakhir yang belum dipangkas di pecahan. Ini adalah rekor tertua di pecahan.
+ **Pada stempel waktu** — Mulai membaca aliran dari waktu yang ditentukan. Di bawah **Timestamp**, masukkan data dan waktu menggunakan YYYY/MM/DD dan format hh: mm: ss.
1. (Opsional) Untuk **pengaturan tambahan - opsional**, lakukan hal berikut:
1. Untuk **ukuran Batch - opsional**, masukkan jumlah maksimum catatan untuk setiap batch. Nilai default adalah 10.
1. (Opsional) Untuk **jendela Batch - opsional**, masukkan jumlah maksimum detik untuk mengumpulkan catatan sebelum melanjutkan.
1. Untuk **batch bersamaan per pecahan - opsional**, masukkan jumlah batch dari pecahan yang sama yang dapat dibaca pada saat yang sama.
1. Untuk **Kegagalan item batch sebagian**, pilih yang berikut ini:
+ **AUTOMATIC\_BISECT** — Potong dua setiap batch dan coba lagi setiap setengahnya sampai semua catatan diproses atau ada satu pesan gagal yang tersisa di batch.
**catatan**
Jika Anda tidak memilih **AUTOMATIC\_BISECT**, Anda dapat mengembalikan catatan gagal tertentu dan hanya yang dicoba ulang.
------
#### [ Amazon MQ ]
**Untuk mengonfigurasi sumber Amazon MQ dengan menggunakan konsol**
1. Untuk **Sumber**, pilih **Amazon MQ**.
1. Untuk **broker Amazon MQ**, pilih aliran yang ingin Anda gunakan sebagai sumber.
1. Untuk **nama Antrian**, masukkan nama antrian yang akan dibaca pipa.
1. Untuk **Metode Otentikasi**, pilih **BASIC\_AUTH**.
1. Untuk **kunci Rahasia**, pilih kunci rahasia.
1. (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.
1. Untuk **jendela Batch - opsional**, masukkan jumlah maksimum detik untuk mengumpulkan catatan sebelum melanjutkan.
------
#### [ Amazon MSK ]
**Untuk mengonfigurasi sumber MSK Amazon dengan menggunakan konsol**
1. Untuk **Sumber**, pilih **Amazon MSK**.
1. Untuk **Amazon MSK cluster**, pilih cluster yang ingin Anda gunakan.
1. Untuk **nama Topik**, masukkan nama topik yang akan dibaca pipa.
1. (Opsional) Untuk **ID Grup Konsumen - opsional**, masukkan ID grup konsumen yang Anda inginkan untuk bergabung dengan pipa.
1. (Opsional) Untuk **Otentikasi - opsional**, aktifkan **Gunakan Otentikasi** dan lakukan hal berikut:
1. Untuk **metode Otentikasi**, pilih jenis yang Anda inginkan.
1. Untuk **kunci Rahasia**, pilih kunci rahasia.
1. (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.
1. Untuk **jendela Batch - opsional**, masukkan jumlah maksimum detik untuk mengumpulkan catatan sebelum melanjutkan.
1. Untuk **posisi awal**, pilih salah satu dari berikut ini:
+ **Terbaru** - Mulailah membaca topik dengan catatan terbaru di pecahan.
+ **Potong cakrawala** - Mulailah membaca topik dengan catatan terakhir yang belum dipangkas di pecahan. Ini adalah rekor tertua di pecahan.
**catatan**
**Trim horizon** sama dengan **Earlyest** untuk Apache Kafka.
------
#### [ Self managed Apache Kafka ]
**Untuk mengonfigurasi sumber Apache Kafka yang dikelola sendiri dengan menggunakan konsol**
1. Untuk **Sumber**, pilih **Apache Kafka yang dikelola sendiri**.
1. Untuk **server Bootstrap**, masukkan alamat `host:port` pasangan broker Anda.
1. Untuk **nama Topik**, masukkan nama topik yang akan dibaca pipa.
1. (Opsional) Untuk **VPC**, pilih VPC yang Anda inginkan. Kemudian, untuk subnet **VPC, pilih subnet** yang diinginkan. Untuk **grup keamanan VPC, pilih grup** keamanan.
1. (Opsional) Untuk **Otentikasi - opsional**, aktifkan **Gunakan Otentikasi** dan lakukan hal berikut:
1. Untuk **metode otentikasi**, pilih jenis otentikasi.
1. Untuk **kunci Rahasia**, pilih kunci rahasia.
1. (Opsional) Untuk **pengaturan tambahan - opsional**, lakukan hal berikut:
1. Untuk **posisi awal**, pilih salah satu dari berikut ini:
+ **Terbaru** - Mulailah membaca aliran dengan catatan terbaru di pecahan.
+ **Potong cakrawala** - Mulailah membaca aliran dengan catatan terakhir yang belum dipangkas di pecahan. Ini adalah rekor tertua di pecahan.
1. Untuk **ukuran Batch - opsional**, masukkan jumlah maksimum catatan untuk setiap batch. Nilai default-nya adalah 100.
1. Untuk **jendela Batch - opsional**, masukkan jumlah maksimum detik untuk mengumpulkan catatan sebelum melanjutkan.
------
#### [ Amazon SQS ]
**Untuk mengonfigurasi sumber Amazon SQS dengan menggunakan konsol**
1. Untuk **Sumber**, pilih **SQS.**
1. Untuk **antrian SQS**, pilih antrian yang ingin Anda gunakan.
1. (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.
1. Untuk **jendela Batch - opsional**, masukkan jumlah maksimum detik untuk mengumpulkan catatan sebelum melanjutkan.
------
## Mengkonfigurasi penyaringan acara (opsional)
Anda dapat menambahkan pemfilteran ke pipa Anda sehingga Anda hanya mengirim sebagian peristiwa dari sumber Anda ke target.
**Untuk mengkonfigurasi pemfilteran dengan menggunakan konsol**
1. Pilih **Penyaringan**.
1. Di bawah **Contoh acara - opsional**, Anda akan melihat contoh peristiwa yang dapat Anda gunakan untuk membangun pola acara Anda, atau Anda dapat memasukkan acara Anda sendiri dengan memilih **Enter your own**.
1. Di bawah **pola acara**, masukkan pola acara yang ingin Anda gunakan untuk memfilter peristiwa. Untuk informasi selengkapnya tentang membuat filter, lihat[Pemfilteran acara di Amazon Pipes EventBridge](eb-pipes-event-filtering.md).
Berikut ini adalah contoh pola peristiwa yang hanya mengirimkan peristiwa dengan nilai **Seattle** di bidang **City**.
```
{
"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**.
1. Di bawah **Detail**, untuk **Layanan**, pilih layanan dan setelan terkait yang ingin Anda gunakan untuk pengayaan.
Anda juga dapat mengubah data sebelum mengirimnya untuk ditingkatkan.
**(Opsional) Untuk menentukan transformator input**
1. Pilih **Enrichment Input Transformer - opsional**.
1. Untuk ** events/Event Payload Sampel**, pilih jenis acara sampel.
1. 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 peristiwa sampel untuk menambahkannya ke transformator.
1. Untuk **Output**, verifikasi bahwa output terlihat seperti yang Anda inginkan.
Sekarang data telah disaring dan ditingkatkan, Anda harus menentukan target untuk mengirim data acara ke.
## Mengkonfigurasi target
**Untuk mengkonfigurasi target**
1. Pilih **Target**.
1. 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 mengirimnya ke target.
**(Opsional) Untuk menentukan transformator input**
1. Pilih **Target Input Transformer - opsional**.
1. Untuk ** events/Event Payload Sampel**, pilih jenis acara sampel.
1. 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 peristiwa sampel untuk menambahkannya ke transformator.
1. Untuk **Output**, verifikasi bahwa output terlihat seperti yang Anda inginkan.
Sekarang pipa dikonfigurasi, pastikan pengaturannya dikonfigurasi dengan benar.
## Mengkonfigurasi pengaturan pipa
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**.
1. 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**.
1. Di bawah **Izin**, untuk **peran Eksekusi**, lakukan salah satu hal berikut:
1. Untuk EventBridge membuat peran eksekusi baru untuk pipa ini, pilih **Buat peran baru untuk sumber daya khusus ini.** Di bawah **Nama peran**, Anda dapat mengedit nama peran secara opsional.
1. Untuk menggunakan peran eksekusi yang ada, pilih **Gunakan peran yang ada**. Di bawah **Nama peran**, pilih peran.
1. (Opsional) Jika Anda telah menentukan DynamoDB aliran Kinesis atau sebagai sumber pipa, Anda dapat mengonfigurasi kebijakan coba lagi dan antrian huruf mati (DLQ).
Untuk **kebijakan Coba lagi dan antrian Dead-letter - opsional**, lakukan hal berikut:
Di bawah **kebijakan Coba Ulang**, lakukan hal berikut:
1. Jika Anda ingin mengaktifkan kebijakan coba lagi, aktifkan Coba **lagi**. Secara default, pipa yang baru dibuat tidak mengaktifkan kebijakan coba lagi.
1. Untuk **Masa peristiwa maksimal**, masukkan nilai antara satu menit (00:01) dan 24 jam (24:00).
1. Untuk **Upaya coba lagi**, masukkan angka antara 0 dan 185.
1. Jika Anda ingin menggunakan antrian huruf mati (DLQ), aktifkan antrian **Dead-letter, pilih metode pilihan Anda, dan pilih antrian** atau topik yang ingin Anda gunakan. Secara default, pipa yang baru dibuat tidak menggunakan DLQ.
1. Pilih KMS key EventBridge untuk digunakan saat mengenkripsi data pipa.
Untuk informasi selengkapnya tentang cara EventBridge penggunaan KMS keys, lihat[Enkripsi saat diam](eb-data-protection.md#eb-encryption-at-rest).
+ Pilih **Gunakan Kunci milik AWS** EventBridge untuk mengenkripsi data menggunakan file 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, a 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 kendali 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.
1. (Opsional) Di bawah **Log - opsional**, Anda dapat mengatur cara EventBridge Pipes mengirimkan informasi pencatatan ke layanan yang didukung, termasuk cara mengonfigurasi log tersebut.
Untuk informasi selengkapnya tentang pencatatan pipa logging, lihat[Pencatatan kinerja Amazon EventBridge Pipes](eb-pipes-logs.md).
CloudWatch log dipilih sebagai tujuan log secara default, seperti tingkat `ERROR` log. Jadi, secara default, EventBridge Pipes membuat grup CloudWatch log baru yang mengirimkan catatan log yang berisi `ERROR` tingkat detail.
Agar EventBridge Pipes 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.
1. Untuk **tingkat Log**, pilih tingkat informasi EventBridge untuk disertakan dalam catatan log. Tingkat `ERROR` log dipilih secara default.
Untuk informasi selengkapnya, lihat [Menentukan tingkat log EventBridge Pipa](eb-pipes-logs.md#eb-pipes-logs-level).
1. Pilih **Sertakan data eksekusi** jika Anda EventBridge ingin menyertakan informasi payload peristiwa dan permintaan layanan dan informasi respons dalam catatan log.
Untuk informasi selengkapnya, lihat [Termasuk data eksekusi di log EventBridge Pipes](eb-pipes-logs.md#eb-pipes-logs-execution-data).
1. 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 untuk digunakan sebagai tujuan log.
+ Masukkan ID AWS akun pemilik bucket.
+ Masukkan teks awalan yang ingin Anda gunakan saat EventBridge membuat objek S3.
Untuk informasi selengkapnya, lihat [Mengatur objek menggunakan awalan](https://docs.aws.amazon.com/AmazonS3/latest/userguide/using-prefixes.html) di *Amazon Simple Storage Service Panduan Pengguna*.
+ Pilih bagaimana Anda ingin EventBridge memformat catatan log S3:
+ `json`: JSON
+ `plain`: Teks biasa
+ `w3c`: Format [file logging diperpanjang W3C](https://www.w3.org/TR/WD-logfile)
1. (Opsional) Di bawah **Tag - opsional**, pilih **Tambahkan tag baru** dan masukkan satu atau beberapa tag untuk aturan. Untuk informasi selengkapnya, lihat [Menandai sumber daya di Amazon EventBridge](eb-tagging.md).
1. 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 sumbernya.
**catatan**
EventBridge tidak melakukan validasi yang sama untuk pengayaan atau target karena 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 sumbernya.
+ **Pengayaan —** EventBridge memvalidasi bahwa ukuran batch untuk API Gateway dan pengayaan tujuan API adalah 1 karena hanya ukuran batch 1 yang didukung.