CloudWatch Logs サブスクリプションフィルタにより Lambda に流れ込むイベントのデータをデコードする

CloudWatch Logs サブスクリプションフィルタの使用 に書かれているように CloudWatch Logs のサブスクリプションフィルタにより Lambda 関数が起動するときのペイロードの Data は Base64 でエンコード + gzip 圧縮されている。

Lambda レコードの Data 属性は、Base64 でエンコードされており、gzip 形式で圧縮されています。Lambda が受け取る実際のペイロードは、{ “awslogs”: {“data”: “BASE64ENCODED_GZIP_COMPRESSED_DATA”} } の形式になります。raw データは、コマンドラインから次の UNIX コマンドを使用して調べることができます。

これを解く簡単なコードをよく使うのでメモとして残しておく。

const zlib = require('zlib');
const unzip = b => new Promise(resolve => {
    const base64Logs = new Buffer(b, 'base64');
    zlib.gunzip(base64Logs, function (err, bin) {
        if (err != null) throw err;
        resolve(bin.toString('ascii'));
    });
});

exports.handler = async (event) => {
    const logs = await unzip(event['awslogs']['data']);
    const obj = JSON.parse(logs);
    console.log(obj);
    return obj;
};

async/await 好き…。