【发布时间】:2021-11-11 05:27:04
【问题描述】:
我正在尝试在 Firebase 中创建文档后创建集合和文档。
它在模拟器中运行良好,但是当我将我的函数部署到 Firebase 项目时,它们不会创建该集合和文档。
但如果我在现有文档(快照)中创建字段,它就可以工作。
在函数中,我从 API 获取数据并将其写入新文档(目前尚未创建)。
功能:
exports.quoteEndPoint = functions.firestore.document('users/{userID}/followedStocks/{stockID}')
.onCreate((snap, context) => {
const stock_id = context.params.stockID;
const user_id = context.params.userID;
var request = require('request');
var http = require('https');
const options = {
"method": "GET",
"hostname": "alpha-vantage.p.rapidapi.com",
"port": null,
"path": '/query?function=GLOBAL_QUOTE&symbol='+stock_id+'&datatype=json',
"headers": {
"x-rapidapi-host": "%API_HOST%",
"x-rapidapi-key": "%API_KEY%",
"useQueryString": true
}
};
const req = http.request(options, function(res){
const chunks = [];
res.on('data', function(chunk){
chunks.push(chunk);
});
res.on('end', function(){
const body = Buffer.concat(chunks);
//console.log(body.toString());
const result = JSON.parse(body.toString());
console.log(result);
//set values from json responso to Firebase
return snap.ref.collection('quoteEndPoint').doc('data').set(
{
'symbol': result['Global Quote']['01. symbol'],
'open': result['Global Quote']['02. open'],
}, { merge: true }).then(()=>{
console.log('New quoteEndPoint fields for ' + stock_id + ' added to Firebase');
})
.catch(err => {
console.log(err);
});
});
})
.on('error',(err) => {
console.log('Error: '+err.message);
});
req.end();
return true;
});
我试图使函数:function() 异步,但它不起作用。
在模拟器中创建并填充正确路径的值:/users/7nDGdHmZDuoDiJkxixgz/followedStocks/AMD/quoteEndPoint/data
有人可以帮忙吗?
谢谢
【问题讨论】:
标签: javascript node.js firebase google-cloud-functions