寻求支持AWS Lambda Proxy Integration的Node.js FormData解析与HTTPS发送库及示例代码

Hey there! I’ve got you covered on this—handling FormData with file uploads in AWS Lambda Proxy Integration using Node.js is totally doable, and I’ll walk you through the best tools and a full, runnable example.

• busboy: This is the go-to lightweight, streaming parser for multipart/form-data requests. It’s ideal for Lambda because it processes data in chunks instead of loading the entire file into memory, which helps avoid hitting memory limits.
• form-data: Once you’ve parsed and processed the incoming data, this library lets you construct a new FormData payload to send via HTTPS, which matches exactly what you need.

Here’s a complete Lambda function that parses incoming FormData (including files) from a Proxy Integration event, extracts the data, and sends the processed content via HTTPS:

const Busboy = require('busboy');
const FormData = require('form-data');
const https = require('https');

exports.handler = async (event) => {
  return new Promise((resolve, reject) => {
    // Parse Lambda Proxy event details
    const contentType = event.headers['Content-Type'] || event.headers['content-type'];
    const bodyBuffer = Buffer.from(event.body, event.isBase64Encoded ? 'base64' : 'utf8');

    // Configure Busboy for multipart parsing
    const busboy = Busboy({ headers: { 'content-type': contentType } });
    const formDataResult = { fields: {}, files: [] };

    // Capture regular form fields
    busboy.on('field', (name, value) => {
      formDataResult.fields[name] = value;
    });

    // Capture uploaded files and their metadata
    busboy.on('file', (name, file, info) => {
      const { filename, encoding, mimeType } = info;
      const fileChunks = [];

      file.on('data', (chunk) => fileChunks.push(chunk));
      file.on('end', () => {
        formDataResult.files.push({
          fieldName: name,
          filename,
          encoding,
          mimeType,
          content: Buffer.concat(fileChunks)
        });
      });
    });

    // Run post-parsing logic once Busboy finishes
    busboy.on('finish', async () => {
      try {
        // Log parsed data (customize processing here as needed)
        console.log('Parsed form fields:', formDataResult.fields);
        console.log('Uploaded files:', formDataResult.files.map(f => `${f.filename} (${f.mimeType})`));

        // Build outgoing FormData for HTTPS request
        const outgoingForm = new FormData();
        // Add parsed fields
        Object.entries(formDataResult.fields).forEach(([key, value]) => {
          outgoingForm.append(key, value);
        });
        // Add parsed files
        formDataResult.files.forEach(file => {
          outgoingForm.append(file.fieldName, file.content, {
            filename: file.filename,
            contentType: file.mimeType
          });
        });

        // Configure and send HTTPS request (replace with your target endpoint)
        const httpsRequestOptions = {
          method: 'POST',
          hostname: 'your-target-api.com',
          path: '/upload-processing',
          headers: outgoingForm.getHeaders()
        };

        await new Promise((reqResolve, reqReject) => {
          const req = https.request(httpsRequestOptions, (res) => {
            let responseBody = '';
            res.on('data', (chunk) => responseBody += chunk);
            res.on('end', () => {
              console.log('HTTPS request successful, response:', responseBody);
              reqResolve();
            });
          });

          req.on('error', (err) => reqReject(err));
          outgoingForm.pipe(req);
        });

        // Return success response to the original client
        resolve({
          statusCode: 200,
          body: JSON.stringify({
            message: 'Form data processed and forwarded successfully',
            receivedFields: formDataResult.fields,
            receivedFiles: formDataResult.files.map(f => f.filename)
          })
        });
      } catch (err) {
        console.error('Error processing request:', err);
        reject({
          statusCode: 500,
          body: JSON.stringify({ message: 'Failed to process request', error: err.message })
        });
      }
    });

    // Start parsing the request body
    busboy.end(bodyBuffer);
  });
};

• Install Dependencies: Before deploying your Lambda, run this in your project directory to add the required packages:

  npm install busboy form-data
  

• Lambda Configuration:
  • Boost memory allocation (minimum 256MB, adjust based on average file size) to avoid memory issues during file processing.
  • Set a timeout of 10-15 seconds to account for HTTPS request latency.
• API Gateway Setup: Double-check that your API Gateway is configured as a Lambda Proxy Integration—this ensures the full request details (headers, encoded body, etc.) are passed to your function.

内容的提问来源于stack exchange，提问作者Alvin Quezon