heroku 服务器和火力基地

Question

我正在尝试创建一个服务器来监听 firebase 数据库中所做的更改，然后将电子邮件发送到某个电子邮件地址。我设法实现了firebase和sendgrid，我已经通过向数据库添加一些条目并发送测试邮件进行了测试。所以 sendgrid 和 firebase 正在工作。这里的问题取决于我如何设法发送电子邮件，每次打开应用程序时它都会发送电子邮件。

所以问题来了，如果每次应用程序打开它都会执行 js 文件中的代码。当我添加代码以侦听数据库中添加的子事件时，每次打开应用程序时都会调用它，因此多个侦听器将处于活动状态，并且我假设将针对单个事件发送多封电子邮件。

所以我一无所知，无论如何这只会被调用一次吗？或者我不应该多次打开“应用程序”？还是我没有以正确的方式部署服务器？

我的目标是，一旦我部署服务器，它将自动执行其编写的操作，而无需在 heroku 中实际打开“应用程序”，或者至少在应用程序打开时不会再次调用代码，部署时只需一次。

这是 server.js 的代码

var firebase = require('firebase');
var helper = require('sendgrid').mail;

firebase.initializeApp({
  serviceAccount: "./DB-A2312SDA.json",
  databaseURL: "https://DATABASENAME.firebaseio.com/"
});

// Email

var from_email = new helper.Email('example@example.com');
var to_email = new helper.Email('example@gmail.com');
var subject = 'Hello World from the SendGrid Node.js Library!';
var content = new helper.Content('text/plain', 'Hello, Email!');
var mail = new helper.Mail(from_email, subject, to_email, content);

var sg = require('sendgrid')(process.env.SG_API_KEY);
var request = sg.emptyRequest({
  method: 'POST',
  path: '/v3/mail/send',
  body: mail.toJSON(),
});

sg.API(request, function(error, response) {
  console.log(response.statusCode);
  console.log(response.body);
  console.log(response.headers);
});

这是 package.json

{
  "name": "server_test",
  "version": "1.0.0",
  "description": "",
  "main": "server.js",
  "scripts": {
    "start": "node server.js"
  },
  "engines": {
    "node": "6.9.0"
  },
  "author": "",
  "license": "ISC",
  "dependencies": {
    "firebase": "^3.5.1",
    "sendgrid": "^4.7.0"
  }
}

和过程文件

web: node server.js

Answer 1

通常在这种情况下，您的数据库中有一个节点，该节点指示您需要向其发送消息的地址。例如，如果您想向已注册某项内容的人发送欢迎信息，您可以将其建模为：

welcomeMessageQueue
    $pushid
        email: "rialcom@company.com"
        firstName: "Ralcom"

你不能在你的节点脚本中附加一个监听器：

1. 对于此队列中的每条消息
2. 向该电子邮件地址发送消息
3. 然后从队列中删除该项目

这里重要的是，一旦您发送了消息，就从队列中删除该项目。这样，消息只会发送一次。

一个简单的方法是：

var ref = firebase.database().ref();
var queue = ref.child('welcomeMessageQueue');
queue.on('child_added', function(snapshot) {
    var message = snapshot.val();
    var sg = require('sendgrid')(process.env.SG_API_KEY);
    var request = sg.emptyRequest({
      method: 'POST',
      path: '/v3/mail/send',
      body: mail.toJSON(),
    });

    sg.API(request)
      .then(function(response) {
          snapshot.ref.remove();
      });
})

如需更可扩展的方法，请查看firebase-queue。

有关使用此方法的简单教程，请参阅blog post on sending push notifications。