Skip to content

Instantly share code, notes, and snippets.

@identiq identiq/Gif.js
Created Nov 25, 2018

Embed
What would you like to do?
Video preview generation (like giphy) with FFMPEG (ffmpeg-fluent) on node Serverless Lambda
const config = require('../config.json');
const fs = require('fs');
const _ = require('lodash');
const path = require('path');
const ffmpegPath = require('@ffmpeg-installer/ffmpeg').path;
const ffmpeg = require('fluent-ffmpeg');
ffmpeg.setFfmpegPath(ffmpegPath);
const AWS = require('aws-sdk');
const s3 = new AWS.S3({
accessKeyId: config.AWS_ACCESS_KEY_ID,
secretAccessKey: config.AWS_SECRET_ACCESS_KEY,
useAccelerateEndpoint: true,
});
const TMP_PATH = process.env.TMP_PATH;
module.exports = {
async giphy(event) {
for (const record of event.Records) {
await handleRecord(record.s3);
}
},
};
async function handleRecord(record) {
const key = record.object.key;
const videoPath = await downloadFile(key);
try {
const res = await ffmpegToGif(videoPath, key);
console.log('ffmpegToGif', res);
} catch (err) {
console.error(err);
}
}
function downloadFile(key) {
return new Promise((resolve, reject) => {
const destPath = `${TMP_PATH}/${path.basename(key)}`
const params = {
Bucket: process.env.S3_BUCKET_NAME,
Key: key
}
const s3Stream = s3.getObject(params).createReadStream();
const fileStream = fs.createWriteStream(destPath);
s3Stream.on('error', reject);
fileStream.on('error', reject);
fileStream.on('close', () => {
resolve(destPath);
});
s3Stream.pipe(fileStream);
});
}
function ffmpegToGif(videoPath, key) {
return new Promise((resolve, reject) => {
const filename = _.first(path.basename(key).split('.'));
const bucketPath = _.first(key.split('.'));
ffmpeg(videoPath)
.inputOptions(['-t 2.5', '-ss 61.0'])
.complexFilter('[0:v]palettegen')
.on('end', () => {
ffmpeg(videoPath)
.inputOptions(['-t 2.5', '-ss 61.0'])
.addInput(`${TMP_PATH}/${filename}.png`)
.complexFilter(['[0:v][1:v]paletteuse'])
.on('end', async () => {
const gif = fs.createReadStream(`${TMP_PATH}/${filename}.gif`);
const res = await s3.putObject({
Bucket: process.env.S3_BUCKET_NAME,
Key: bucketPath + '.gif',
Body: gif,
ContentType: 'image/gif'
}).promise();
resolve(res)
})
.on('error', err => {
reject(err);
})
.save(`${TMP_PATH}/${filename}.gif`);
})
.on('error', err => {
reject(err);
})
.save(`${TMP_PATH}/${filename}.png`);
});
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.