Firestore 将函数返回添加到数据库

Question

我正在尝试使用 firebase 创建一个函数，根据请求，该函数执行一些抓取活动，然后每次将结果记录到集合中。我的函数工作并返回我需要的项目数组，但是我在将此数组添加到 firestore 数据库中时遇到问题。

我不确定我是否需要订阅响应或它是否返回其他内容。 云功能：

exports.scraper = functions.https.onRequest( async (request, response) => {
cors(request, response, async () => {
const body = (request.body);
const data = await scrapeteamtags(body.text);
response.send(data)
});
return admin.firestore().collection('games').add({
teams: data
})

});

添加了在等待上下文中使用的函数：

const scrapeteamtags = (text) => {
const urls = Array.from( getUrls(text) );
const requests = urls.map(async url => {
const res = await fetch(url);
const html = await res.text();
const $ = cheerio.load(html);

const getTeamlist = JSON.parse($('body').text())  

var gamelist = {
games: []
}

getTeamlist.SSResponse.children.map(function(item) {
// go into the returned json
var event = new Object;
var leagues  = ["Premier League", "Spanish La Liga", "Italian Serie A", 'French Ligue 1', 'German Bundesliga']
// finds all child items that contain the event tag

if(Object.keys(item).includes('event')) {
// check that the league is on the list which are of interest
if(leagues.includes(item.event.typeName)) {
event.id = item.event.id;
event.name = item.event.name;
// add the event name and id to the object then go into next level to get market data
item.event.children.map(function(item1) {
if(Object.keys(item1).includes('market')) {
event.marketid = item1.market.id
// add the market data id to the object
var eventoutcome = []
item1.market.children.map(function(item2) {
if(Object.keys(item2).includes('outcome')) {
eventoutcome.push({"id" : item2.outcome.id,
"id": item2.outcome.id,
"name": item2.outcome.name,
"price": item2.outcome.children[0].price.priceDec})
//adds the id, name and price to an array, then add it to the object
event.outcome = eventoutcome
}
})
}
})
gamelist.games.push(event)
}
// push each event as a new object to the array of games

}
})
//console.log(gamelist.games)
return {
gamelist
}
});

return Promise.all(requests);
}

Answer 1

HTTP 函数不允许你返回包含要发送的数据的承诺。 (这就是可调用函数的工作方式，但这在这里不适用。 您必须等待数据库写入完成，然后发送响应以终止函数。

该函数的结构应该更像这样：

exports.scraper = functions.https.onRequest( async (request, response) => {
cors(request, response, async () => {
const body = (request.body);
const data = await scrapeteamtags(body.text);
await admin.firestore().collection('games').add({
teams: data
})
response.send(data)
});

});