使用firebase云功能将图像保存到gcloud

问题描述 投票:0回答:1

我想在云功能中从unsplash保存一个选定的图像 - 在后台运行它。这是我的代码:

export const getUnsplashCron = functions
  .region('europe-west1')
  .runWith({ memory: '512MB', timeoutSeconds: 15 })
  .https.onRequest(async(req, res) => {

    if (!req.query.url) {
      res.status(300).send('no url');
    }

    return request({
      url: req.query.url + '?client_id=' + environment.unsplash.appId,
      encoding: null
    }, (err, response, body) => {
      if (!err && response.statusCode === 200) {

        const stream = require('stream');
        const bufferStream = new stream.PassThrough();

        bufferStream.end(Buffer.from(body, 'base64'));

        const file = admin.storage().bucket().file('name.jpg');

        bufferStream.pipe(
          file.createWriteStream({
            public: true
          }))
          .on('error', function(error) {
            console.log(error);
            return res.status(500).send(error)
          })
          .on('finish', function() {

            const config: GetSignedUrlConfig = {
              action: 'read',
              expires: '01-01-2025'
            };
            file.getSignedUrl(config, function(error, url) {
              console.log(url);
              if (error) {
                return res.status(500).send(error);
              }
              return res.status(500).send(url);
            });

          });


      }
    });

  });

但是我得到了一个

错误:在Util.handleResp(/ srv / node_modules / @ google-cloud / common /)的Util.parseHttpRespBody(/ srv / node_modules / @ google-cloud / common / build /src/util.js:172:38)找不到build / src / util.js:116:117)atResponse上的retryRequest(/srv/node_modules/@google-cloud/common/build/src/util.js:404:22)(/ s​​rv / node_modules / retry-request /index.js:200:7)在/srv/node_modules/teeny-request/build/src/index.js:158:17 at at process._tickDomainCallback(internal / process / next_tick.js:229:7)代码: 404,错误:[{domain:'global',reason:'notFound',message:'Not Found'}],响应:未定义,消息:'Not Found'}

我究竟做错了什么?!

node.js google-cloud-functions gcloud
1个回答
0
投票

您应该使用promises来处理异步任务(例如对unsplash的HTTP调用或对Cloud Storage的写入)。默认情况下,request不会返回promise,因此您需要使用接口包装器来处理请求,例如request-promise

因此,您应该按如下方式修改代码:

const rp = require('request-promise');
.....

export const getUnsplashCron = functions
  .region('europe-west1')
  .runWith({ memory: '512MB', timeoutSeconds: 15 })
  .https.onRequest(async(req, res) => {

  .......

  const options = {
    uri: req.query.url + '?client_id=' + environment.unsplash.appId
  };

  rp(options)
    .then(response => {
      .... //Upload your file
      res.send('Success');
    })
    .catch(err => {
      // API call failed...
      res.status(500).send('Error': err);
    });
};

您可以观看此官方视频系列了解更多详情:https://firebase.google.com/docs/functions/video-series/(特别是3个名为“Learn JavaScript Promises”的视频)。

© www.soinside.com 2019 - 2024. All rights reserved.