如何在NodeJS中使用SendGrid API和动态模板

aydmsdu9 于 2023-05-06 发布在 Node.js

关注(0)|答案(2)|浏览(171)

我在SendGrid中有一个动态模板。使用Postman向https://api.sendgrid.com/v3/mail/send发送POST请求
使用以下JSON：

{
    "personalizations": [{
        "to": [{
            "email": "dariusgoore@gmail.com",
            "name": "test"
        }],
        "dynamic_template_data":{
            "name":"John",
            "text": "Someone just added a new post!",
        }
    }],
    "from": {
        "email": "team@writerboards.com",
        "name": "test"
    },
    "reply_to": {
        "email": "dariusgoore@gmail.com",
        "name": "test"
    },
    "template_id": "d-c8f201dd360d40bc877da13a1a0b36b1"
}

使用模板发送电子邮件。
然而，我似乎不能从Express发送类似的请求。
下面是调用SendGrid的路由（端点响应cron作业）：

const express = require('express');
const User = require('../models/User');
const Act = require('../models/Act');
const sgMail = require('@sendgrid/mail');
sgMail.setApiKey(process.env.SENDGRID_API_KEY);

let router = express.Router();

router.get('/', async (req, res) => { 
  // getdate 14 days ago
  var ago_date = new Date();
  ago_date.setDate(ago_date.getDate()-0)
  // loop through users
  console.log('crons: getting users');
  const users = await User.query();
  console.log('crons:  number of users: ', users.length);
  for (const user of users) {

console.log(user.username)
const lastAct = await Act
  .query()
  .where('users_id', user.id)
  .orderBy('created_at', 'desc')
  .limit(1);

  const msg = {
    to: 'dariusgoore@gmail.com',
    from: 'team@writerboards.com',
    templateId: 'd-c8f201dd360d40bc877da13a1a0b36b1',

    dynamic_template_data: {
      subject: 'Testing Templates',
      name: 'Some One',
      text: 'Denver',
    },
  };

  console.log('this is the msg 2b sent: ', msg)
  const {
    classes: {
      Mail,
    },
  } = require('@sendgrid/helpers');
  const mail = Mail.create(msg);
  const body = mail.toJSON();
  console.log('this is the body: ', body);
  await sgMail.send(msg); 

  res.json({
    success: true, message: 'ok'
  });   // respond back to request
// };
  };

  res.json({
    success: true, message: 'ok' 
  }); 
});

下面是显示错误的错误跟踪：
错误[ERR_HTTP_HEADERS_SENT]：将标头发送到客户端后无法设置标头：
完整跟踪如下：

userone
sending email re on post
this is the msg 2b sent:  { to: 'dariusgoore@gmail.com',
  from: 'team@writerboards.com',
  templateId: 'd-c8f201dd360d40bc877da13a1a0b36b1',
  dynamic_template_data:
   { subject: 'Testing Templates',
     name: 'Some One',
     text: 'Denver' } }
this is the body:  { from: EmailAddress { email: 'team@writerboards.com', name: '' },
  subject: undefined,
  personalizations: [ { to: [Array], dynamic_template_data: [Object] } ],
  template_id: 'd-c8f201dd360d40bc877da13a1a0b36b1' }
usertwo
sending email re on post
this is the msg 2b sent:  { to: 'dariusgoore@gmail.com',
  from: 'team@writerboards.com',
  templateId: 'd-c8f201dd360d40bc877da13a1a0b36b1',
  dynamic_template_data:
   { subject: 'Testing Templates',
     name: 'Some One',
     text: 'Denver' } }
this is the body:  { from: EmailAddress { email: 'team@writerboards.com', name: '' },
  subject: undefined,
  personalizations: [ { to: [Array], dynamic_template_data: [Object] } ],
  template_id: 'd-c8f201dd360d40bc877da13a1a0b36b1' }
(node:19822) UnhandledPromiseRejectionWarning: Error [ERR_HTTP_HEADERS_SENT]: Cannot set headers after they are sent to the client
    at ServerResponse.setHeader (_http_outgoing.js:470:11)
    at ServerResponse.header (/Users/dariusgoore/development/writerboard/writerboard-express-api/node_modules/express/lib/response.js:771:10)
    at ServerResponse.send (/Users/dariusgoore/development/writerboard/writerboard-express-api/node_modules/express/lib/response.js:170:12)
    at ServerResponse.json (/Users/dariusgoore/development/writerboard/writerboard-express-api/node_modules/express/lib/response.js:267:15)
    at router.get (/Users/dariusgoore/development/writerboard/writerboard-express-api/src/routes/crons.js:54:11)
    at process._tickCallback (internal/process/next_tick.js:68:7)
(node:19822) UnhandledPromiseRejectionWarning: Unhandled promise rejection. This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). (rejection id: 3)

node.js

来源：https://stackoverflow.com/questions/59688500/how-to-use-sendgrid-api-with-dynamic-templates-with-nodejs

2条答案

按热度按时间

cmssoen21#

很抱歉多年来的回应。
我们实际上重新设计了我们的整个后端，而且tbh，我不记得我们到底做了什么。
无论如何，这里是工作路线的代码：

const express = require('express');
const axios = require('axios');
const Analytics = require('analytics-node');
const client = new Analytics('write key');

const auth = require('../middlewares/authenticate');

const User = require('../models/User');
const Post = require('../models/Post');
const Group = require('../models/Group');

// SendGrid initialization
const sgMail = require('@sendgrid/mail');
sgMail.setApiKey(process.env.SENDGRID_API_KEY);

let router = express.Router();

router.post('/', auth.required, async (req, res, next) => {
    await Post.query().insert({
        body: req.body.post.body,
        users_id: req.user.id,
        groups_id: req.body.post.groupId,
        parents_id: req.body.post.parents_id
    });

    let poster = await User.query().findById(req.user.id)
    let group = await Group.query()
        .findById(req.body.post.groupId)
        .eager('user');

    client.track({
        event: 'Post created',
        userId: req.user.id,
        properties: {
            body: req.body.post.body
        }
    });

    let newPost = req.body;
    let recipients = group.user.filter(el => (
        el.id !== poster.id 
    ));

    // Check to see if the environment is in production before sending the email.
    if(process.env.NODE_ENV !== "production") return res.json({
        success: false, 
        message: "fail" 
    });

    for(let i = 0; i < recipients.length; i++){
        sgMail.send({
            from: "email@domain.com",
            template_id: process.env.SENDGRID_NEW_POST,
            asm: {
                // new post notification list
                groupId: 20914 
            },
            personalizations: [{
                to: { email: recipients[i].email },
                dynamic_template_data: {
                    subject: `New Post: ${poster.username} just posted something`,
                    recipient_name: recipients[i].username, 
                    poster_name: poster.username,
                    group_name: group.name,
                    post_text: newPost.post.body,
                    button_url: process.env.VUE_HOME_URL,
                },
            }]
        });
    }

    res.json({ success: true, message: "ok" });
});

赞(0）回复(0）举报 2023-05-06

rkue9o1l2#

很抱歉响应晚了，但我认为这里的主要问题是，你在函数结束时发送了2个响应，第二次，express告诉你，你已经通过抛出异常发送了一个响应。
不确定sendgrid部分的代码是否正确，我实际上是在寻找更多关于动态模板API的文档。

赞(0）回复(0）举报 2023-05-06