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:
+ [Tujuan API](eb-api-destinations.md)
+ [API Gateway](eb-api-gateway-target.md)
+ [Antrian pekerjaan batch](#pipes-targets-specifics-batch)
+ [CloudWatch grup log](#pipes-targets-specifics-cwl)
+ [Tugas ECS](#pipes-targets-specifics-ecs-task)
+ [Bus acara di akun dan Wilayah yang sama](#pipes-targets-specifics-eventbridge)
+ Aliran pengiriman Firehose
+ Templat penilaian Inspector
+ Aliran kinesis
+ [Fungsi Lambda (SYNC atau ASYNC)](#pipes-targets-specifics-lambda-stepfunctions)
+ Kueri API data klaster Redshift
+ SageMaker Pipa AI
+ Topik Amazon SNS (topik SNS FIFO tidak didukung)
+ Antrean Amazon SQS
+ [Mesin status Step Functions](#pipes-targets-specifics-lambda-stepfunctions)
+ Alur kerja ekspres (SYNC atau ASYNC)
+ Alur kerja standar (ASYNC)
+ [Timestream untuk LiveAnalytics meja](#pipes-targets-specifics-timestream)
## Parameter terget
Beberapa layanan target tidak mengirim muatan acara ke target, sebaliknya, mereka memperlakukan acara sebagai pemicu untuk menjalankan API tertentu. EventBridge menggunakan [https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetParameters.html](https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetParameters.html)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 [https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetParameters.html#pipes-Type-PipeTargetParameters-InputTemplate](https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetParameters.html#pipes-Type-PipeTargetParameters-InputTemplate)objek untuk memastikan data terstruktur dengan benar. Jika Anda ingin memasukkan muatan acara asli, rujuk di [https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetParameters.html#pipes-Type-PipeTargetParameters-InputTemplate](https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetParameters.html#pipes-Type-PipeTargetParameters-InputTemplate).)
+ API Gateway (Data yang dikirim ke API Gateway harus sesuai dengan struktur API. Anda harus menggunakan [https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetParameters.html#pipes-Type-PipeTargetParameters-InputTemplate](https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetParameters.html#pipes-Type-PipeTargetParameters-InputTemplate)objek untuk memastikan data terstruktur dengan benar. Jika Anda ingin memasukkan muatan acara asli, rujuk di [https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetParameters.html#pipes-Type-PipeTargetParameters-InputTemplate](https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetParameters.html#pipes-Type-PipeTargetParameters-InputTemplate).)
+ [https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetRedshiftDataParameters.html](https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetRedshiftDataParameters.html)(Cluster API Data Amazon Redshift)
+ [https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetSageMakerPipelineParameters.html](https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetSageMakerPipelineParameters.html)(Pipa Pembuatan Model SageMaker Runtime Amazon)
+ [https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetBatchJobParameters.html](https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetBatchJobParameters.html) (AWS Batch)
**catatan**
EventBridge tidak mendukung semua sintaks JSON Path dan mengevaluasinya saat runtime. Sintaks yang didukung meliputi:
notasi titik (misalnya,`$.detail`)
garis putus-putus
menggarisbawahi
karakter alfanumerik
indeks array
wildcard (\*)
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, 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](eb-pipes-input-transformation.md).
Sintaks dinamis dapat digunakan pada semua string, bidang non-enum dari semua pengayaan EventBridge Pipa dan parameter target kecuali:
+ [https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetCloudWatchLogsParameters.html](https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetCloudWatchLogsParameters.html)
+ [https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetEventBridgeEventBusParameters.html](https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetEventBridgeEventBusParameters.html)
+ [https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeEnrichmentHttpParameters.html](https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeEnrichmentHttpParameters.html)
+ [https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetHttpParameters.html](https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetHttpParameters.html)
[Misalnya, untuk mengatur target Kinesis pipa ke kunci khusus dari peristiwa sumber Anda, atur. `PartitionKey` KinesisTargetParameter PartitionKey](https://docs.aws.amazon.com/)ke:
+ `"$.data.{{someKey}}"`untuk sumber Kinesis
+ `"$.body.{{someKey}}"`untuk sumber Amazon SQS
Kemudian, jika payload acara adalah string JSON yang valid, seperti`{"{{someKey}}":"{{someValue}}"}`, EventBridge mengekstrak nilai dari jalur JSON dan menggunakannya sebagai parameter target. Dalam contoh ini, EventBridge akan mengatur Kinesis `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`
## 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 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](https://docs.aws.amazon.com/step-functions/latest/dg/concepts-standard-vs-express.html) 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.
+ 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`BatchParameters`, 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` in`PipeTarget`. 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](eb-pipes-batching-concurrency.md).
## 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](eb-pipes-create.md#pipes-configure-pipe-settings).
## 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 [https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetEventBridgeEventBusParameters.html](https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/API_PipeTargetEventBridgeEventBusParameters.html)untuk 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](eb-pipes-input-transformation.md).