Dokumen ini menyajikan data pengujian kinerja aliran acara EventBridge dalam berbagai skenario. Anda dapat menggunakan data tersebut untuk mengevaluasi dan merencanakan konfigurasi sumber daya bagi tugas aliran acara.
Pengujian ini dioptimalkan untuk latensi rendah. Jika skenario Anda memprioritaskan throughput dan tidak sensitif terhadap latensi, kinerja aktual mungkin lebih baik.
Pengujian kinerja dari topik Kafka ke topik Kafka
Konfigurasi lingkungan pengujian
Spesifikasi instans Kafka
Item konfigurasi | Instans hulu | Instans Hilir |
Jenis spesifikasi | Edisi Standar (High-write) | Edisi Standar (High-write) |
Jenis instans | Instansi terhubung-Internet dan VPC | Instansi terhubung-Internet dan VPC |
Spesifikasi trafik | alikafka.hw.2xlarge Trafik baca puncak 20 MB/detik Trafik tulis puncak 20 MB/detik | alikafka.hw.2xlarge Trafik baca puncak 20 MB/detik Trafik tulis puncak 20 MB/detik |
Lalu lintas internet | 81 Mbps | 81 Mbps |
Jenis disk | Ultra disk | Ultra disk |
Kapasitas disk | 900 GB Kapasitas penyimpanan 300 GB Kapasitas cadangan 600 GB | 900 GB Kapasitas penyimpanan 300 GB Kapasitas cadangan 600 GB |
Versi | 2.6.2 | 2.6.2 |
Kategori topik | Pesan Normal | Pesan Normal |
Ukuran pesan | 1 KB | 1 KB |
Konten pesan | Kunci: null Isi: string acak | Kunci: null Isi: string acak |
Parameter tugas aliran acara
Konfigurasi sumber
Parameter | Nilai |
Konfigurasi jaringan | Jaringan Klasik |
Format data | Biner |
Konfigurasi sink
Parameter | Nilai |
Mode acknowledgment (ack) | None |
Isi pesan (Value) | Ekstraksi biner: $.data.value |
Kunci pesan (Key) | $.data.key |
Konfigurasi lanjutan
Parameter | Nilai |
Ukuran dorong batch | 100 |
Interval dorong batch (detik) | 0 |
Metode pengujian
Sebuah produsen dikonfigurasi untuk menulis data ke instans Kafka sumber dengan parameter pengiriman batch berikut:
Waktu tunggu batch maksimum: 50 ms
Jendela pengiriman batch: 100 pesan
Hasil pengujian
CUs minimum | CUs maksimum | Laju pemrosesan event (event/detik) | Throughput (MB/detik) | Latensi (ms) |
1 | 1 | 1.500 | 1,5 | 70-80 |
2 | 2 | 4.000 | 4 | 70-90 |
3 | 3 | 6.000 | 6 | 80-100 |
4 | 4 | 8.000 | 8 | 80-120 |
Faktor-faktor berikut secara signifikan memengaruhi kinerja aliran acara:
Pengiriman batch produsen: Menonaktifkan pengiriman batch mengurangi kemampuan pemrosesan Unit Kapasitas (CU) sekitar 50%.
Ukuran pesan: Pesan individual yang besar mengurangi kemampuan pemrosesan CU.
Konfigurasi batch aliran acara: Menonaktifkan jendela dorong batch mengurangi kemampuan pemrosesan CU.
Waktu tanggapan hilir: Latensi tanggapan hilir yang tinggi mengurangi kemampuan pemrosesan CU.
Format data: Menggunakan format JSON mengurangi kemampuan pemrosesan CU. Semakin kompleks strukturnya, semakin besar dampaknya.
Kompresi pesan: Menggunakan kompresi pesan pada instans Kafka sumber mengurangi kemampuan pemrosesan CU.
Pengujian kinerja dari topik RocketMQ ke topik RocketMQ
Konfigurasi lingkungan pengujian
Spesifikasi instans RocketMQ
Item konfigurasi | Instans hulu | Instans hilir |
Seri utama | Edisi Platinum | Edisi Platinum |
Sub-seri | Edisi Ketersediaan Tinggi Cluster | Edisi Ketersediaan Tinggi Cluster |
Versi instans | 5.0-rmq-20250410-1 | 5.0-rmq-20250410-1 |
Jenis instans | rmq.u2.10xlarge | rmq.u2.10xlarge |
Bandwidth publik | Bandwidth tetap 51 Mb/detik | Bandwidth tetap 10 Mb/detik |
Transaksi per detik (TPS) puncak untuk mengirim/menerima | 5.000 untuk mengirim / 5.000 untuk menerima | 5.000 untuk mengirim / 5.000 untuk menerima |
TPS elastis puncak untuk mengirim/menerima | 10.000 untuk mengirim / 10.000 untuk menerima | 2.500 untuk mengirim / 2.500 untuk menerima |
Kategori topik | Pesan Normal | Pesan Normal |
Ukuran pesan | 1 KB | 1 KB |
Konten pesan | Properti: Default sistem Isi: string acak | Properti: Default sistem Isi: string acak |
Parameter tugas aliran acara
Konfigurasi sumber
Parameter | Nilai |
RegionId | cn-hangzhou |
InstanceId | rmq-cn-xxx |
Topic | test_perf |
GroupID | GID_EVENTBRIDGE_xxx |
InstanceType | Cloud_5 |
InstanceVpcId | vpc-xxx |
InstanceVSwitchIds | vsw-xxx |
InstanceSecurityGroupId | sg-xxx |
InstanceNetwork | PrivateNetwork |
Konfigurasi sink
Parameter | Konfigurasi |
InstanceId | Nilai: "rmq-cn-xxx", Bentuk: "CONSTANT" |
Topic | Nilai: "test_perf", Bentuk: "CONSTANT" |
Body | Nilai: "$.data.body", Bentuk: "BINARY_EXTRACTION" |
Properties | Nilai: "{\"userProperties\":\"$.data.userProperties\",\"msgId\":\"$.data.systemProperties.UNIQ_KEY\"}" Bentuk: "TEMPLATE" Template: "{\"EB_SYS_EMBED_OBJECT\":\"${userProperties}\",\"UNIQ_KEY\":\"${msgId}\"}" |
Keys | Nilai: "$.data.systemProperties.KEYS", Bentuk: "JSONPATH" |
Tags | Nilai: "$.data.systemProperties.TAGS", Bentuk: "JSONPATH" |
InstanceType | Nilai: "SelfBuilt", Bentuk: "CONSTANT" |
VpcId | Nilai: "vpc-xxx", Bentuk: "CONSTANT" |
VSwitchIds | Nilai: "vsw-xxx", Bentuk: "CONSTANT" |
SecurityGroupId | Nilai: "sg-xxx", Bentuk: "CONSTANT" |
InstanceUsername | Nilai: "xxx", Bentuk: "CONSTANT" |
InstancePassword | Nilai: "xxx", Bentuk: "CONSTANT" |
DeliveryOrderType | Nilai: "Concurrently", Bentuk: "CONSTANT" |
Network | Nilai: "PrivateNetwork", Bentuk: "CONSTANT" |
InstanceEndpoint | Nilai: "rmq-cn-xxx-vpc.cn-hangzhou.rmq.aliyuncs.com:8080", Bentuk: "CONSTANT" |
Konfigurasi lanjutan
Parameter | Nilai |
ErrorsTolerance | NONE |
RetryStrategy | PushRetryStrategy: "EXPONENTIAL_DECAY_RETRY" |
BusinessOption | BusinessMode: "CapacityUnitMode" MaxCapacityUnitCount: "4" MinCapacityUnitCount: "4" |
Metode pengujian
Dalam pengujian ini, pesan berukuran 1 KB dengan konten acak dikirim satu per satu ke topik hulu.
Hasil pengujian
Minimum CUs | CUs maksimum | Laju pemrosesan event (event/detik) | Latensi (ms) |
1 | 1 | 500 | Sekitar 150 |
2 | 2 | 1.000 | 110-180 |
3 | 3 | 1.500 | 125-218 |
4 | 4 | 2.000 | 140-218 |