用GraphicsMagick从远程流创建GIF

5
我目前正在使用node从远程文件创建GIF,通过将每个图像下载到文件系统中的tmp文件夹中。我希望绕过将图像保存到tmp文件夹中并改为在内存中保存。这种做法是否可行?正如您所看到的,我的AWS类中有一个下载函数,它将文件保存到tmp文件夹中。
download(key){
    return new Promise((resolve, reject) => {
      request.head(`${this.base_url}/${this.bucket}/${key}`, (err, res, body) => {
        request(`${this.base_url}/${this.bucket}/${key}`)
            .pipe(fs.createWriteStream(`tmp/${key}`)).on('close', resolve )
      })
    })
};

当所有文件都下载完毕后,我在GifService类中有一个createGif函数,它将每个文件路径作为gm的自定义参数添加,延迟50ms,调整大小,然后输出为缓冲区,最后上传至AWS s3。

import gm from 'gm';

...

constructor(){
    this.gm = gm()
}

generateGif(images, prefix){

    return new Promise((resolve, reject) => {

        // for each image we want in array, we pass to gm
        images.forEach(image => {
            this.gm.in(`tmp/${image.Key}`)
        })

        // Now we create the gif with 50sec delay between images, sized to 600px x 2
        this.gm
            .delay(50)
            .resize(600,600)
            .toBuffer('gif', async (err, buffer) => {
        if (err) reject(err)

        const params = {
                ACL: 'public-read',
                Bucket: config.aws_bucket,
                ContentType: 'image/gif',
                Key: `${prefix}/${uuid()}.gif`,
                Body: buffer
              }

              try{
                // uplaod to S3
            const upload = await this.aws.upload(params)

            // resolve s3 URL
            resolve(upload)

              }catch(err) {
                console.log('err', err)
                reject(err)
              }

      });
    })

}

理想情况下,如果我可以将远程文件流作为自定义参数传递,或者将缓冲区作为自定义参数传递,而不是使用当前的tmp文件路径进行传递。
images.forEach(image => {
    this.gm.in(`tmp/${image.Key}`)
})

我已经更新了我的帖子,展示了我如何实例化gm / graphicsmagick。 - Stretch0
1个回答

1
我成功地使用了流(streams)来实现,首先将图片转换为miff格式并将它们连接成单个流,然后再次将缓冲区(buffer)或流(stream)传递到gm中,并使用延迟(delay)即可完成操作。为使此方法生效,您需要安装concat-stream npm。
对于混合的ES5代码,抱歉。
import gm from 'gm';
var concat = require('concat-stream');
...

constructor() {
    this.gm = gm()
}

start() {

    return getYourReadAbleStreamsSomehow().then(streams => {

        return generateGif(streams);

    }).then(gifBuffer => {

        return uploadToAWS(gifBuffer, prefix);

    }).catch(err => {
        console.log(err)
    })

}

uploadToAWS(buffer, prefix) {
    const params = {
        ACL: 'public-read',
        Bucket: config.aws_bucket,
        ContentType: 'image/gif',
        Key: `${prefix}/${uuid()}.gif`,
        Body: buffer
    }

    try {
        // uplaod to S3
        const upload = await this.aws.upload(params)

        // resolve s3 URL
        resolve(upload)

    } catch (err) {
        console.log('err', err)
        reject(err)
    }
}

generateGif(imageStreams, delay) {

    return new Promise((resolve, reject) => {

        var write = concat(function(buffer) {
            gm(buffer)
                .delay(delay)
                .toBuffer('gif', function(err, buffer) {

                    if (err) 
                        reject(err);

                    resolve(buffer);

                })
        })

        //Convert to miff and concat streams
        var i = 0;
        var streamHandler = function() {

            gm(imageStreams[i])
                .resize('600', '600')
                .stream('miff', function(err, stdout, stderr) {
                    if (err)
                        reject(err)

                    var lastOne = i === streams.length - 1;

                    if (!lastOne)
                        stdout.once('end', streamHandler)

                    stdout.pipe(write, {
                        end: lastOne
                    });

                    i++;

                });
        }

        streamHandler();

    })

}

请纠正我,但本质上streamHandler是将所有原始图像缓冲区创建为1个流吗? - Stretch0
是的,它将每个图像转换为MIFF格式,然后可以用于转换为GIF格式。我尝试使用PNG,但它不起作用。如果您已经解决了这个问题,请告诉我。 - Stamos

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接