SendGrid with Firebase Cloud Functions 错误："socket hang up"

Question

我有一个由pub/sub事件触发的云函数。我使用sendgrid nodejs api。主要的想法是每周给我的客户发送一封统计电子邮件。sendEmail()函数为每个客户端运行(80次)。但当我查看功能日志时，我发现25-30封客户电子邮件发送成功，但剩下的则会出现错误："套接字挂断">

我缩短了整个代码，以显示与发送电子邮件相关的主要部分。这是最后一部分。

// 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: '[e-mail]', name: 'xxx' },
reply_to: { email: '[e-mail]', name: 'xxx' },
template_id: 'd-f44eeexxxxxxxxxxxxx'
},
json: true
};
request(options, function (error, response, body) {
if (error) {
console.log("err: " + error);
return;
}
return;
});
}

编辑：

除了以下与"正确链接承诺"相关的答案外，我还将所有电子邮件和个性化设置添加到"个性化设置"数组中，作为"sendEmail"功能上的对象。因此，我对每封电子邮件都提出一个请求。现在没问题。

Answer 1

您没有正确地链接promise，因此在链接结束时没有返回最终promise，这对于云函数来说是强制性的。

下面的一组修改是解决这个问题的第一次尝试。

此外，还不清楚如何调用Sendgrid并返回Sendgrid调用返回的Promise。我建议您使用send()方法，该方法返回Promise，如Node.js的Sendgridv3Webneneneba 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;
});
}

Answer 2

我看到您的代码中有两个与承诺链接有关的问题，这可能导致了这个问题。

首先，您在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，而不需要使用request。https://github.com/sendgrid/sendgrid-nodejs/tree/master/packages/mail

第二个问题是调用从firebase读取的数据，在这里您还使用回调而不是promise。正确的解决方案是：

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);
});
}

这将确保函数calcData在完成所有链接的promise的执行后返回。

还有一件事，如果您在循环中调用calcData，那么请确保将所有promise存储在一个数组中，并在循环调用Promise.all(promisesArray)之后，使函数等待所有执行完成。