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:
-
Bus acara di akun dan Wilayah yang sama
-
Aliran pengiriman Firehose
-
Templat penilaian Inspector
-
Aliran kinesis
-
Kueri data klaster Redshift API
-
SageMaker Pipa
-
SNSTopik Amazon (SNSFIFOtopik tidak didukung)
-
SQSAntrian Amazon
-
-
Alur kerja ekspres (SYNCatauASYNC)
-
Alur kerja standar () ASYNC
-
Parameter terget
Beberapa layanan target tidak mengirim muatan acara ke target, sebaliknya, mereka memperlakukan acara sebagai pemicu untuk memanggil spesifik. API EventBridge menggunakan PipeTargetParametersuntuk menentukan informasi apa yang dikirim ke ituAPI. Sumber daya yang dimaksud meliputi:
-
APItujuan (Data yang dikirim ke API tujuan harus sesuai dengan strukturAPI. Anda harus menggunakan
InputTemplateobjek untuk memastikan data terstruktur dengan benar. Jika Anda ingin memasukkan muatan acara asli, rujuk diInputTemplate.) -
APIGateway (Data yang dikirim ke API Gateway harus sesuai dengan strukturAPI. Anda harus menggunakan
InputTemplateobjek untuk memastikan data terstruktur dengan benar. Jika Anda ingin memasukkan muatan acara asli, rujuk diInputTemplate.) -
PipeTargetRedshiftDataParameters(Cluster Data API 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 JSON jalur dinamis opsional. Anda dapat menggunakan sintaks ini untuk menentukan JSON jalur alih-alih nilai statis (misalnya$.detail.state). Seluruh nilai harus menjadi JSON jalan, bukan hanya bagian darinya. 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 JSON jalur 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 SQS sumber AmazonsomeKey"
Kemudian, jika payload acara adalah JSON string yang valid, seperti{", EventBridge mengekstrak nilai dari JSON jalur dan menggunakannya sebagai parameter target. Dalam contoh ini, EventBridge akan mengatur Kinesis someKey":"someValue"}PartitionKey menjadi”someValue".
Izin
Untuk melakukan API panggilan pada sumber daya yang Anda miliki, EventBridge Pipes memerlukan izin yang sesuai. EventBridge PIpesmenggunakan IAM peran yang Anda tentukan pada pipa untuk pengayaan dan panggilan target menggunakan prinsipal. IAM pipes.amazonaws.com
Memanggil target
EventBridge memiliki cara berikut untuk memanggil target:
-
Synchronously (tipe pemanggilan diatur 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 SQS antrian Amazon standar, EventBridge 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.
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 JSON jalur 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 JSON jalur ke muatan acara masuk Anda.
Spesifik target ECS tugas Amazon
Semua ECS runTask parameter Amazon dikonfigurasi secara eksplisit melalui. EcsParameters Seperti semua parameter pipa, parameter ini dapat dinamis saat menggunakan JSON jalur ke muatan acara masuk Anda.
Fungsi Lambda dan spesifikasi target alur kerja Step Functions
Lambda dan Step Functions tidak memiliki batch. API Untuk memproses batch peristiwa dari sumber pipa, batch dikonversi ke JSON array 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.
