Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Target Amazon EventBridge Pipes
Anda dapat mengirim data dalam pipa Anda ke target tertentu. Anda dapat mengonfigurasi target berikut saat menyiapkan pipa di EventBridge:
-
Aliran pengiriman Firehose
-
Templat penilaian Inspector
-
Aliran kinesis
-
Kueri API data klaster Redshift
-
SageMaker Pipa AI
-
Topik Amazon SNS (topik SNS FIFO tidak didukung)
-
Antrean Amazon SQS
-
-
Alur kerja ekspres (SYNC atau ASYNC)
-
Alur kerja standar (ASYNC)
-
Parameter terget
Beberapa layanan target tidak mengirim payload acara ke target, sebaliknya, mereka memperlakukan acara sebagai pemicu untuk menjalankan API tertentu. EventBridge menggunakan PipeTargetParametersuntuk menentukan informasi apa yang dikirim ke API itu. Sumber daya yang dimaksud meliputi:
-
Tujuan API (Data yang dikirim ke tujuan API harus sesuai dengan struktur API. Anda harus menggunakan
InputTemplateobjek untuk memastikan data terstruktur dengan benar. Jika Anda ingin memasukkan muatan acara asli, rujuk diInputTemplate.) -
API Gateway (Data yang dikirim ke API Gateway harus sesuai dengan struktur API. Anda harus menggunakan
InputTemplateobjek untuk memastikan data terstruktur dengan benar. Jika Anda ingin memasukkan muatan acara asli, rujuk diInputTemplate.) -
PipeTargetRedshiftDataParameters(Cluster API Data Pergeseran Merah Amazon) -
PipeTargetSageMakerPipelineParameters(Pipa Pembuatan Model SageMaker Runtime Amazon) -
PipeTargetBatchJobParameters(AWS Batch)
catatan
EventBridge tidak mendukung semua sintaks JSON Path dan mengevaluasinya saat runtime. Sintaks yang didukung meliputi:
notasi titik (misalnya,
$.detail)tanda hubung
menggarisbawahi
karakter alfanumerik
indeks array
wildcard (*)
Parameter jalur dinamis
EventBridge Parameter target pipa mendukung sintaks jalur JSON dinamis opsional. Anda dapat menggunakan sintaks ini untuk menentukan jalur JSON alih-alih nilai statis (misalnya$.detail.state). Seluruh nilai harus berupa jalur JSON, tidak hanya sebagian saja. Misalnya, RedshiftParameters.Sql bisa $.detail.state tetapi tidak bisa"SELECT * FROM $.detail.state". Jalur ini diganti secara dinamis saat runtime dengan data dari payload acara itu sendiri di jalur yang ditentukan. Parameter jalur dinamis tidak dapat mereferensikan nilai baru atau yang diubah yang dihasilkan dari transformasi input. Sintaks yang didukung untuk jalur JSON parameter dinamis sama seperti saat mengubah input. Untuk informasi selengkapnya, lihat Transformasi masukan Amazon EventBridge Pipes.
Sintaks dinamis dapat digunakan pada semua string, bidang non-enum dari semua pengayaan EventBridge Pipa dan parameter target kecuali:
-
"$.data.untuk sumber KinesissomeKey" -
"$.body.untuk sumber Amazon SQSsomeKey"
Kemudian, jika payload acara adalah string JSON yang valid, seperti{", EventBridge mengekstrak nilai dari jalur JSON dan menggunakannya sebagai parameter target. Dalam contoh ini, EventBridge akan mengatur Kinesis someKey":"someValue"}PartitionKey menjadi "”someValue.
Izin
Untuk melakukan panggilan API pada sumber daya yang Anda miliki, EventBridge Pipes memerlukan izin yang sesuai. EventBridge PIpes menggunakan peran IAM yang Anda tentukan pada pipa untuk pengayaan dan panggilan target menggunakan prinsipal IAM. pipes.amazonaws.com
Memohon target
EventBridge memiliki cara berikut untuk memanggil target:
-
Synchronously (tipe pemanggilan disetel ke
REQUEST_RESPONSE) — EventBridge menunggu respons dari target sebelum melanjutkan. -
Secara asinkron (tipe pemanggilan disetel ke
FIRE_AND_FORGET) — EventBridge tidak menunggu respons sebelum melanjutkan.
Secara default, untuk pipa dengan sumber yang dipesan, EventBridge memanggil target secara serempak karena respons dari target diperlukan sebelum melanjutkan ke acara berikutnya.
Jika sumber tidak menerapkan urutan, seperti antrian EventBridge Amazon SQS standar, dapat memanggil target yang didukung secara sinkron atau asinkron.
Dengan fungsi Lambda dan mesin status Step Functions, Anda dapat mengonfigurasi jenis pemanggilan.
catatan
Untuk mesin status Step Functions, alur kerja Standar harus dipanggil secara asinkron.
Batas ukuran muatan
EventBridge Pipa mendukung muatan hingga 6 MB. Namun, batas ukuran muatan efektif ditentukan oleh mana yang lebih kecil: batas Pipa 6 MB atau ukuran muatan maksimum layanan target. Contoh:
-
Fungsi Lambda mendukung muatan hingga 6 MB, sehingga batas efektif untuk pipa yang menargetkan Lambda adalah 6 MB.
-
EventBridge bus acara mendukung muatan hingga 256 KB, sehingga batas efektif untuk pipa yang menargetkan bus acara adalah 256 KB.
-
Mesin status Step Functions mendukung muatan hingga 256 KB, sehingga batas efektif untuk pipa yang menargetkan Step Functions adalah 256 KB.
Saat mengonfigurasi pipa Anda, pastikan ukuran muatan Anda, termasuk transformasi apa pun yang diterapkan oleh pengayaan atau transformasi input, tidak melebihi ukuran muatan maksimum target.
AWS Batch antrian pekerjaan spesifik target
Semua AWS Batch submitJob parameter dikonfigurasi secara eksplisit denganBatchParameters, dan seperti semua parameter Pipe, parameter ini dapat dinamis menggunakan jalur JSON ke muatan acara masuk Anda.
CloudWatch Log spesifik target grup
Apakah Anda menggunakan transformator input atau tidak, muatan peristiwa digunakan sebagai pesan log. Anda dapat mengatur Timestamp (atau eksplisit LogStreamName tujuan Anda) melalui CloudWatchLogsParameters inPipeTarget. Seperti semua parameter pipa, parameter ini dapat dinamis saat menggunakan jalur JSON ke muatan acara masuk Anda.
Spesifikasi target tugas Amazon ECS
Semua runTask parameter Amazon ECS dikonfigurasi secara eksplisit melalui. EcsParameters Seperti semua parameter pipa, parameter ini dapat dinamis saat menggunakan jalur JSON ke muatan acara masuk Anda.
Fungsi Lambda dan spesifikasi target alur kerja Step Functions
Lambda dan Step Functions tidak memiliki API batch. Untuk memproses batch peristiwa dari sumber pipa, batch dikonversi ke array JSON dan diteruskan sebagai input ke target Lambda atau Step Functions. Untuk informasi selengkapnya, lihat Pengelompokan dan konkurensi EventBridge Pipa Amazon.
Timestream untuk spesifikasi target LiveAnalytics tabel
Pertimbangan saat menentukan LiveAnalytics tabel Timestream for sebagai target pipa meliputi:
-
Aliran Apache Kafka (termasuk dari Amazon MSK atau penyedia pihak ketiga) saat ini tidak didukung sebagai sumber pipa.
-
Jika Anda telah menentukan DynamoDB aliran Kinesis atau sebagai sumber pipa, Anda harus menentukan jumlah upaya coba lagi.
Untuk informasi selengkapnya, lihat Mengkonfigurasi pengaturan pipa.
EventBridge spesifik target bus acara
Saat Anda mengonfigurasi bus EventBridge acara sebagai target pipa, muatan dari pipa Anda secara otomatis ditempatkan di detail bagian EventBridge acara. Gunakan PipeTargetEventBridgeEventBusParametersuntuk mengkonfigurasi acara source dan detail-type bidang. Kedua bidang mendukung sintaks jalur JSON dinamis untuk mengekstrak nilai dari payload acara Anda. Misalnya, atur Source ke $.body.source atau DetailType ke$.data.eventType. Anda juga dapat menggunakan transformator input untuk memodifikasi struktur acara sebelum ditempatkan di detail lapangan. Lihat informasi yang lebih lengkap di Transformasi masukan Amazon EventBridge Pipes.
