在 Lambda@Edge 源请求函数中替换 body 时出现验证错误
Validation error when I replace body in Lambda@Edge origin request function
我在提供 HLS 视频的 s3 存储桶前面有 Cloudfront。我正在尝试动态修改清单文件以将身份验证令牌添加到其中的段。
我真正想做的是修改 body 我在查看器响应函数中发送回客户端,但由于这是不可能的,我正在尝试使用原始请求函数从 S3 手动获取 object,修改它,然后 return 使用新 body 的 Cloudfront 请求。我收到 "The Lambda function result failed validation: The body is not a string, is not an object, or exceeds the maximum size"
的 503 错误
我的 body 小于 8kb(1MB 是文档中的限制)。据我所知,我生成的云端请求 object 看起来不错,base64 数据解码为我想要的。我也尝试过使用文本而不是 base64。我在 Cloudfront 中启用了 "include body"。
const fs = require('fs');
const querystring = require('querystring');
const AWS = require('aws-sdk');
const S3 = new AWS.S3();
exports.handler = async (event) => {
const cfrequest = event.Records[0].cf.request;
const queryString = querystring.parse(event.Records[0].cf.request.querystring);
const jwtToken = queryString.token;
if (cfrequest.uri.match(/\.m3u8?$/mi)) {
const s3Response = await (new Promise((resolve, reject) => {
S3.getObject({
Bucket: 'bucket',
Key: cfrequest.uri.substring(1)
}, (err, data) => {
if (err) {
reject(err)
} else {
resolve(data);
}
});
}));
const manifestFile = s3Response.Body.toString('utf8');
const newManifest = manifestFile.replace(/^((\S+)\.(m3u8|ts|vtt))$/gmi, (_, url) => `${url}?token=${jwtToken}`);
const base64NewManifest = Buffer.from(newManifest, 'utf8').toString('base64');
const tokenizedCfRequest = {
...cfrequest,
body: {
action: 'replace',
data: base64NewManifest,
encoding: 'base64'
}
};
return tokenizedCfRequest;
}
return cfrequest;
}
如果您想生成自己的响应,您需要使用 查看器请求 或 源请求 事件和 return像这样的回应:
exports.handler = async (event) => {
const cfRequest = event.Records[0].cf.request;
const queryString = querystring.parse(event.Records[0].cf.request.querystring);
const jwtToken = queryString.token;
if (cfrequest.uri.match(/\.m3u8?$/mi)) {
// ... your code here ...
const response = {
status: 200, // only mandatory field
body: base64NewManifest,
bodyEncoding: 'base64',
};
return response;
}
// Return original request if no uri match
return cfRequest;
}
我在提供 HLS 视频的 s3 存储桶前面有 Cloudfront。我正在尝试动态修改清单文件以将身份验证令牌添加到其中的段。
我真正想做的是修改 body 我在查看器响应函数中发送回客户端,但由于这是不可能的,我正在尝试使用原始请求函数从 S3 手动获取 object,修改它,然后 return 使用新 body 的 Cloudfront 请求。我收到 "The Lambda function result failed validation: The body is not a string, is not an object, or exceeds the maximum size"
的 503 错误我的 body 小于 8kb(1MB 是文档中的限制)。据我所知,我生成的云端请求 object 看起来不错,base64 数据解码为我想要的。我也尝试过使用文本而不是 base64。我在 Cloudfront 中启用了 "include body"。
const fs = require('fs');
const querystring = require('querystring');
const AWS = require('aws-sdk');
const S3 = new AWS.S3();
exports.handler = async (event) => {
const cfrequest = event.Records[0].cf.request;
const queryString = querystring.parse(event.Records[0].cf.request.querystring);
const jwtToken = queryString.token;
if (cfrequest.uri.match(/\.m3u8?$/mi)) {
const s3Response = await (new Promise((resolve, reject) => {
S3.getObject({
Bucket: 'bucket',
Key: cfrequest.uri.substring(1)
}, (err, data) => {
if (err) {
reject(err)
} else {
resolve(data);
}
});
}));
const manifestFile = s3Response.Body.toString('utf8');
const newManifest = manifestFile.replace(/^((\S+)\.(m3u8|ts|vtt))$/gmi, (_, url) => `${url}?token=${jwtToken}`);
const base64NewManifest = Buffer.from(newManifest, 'utf8').toString('base64');
const tokenizedCfRequest = {
...cfrequest,
body: {
action: 'replace',
data: base64NewManifest,
encoding: 'base64'
}
};
return tokenizedCfRequest;
}
return cfrequest;
}
如果您想生成自己的响应,您需要使用 查看器请求 或 源请求 事件和 return像这样的回应:
exports.handler = async (event) => {
const cfRequest = event.Records[0].cf.request;
const queryString = querystring.parse(event.Records[0].cf.request.querystring);
const jwtToken = queryString.token;
if (cfrequest.uri.match(/\.m3u8?$/mi)) {
// ... your code here ...
const response = {
status: 200, // only mandatory field
body: base64NewManifest,
bodyEncoding: 'base64',
};
return response;
}
// Return original request if no uri match
return cfRequest;
}