Transformasi EventBridge masukan Amazon Pipes

<aws.pipes.pipe-arn>— Nama Sumber Daya Amazon (ARN) dari pipa.

<aws.pipes.pipe-name>— Nama pipa.

<aws.pipes.source-arn>— ARN dari sumber peristiwa pipa.

<aws.pipes.enrichment-arn>— ARN pengayaan pipa.

<aws.pipes.target-arn>— ARN target pipa.

<aws.pipes.event.ingestion-time>- Waktu di mana acara diterima oleh transformator input. Ini adalah stempel waktu ISO 8601. Waktu ini berbeda untuk transformator input pengayaan dan transformator input target, tergantung pada kapan pengayaan selesai memproses acara.

<aws.pipes.event>— Acara seperti yang diterima oleh transformator input.

Untuk transformator input pengayaan, ini adalah peristiwa dari sumbernya. Ini berisi payload asli dari sumber, ditambah metadata khusus layanan tambahan. Lihat topik di Sumber EventBridge Pipa Amazon untuk contoh khusus layanan.

Untuk transformator input target, ini adalah peristiwa yang dikembalikan oleh pengayaan, jika dikonfigurasi, tanpa metadata tambahan. Dengan demikian, muatan yang dikembalikan pengayaan mungkin non-JSON. Jika tidak ada pengayaan yang dikonfigurasi pada pipa, ini adalah peristiwa dari sumber dengan metadata.

<aws.pipes.event.json>— Sama sepertiaws.pipes.event, tetapi variabel hanya memiliki nilai jika muatan asli, baik dari sumber atau dikembalikan oleh pengayaan, adalah JSON. Jika pipa memiliki bidang yang dikodekan, seperti bidang Amazon SQS atau Kinesisdata, body bidang tersebut diterjemahkan dan diubah menjadi JSON yang valid. Karena tidak lolos, variabel hanya dapat digunakan sebagai nilai untuk bidang JSON. Untuk informasi selengkapnya, lihat Penguraian data tubuh implisit.

MQ aktif — data

Kinesis — data

Amazon MSK — dan key value

Kelinci MQ — data

Apache Kafka yang dikelola sendiri; — dan key value

Amazon SQS — body

Untuk String, tanda kutip diperlukan.

Tidak ada validasi saat membuat jalur JSON untuk templat Anda.

Jika Anda menentukan variabel untuk mencocokkan jalur JSON yang tidak ada dalam acara, EventBridge ganti variabel itu dengan string kosong. EventBridge menyertakan kunci dalam output dengan nilai string kosong alih-alih menghilangkannya.

Properti JSON seperti hanya aws.pipes.event.json dapat digunakan sebagai nilai bidang JSON, bukan sebaris dalam string lain.

EventBridge tidak lu put dari nilai yang diekstraksi oleh Jal ur Input, saat mengisi Template Input untuk target.

Jika jalur JSON mereferensikan objek atau array JSON, tetapi variabel direferensikan dalam string, EventBridge menghapus tanda kutip internal untuk memastikan string yang valid. Misalnya, “Body is <$.body>” akan menghasilkan penghapusan tanda kutip dari EventBridge objek.

Oleh karena itu, jika Anda ingin menampilkan objek JSON berdasarkan variabel jalur JSON tunggal, Anda harus menempatkannya sebagai kunci. Dalam contoh ini,{"body": <$.body>}.

Kutipan tidak diperlukan untuk variabel yang mewakili string. Mereka diizinkan, tetapi Pip EventBridge es secara otomatis menambahkan tanda kutip ke nilai variabel string selama transformasi, untuk memastikan output transformasi adalah JSON yang valid. EventBridge Pipes tidak menambahkan tanda kutip ke variabel yang mewakili objek JSON atau array. Jangan menambahkan tanda kutip untuk variabel yang mewakili objek JSON atau array.

Misalnya, template input berikut menyertakan variabel yang mewakili string dan objek JSON:

{
  "pipeArn" : <aws.pipes.pipe-arn>,
  "pipeName" : <aws.pipes.pipe-name>,
  "originalEvent" : <aws.pipes.event.json>
}

Menghasilkan JSON yang valid dengan kutipan yang tepat:

{
  "pipeArn" : "arn:aws:events:us-east-2:123456789012:pipe/example",
  "pipeName" : "example",
  "originalEvent" : {
    ... // commented for brevity
  }
}

Untuk pengayaan atau target Lambda atau Step Functions, batch dikirim ke target sebagai array JSON, bahkan jika ukuran batch adalah 1. Namun, transformator input masih akan diterapkan ke catatan individu dalam JSON Array, bukan array secara keseluruhan. Untuk informasi selengkapnya, lihat Pengelompokan dan konkurensi EventBridge Pipa Amazon.

Transformator input dan penyaringan dapat mengekstrak nilai JSON yang telah dikodekan string sekali, tetapi bukan nilai yang telah dikodekan string dua kali. Hal ini biasanya terjadi ketika pesan Amazon SNS dikirim ke Amazon SQS. Ketika Amazon SQS menerima pesan Amazon SNS, itu merangkai seluruh pesan. Ketika Pipes kemudian menerima pesan Amazon SQS ini, konten pesan Amazon SNS muncul di body lapangan dan dapat diakses. Namun, jika Message bidang Amazon SNS itu sendiri berisi JSON yang disatukan, konten bersarang itu dikodekan ganda dan tidak dapat diakses oleh transformator atau filter input. Misalnya, dapat <$.body.TopicArn> diakses, tetapi <$.body.Message.operation> tidak jika Message bidang berisi JSON berstringified seperti. "{\\\"operation\\\":\\\"UPDATE\\\",\\\"email\\\":\\\"user@example.com\\\"}"

Untuk mengatasi batasan ini, gunakan langkah pengayaan dengan fungsi Lambda untuk mengurai konten yang dikodekan ganda dan mengekstrak nilai bersarang. Untuk informasi lebih lanjut tentang pengayaan, lihatPengayaan.