AWS CloudWatch 日志订阅过滤器解码
AWS CloudWatch log subscription filters decode
我正在使用 CloudWatch 日志订阅过滤器流式传输到 Lambda 并将消息发布到 SNS 主题。但是会输出乱码,解码不成功
我的输出:
k
%"
jVbB
如果不解码会输出如下:
{ "awslogs": {"data": "BASE64ENCODED_GZIP_COMPRESSED_DATA"} }
我的代码在下面,它使用的是 nodejs:
console.log("Loading function");
var AWS = require("aws-sdk");
exports.handler = function(event, context) {
var eventText = JSON.stringify(event, null, 2);
var decodeText = new Buffer(eventText, 'base64').toString('ascii');
console.log("Received event:", eventText);
var sns = new AWS.SNS();
var params = {
Message: decodeText,
Subject: "Test SNS From Lambda",
TopicArn: "arn:aws:sns:region:account:snsTopic"
};
sns.publish(params, context.done);
};
CloudWatch Logs 以 gzip 压缩和 base64 编码的列表的形式传送到订阅的 Lambda 函数。
以下是如何解码和解压缩日志列表的示例:
const zlib = require('zlib');
exports.handler = async (event, context) => {
if (event.awslogs && event.awslogs.data) {
const payload = Buffer.from(event.awslogs.data, 'base64');
const logevents = JSON.parse(zlib.unzipSync(payload).toString()).logEvents;
for (const logevent of logevents) {
const log = JSON.parse(logevent.message);
console.log(log);
}
}
};
我正在使用 CloudWatch 日志订阅过滤器流式传输到 Lambda 并将消息发布到 SNS 主题。但是会输出乱码,解码不成功
我的输出:
k
%"
jVbB
如果不解码会输出如下:
{ "awslogs": {"data": "BASE64ENCODED_GZIP_COMPRESSED_DATA"} }
我的代码在下面,它使用的是 nodejs:
console.log("Loading function");
var AWS = require("aws-sdk");
exports.handler = function(event, context) {
var eventText = JSON.stringify(event, null, 2);
var decodeText = new Buffer(eventText, 'base64').toString('ascii');
console.log("Received event:", eventText);
var sns = new AWS.SNS();
var params = {
Message: decodeText,
Subject: "Test SNS From Lambda",
TopicArn: "arn:aws:sns:region:account:snsTopic"
};
sns.publish(params, context.done);
};
CloudWatch Logs 以 gzip 压缩和 base64 编码的列表的形式传送到订阅的 Lambda 函数。
以下是如何解码和解压缩日志列表的示例:
const zlib = require('zlib');
exports.handler = async (event, context) => {
if (event.awslogs && event.awslogs.data) {
const payload = Buffer.from(event.awslogs.data, 'base64');
const logevents = JSON.parse(zlib.unzipSync(payload).toString()).logEvents;
for (const logevent of logevents) {
const log = JSON.parse(logevent.message);
console.log(log);
}
}
};