我有一个由pub / sub事件触发的云功能。我使用sendgrid nodejs api。主要想法是向我的客户发送每周统计电子邮件。 sendEmail（）函数为每个客户端运行（80次）。但是当我检查功能日志时，我看到有25-30个客户端电子邮件成功发送，但剩下的就是错误：“socket hang up”
我缩短了整个代码，以显示与发送电子邮件相关的主要部分。这是最后一部分。
// I shortened the whole function as it is a very long function.
// The main and the last part is as below
// I have nearly 80 clients and sendEmail function run for each client.
function calcData(i, data) {
return admin.database().ref('clientUrlClicks/' + data.key)
.orderByChild('date')
.startAt(dateStartEpox)
.endAt(dateEndEpox)
.once('value', urlClickSnap => {
clients[i].clickTotalWeek = urlClickSnap.numChildren();
clients[i].listTotalWeek = 0;
admin.database().ref('clientImpressions/' + data.key)
.orderByKey()
.startAt(dateStart)
.endAt(dateEnd)
.once('value', snap => {
snap.forEach(function(impressionSnap) {
clients[i].listTotalWeek += impressionSnap.val();
})
}).then(resp => {
return sendEmail(i, clients[i]);
}).catch(err => {
console.log(err);
});
}).catch(err => {
clients[i].clickTotalWeek = 0;
console.log(err);
});
}
function sendEmail(i, data) {
var options = {
method: 'POST',
url: 'https://api.sendgrid.com/v3/mail/send',
headers:
{
'content-type': 'application/json',
authorization: 'Bearer ' + sgApiKey
},
body:
{
personalizations:
[{
to: [{ email: data.email, name: data.name }],
dynamic_template_data:
{
dateStart: xxx,
dateEnd: xxx,
}
}],
from: { email: '[email protected]', name: 'xxx' },
reply_to: { email: '[email protected]', name: 'xxx' },
template_id: 'd-f44eeexxxxxxxxxxxxx'
},
json: true
};
request(options, function (error, response, body) {
if (error) {
console.log("err: " + error);
return;
}
return;
});
}
编辑：
除了以下与“正确链接承诺”相关的答案之外，我还将所有电子邮件和个性化添加到“个性化”阵列作为“sendEmail”功能的对象。所以，而是发出每个电子邮件的请求，我提出一个请求。现在没问题。
您没有正确地链接承诺，因此在链接结束时不返回最终承诺，这对于云函数是强制性的。
以下一组修改是解决此问题的第一次尝试。
另外，你不清楚如何调用Sendgrid并返回Sendgrid调用返回的Promise。我建议您使用send()方法，它返回一个Promise，如Node.js的Sendgrid v3 Web API的文档中所述，请参阅https://github.com/sendgrid/sendgrid-nodejs/tree/master/packages/mail。
function calcData(i, data) {
//Declare clients aray here
return admin.database().ref('clientUrlClicks/' + data.key)
.orderByChild('date')
.startAt(dateStartEpox)
.endAt(dateEndEpox)
.once('value')
.then(urlClickSnap => {
clients[i].clickTotalWeek = urlClickSnap.numChildren();
clients[i].listTotalWeek = 0;
return admin.database().ref('clientImpressions/' + data.key) //Here you didn't return the promise
.orderByKey()
.startAt(dateStart)
.endAt(dateEnd)
.once('value');
.then(snap => {
snap.forEach(function(impressionSnap) {
clients[i].listTotalWeek += impressionSnap.val();
})
return sendEmail(i, clients[i]);
}).catch(err => {
clients[i].clickTotalWeek = 0;
console.log(err);
return null;
});
}
我看到你的代码与promise链接相关的两个问题，这可能导致这个问题。
首先，您在sendEmail函数中使用带回调的请求。这将不会等待您的网络呼叫完成并返回该功能。现在，这将并行构建调用，在您点击80个客户端计数之前，云功能的执行将完成。解决方案是将request-promise-native（https://github.com/request/request-promise-native）库与您的请求库一起使用。所以你的sendEmail函数现在将成为
sendEmail (i, data) {
.
.
.
return rpn(options).then((d)=>{return d}).catch((e)=>{return console.log(e)})
}
其他解决方案是对nodejs使用sendgrid客户端，它只返回promise并且您不需要使用请求。 https://github.com/sendgrid/sendgrid-nodejs/tree/master/packages/mail
第二个问题是你要求从firebase读取数据，你也在使用回调而不是promises。正确的解决方案是：
function calcData(i, data) {
return admin.database().ref('clientUrlClicks/' + data.key)
.orderByChild('date')
.startAt(dateStartEpox)
.endAt(dateEndEpox)
.once('value').then( urlClickSnap => {
clients[i].clickTotalWeek = urlClickSnap.numChildren();
clients[i].listTotalWeek = 0;
return admin.database().ref('clientImpressions/' + data.key)
.orderByKey()
.startAt(dateStart)
.endAt(dateEnd)
.once('value').then( snap => {
snap.forEach(function(impressionSnap) {
clients[i].listTotalWeek += impressionSnap.val();
})
return sendEmail(i, clients[i]);
})
.catch(err => {
console.log(err);
});
}).catch(err => {
clients[i].clickTotalWeek = 0;
console.log(err);
});
}
这将确保您在完成链接的所有promises的执行后返回calcData函数。
如果你在一个循环中调用calcData，还有一件事，那就确保你将所有的promises存储在一个数组中并在循环调用Promise.all(promisesArray)之后，这样你的函数就会等待所有的执行完成。