在阅读并验证终端参数之后，我运行以下代码。首先，我读入电子邮件的CSV文件并计算每一行。有两个目的：1）它让我可以准确地报告文件进度[如我们稍后所见]，2）当文件中的电子邮件数量等于已完成的验证时，它让我可以停止计时器。我添加了一个计时器，以便我可以运行基准测试并确保我获得良好的结果。

let count = 0; //Line count require("fs") .createReadStream(myArgs[1]) .on("data", function (chunk) { for (let i = 0; i < chunk.length; ++i) if (chunk[i] == 10) count++; }) //Reads the infile and increases the count for each line .on("close", function () { //At the end of the infile, after all lines have been counted, run the recipient validation function validateRecipients.validateRecipients(count, myArgs); });

 然后我调用validateRecipients函数。请注意，此函数是异步的。在验证输入文件和输出文件是CSV格式之后，我写入一个标题行，并使用JSDOM库启动程序计时器。

async function validateRecipients(email_count, myArgs) { if ( //If both the infile and outfile are in .csv format extname(myArgs[1]).toLowerCase() == ".csv" && extname(myArgs[3]).toLowerCase() == ".csv" ) { let completed = 0; //Counter for each API call email_count++; //Line counter returns #lines - 1, this is done to correct the number of lines //Start a timer const { window } = new JSDOM(); const start = window.performance.now(); const output = fs.createWriteStream(myArgs[3]); //Outfile output.write( "Email,Valid,Result,Reason,Is_Role,Is_Disposable,Is_Free,Delivery_Confidence\n" ); //Write the headers in the outfile

以下脚本实际上是程序的主体，所以我将其分解并解释发生了什么。对于输入文件中的每一行：

• 异步获取该行并调用收件人验证API。

fs.createReadStream(myArgs[1]) .pipe(csv.parse({ headers: false })) .on("data", async (email) => { let url = SPARKPOST_HOST + "/api/v1/recipient-validation/single/" + email; await axios .get(url, { headers: { Authorization: SPARKPOST_API_KEY, }, }) //For each row read in from the infile, call the SparkPost Recipient Validation API

然后，在响应中

• 将电子邮件添加到JSON中（以便能够在CSV中打印出电子邮件）

• 验证如果原因为空值，如果是这样，则填充值（这样CSV格式一致，因为在某些情况下响应中会给出原因）

• 为json2csv模块设置选项和键。

• 将JSON转换为CSV并输出（利用json2csv）

• 在终端上写入进度

• 最后，如果文件中的电子邮件数量=完成的验证，停止计时器并打印出结果

  
  

.then(function (response) { response.data.results.email = String(email); //Adds the email as a value/key pair to the response JSON to be used for output response.data.results.reason ? null : (response.data.results.reason = ""); //If reason is null, set it to blank so the CSV is uniform //Utilizes json-2-csv to convert the JSON to CSV format and output let options = { prependHeader: false, //Disables JSON values from being added as header rows for every line keys: [ "results.email", "results.valid", "results.result", "results.reason", "results.is_role", "results.is_disposable", "results.is_free", "results.delivery_confidence", ], //Sets the order of keys }; let json2csvCallback = function (err, csv) { if (err) throw err; output.write(`${csv}\n`); }; converter.json2csv(response.data, json2csvCallback, options); completed++; //Increase the API counter process.stdout.write(`Done with ${completed} / ${email_count}\r`); //Output status of Completed / Total to the console without showing new lines //If all emails have completed validation if (completed == email_count) { const stop = window.performance.now(); //Stop the timer console.log( `所有电子邮件已成功验证，共耗时 ${ (stop - start) / 1000 } 秒` ); } })

我发现的最后一个问题是，虽然这在Mac上运行良好，但在使用Windows进行大约10,000次验证后遇到了以下错误：

Error: connect ENOBUFS XX.XX.XXX.XXX:443 – Local (undefined:undefined) with email XXXXXXX@XXXXXXXXXX.XXX

经过进一步研究，似乎是NodeJS HTTP客户端连接池不重新使用连接的问题。我在这个问题上找到了一个Stackoverflow文章，并经过进一步挖掘，找到了一个好的axios库的默认配置，解决了这个问题。我仍然不确定为什么这个问题只在Windows上发生而不在Mac上发生。