我想在云功能中从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)(/ srv / 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'}
我究竟做错了什么?!
您应该使用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”的视频)。