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
-
Aliran Kinesis
-
Kueri API data cluster pergeseran merah
-
SageMaker Saluran 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 muatan peristiwa ke target, sebaliknya, mereka memperlakukan peristiwa sebagai pemicu untuk memanggil API tertentu. EventBridge menggunakan PipeTargetParameters untuk 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 menyertakan payload 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 menyertakan payload acara asli, rujuk diInputTemplate.) -
PipeTargetRedshiftDataParameters(Cluster API Data Amazon Redshift) -
PipeTargetSageMakerPipelineParameters(Pipa SageMaker Pembuatan Model 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
karakter pengganti (*)
garis miring ke depan
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, bukan hanya sebagian darinya. Misalnya, RedshiftParameters.Sql bisa $.detail.state tetapi tidak bisa"SELECT * FROM $.detail.state". Jalur ini diganti secara dinamis saat runtime dengan data dari muatan peristiwa itu sendiri di jalur yang ditentukan. Parameter jalur dinamis tidak dapat mereferensikan nilai baru atau diubah yang dihasilkan dari transformasi input. Sintaks yang didukung untuk jalur JSON parameter dinamis sama seperti saat mengubah input. Untuk informasi selengkapnya, lihat Transformasi EventBridge masukan Amazon Pipes.
Sintaks dinamis dapat digunakan pada semua string, bidang non-enum dari semua parameter pengayaan EventBridge Pipa dan target kecuali:
Misalnya, untuk menyetel PartitionKey target pipa Kinesis ke kunci kustom dari peristiwa sumber Anda, setel KinesisTargetParameter.PartitionKey ke:
-
"$.data.untuk sumber KinesissomeKey" -
"$.body.untuk sumber Amazon SQSsomeKey"
Kemudian, jika payload peristiwa adalah string JSON yang valid, seperti{", EventBridge ekstrak nilai dari jalur JSON dan menggunakannya sebagai parameter target. Dalam contoh ini, EventBridge akan mengatur Kinesis someKey":"someValue"}PartitionKey ke "someValue”.
Izin
Untuk melakukan panggilan API pada sumber daya yang Anda miliki, Pip EventBridge es memerlukan izin yang sesuai. EventBridge PIPes menggunakan peran IAM yang Anda tentukan pada pipa untuk pengayaan dan panggilan target menggunakan prinsip IAM. pipes.amazonaws.com
Memanggil target
EventBridge memiliki cara berikut untuk memanggil target:
-
Secara sinkron (tipe pemanggilan dis
REQUEST_RESPONSEetel ke) EventBridge — menunggu respons dari target sebelum melanjutkan. -
Asinkron (tipe pemanggilan diset
FIRE_AND_FORGETel ke) - EventBridge tidak menunggu respons sebelum melanjutkan.
Secara default, untuk pipa dengan sumber yang dipesan, EventBridge memanggil target secara sinkron karena respons dari target diperlukan sebelum melanjutkan ke acara berikutnya.
Jika sumber tidak menerapkan perintah, seperti antrian Amazon SQS standar, EventBridge dapat memanggil target yang didukung secara sinkron atau asinkron.
Dengan fungsi Lambda dan mesin status Fungsi Langkah, Anda dapat mengonfigurasi jenis pemanggilan.
catatan
Untuk mesin status Fungsi Langkah, 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 1 MB, sehingga batas efektif untuk pipa yang menargetkan bus acara adalah 1 MB.
-
Step Functions state machine mendukung payload 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 spesifikasi target antrian pekerjaan
Semua AWS Batch submitJob parameter dikonfigurasi secara eksplisit denganBatchParameters, dan seperti semua parameter Pipe, ini dapat dinamis menggunakan jalur JSON ke muatan acara masuk Anda.
CloudWatch Login 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 melaluiEcsParameters. Seperti semua parameter pipa, parameter ini dapat dinamis saat menggunakan jalur JSON ke muatan acara masuk Anda.
Fungsi Lambda dan spesifikasi target alur kerja Fungsi Langkah
Lambda dan Step Functions tidak memiliki API batch. Untuk memproses kumpulan 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 percobaan ulang.
Untuk informasi selengkapnya, lihat Mengonfigurasi pengaturan alur.
EventBridge spesifikasi 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 PipeTargetEventBridgeEventBusParameters untuk mengonfigurasi acara source dan detail-type bidang. Kedua bidang mendukung sintaks jalur JSON dinamis untuk mengekstrak nilai dari muatan 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 EventBridge masukan Amazon Pipes.
