Menulis fungsi Lambda yang mendukung streaming respons

Menulis handler untuk fungsi streaming respons berbeda dari pola handler biasa. Saat menulis fungsi streaming, pastikan untuk melakukan hal berikut:

Mengkonfigurasi fungsi handler untuk mengalirkan respons

Untuk menunjukkan ke runtime bahwa Lambda harus mengalirkan respons fungsi Anda, Anda harus membungkus fungsi Anda dengan streamifyResponse() dekorator. Ini memberi tahu runtime untuk menggunakan jalur logika yang tepat untuk respons streaming dan memungkinkan fungsi untuk mengalirkan respons.

streamifyResponse()Dekorator menerima fungsi yang menerima parameter berikut:

responseStreamObjeknya adalah Node.js writableStream. Seperti halnya aliran seperti itu, Anda harus menggunakan pipeline() metode ini.

const pipeline = require("util").promisify(require("stream").pipeline);
const { Readable } = require('stream');

exports.echo = awslambda.streamifyResponse(async (event, responseStream, _context) => {
  // As an example, convert event to a readable stream.
  const requestStream = Readable.from(Buffer.from(JSON.stringify(event)));

  await pipeline(requestStream, responseStream);
});

Meskipun responseStream menawarkan write() metode untuk menulis ke aliran, kami sarankan Anda menggunakannya pipeline()sedapat mungkin. Menggunakan pipeline() memastikan bahwa aliran yang dapat ditulis tidak kewalahan oleh aliran yang dapat dibaca lebih cepat.

Mengakhiri aliran

Pastikan Anda mengakhiri aliran dengan benar sebelum handler kembali. pipeline()Metode ini menangani ini secara otomatis.

Untuk kasus penggunaan lainnya, panggil responseStream.end() metode untuk mengakhiri aliran dengan benar. Metode ini menandakan bahwa tidak ada lagi data yang harus ditulis ke aliran. Metode ini tidak diperlukan jika Anda menulis ke aliran dengan pipeline() ataupipe().

const pipeline = require("util").promisify(require("stream").pipeline);

exports.handler = awslambda.streamifyResponse(async (event, responseStream, _context) => {
  await pipeline(requestStream, responseStream);
});

exports.handler = awslambda.streamifyResponse(async (event, responseStream, _context) => {
  responseStream.write("Hello ");
  responseStream.write("world ");
  responseStream.write("from ");
  responseStream.write("Lambda!");
  responseStream.end();
});