为最大请求/秒的批处理选择适当的异步方法
我需要对某些外部 API 执行一些延迟的循环调用，以防止“超出用户速率限制"限制. Google Maps Geocoding API 对“req/sec"敏感，允许 10 req/sec.我应该为我的数百个联系人进行地理编码，并且需要这样的延迟.所以，我需要有 10 个异步地理编码功能，每个功能在 1 秒后延迟.因此，我收集数组中的所有联系人，然后以异步方式循环遍历数组. 一般来说，
..
node-async相关内容
Node.js - 使用异步库 - async.foreach 与对象
我正在使用节点异步库 - https://github.com/caolan/async#forEach 并且想遍历一个对象并打印出它的索引键.完成后，我想执行回调. 这是我到目前为止所拥有的，但从未见过 '迭代完成': async.forEach(Object.keys(dataObj), function (err, callback){console.log('*****');}，
..
为最大请求数/秒的批处理选择合适的异步方法
我需要对某些外部 API 执行循环调用并有一些延迟，以防止“超出用户速率限制"限制. Google Maps Geocoding API 对“req/sec"敏感，允许 10 req/sec.我应该为数百个联系人进行地理编码，而这样的延迟是必需的.所以，我需要有 10 个异步地理编码函数，每个函数都有 1 秒的后延迟.因此，我收集数组中的所有联系人，然后以异步方式遍历数组. 通常，我需
..
Node.js:如何限制请求列表?
我正在编写一个node.js应用，该应用需要从提供商的页面列表中获取一些数据: 变量列表= [{url:'http://www.example.com/1'}，{url:'http://www.example.com/2'}，...{url:'http://www.example.com/N'}，]; 目前，我正在使用 async.each ，效果很好: async.each(列表，//
..
如何在Node.js中从Promise中获取价值
嗨，我正在Azure函数中编写Node.js代码，以捕获保存在Azure密钥保管库中的用户名. 这是我写的代码 module.exports = async function (context, req) { var msRestAzure = require('ms-rest-azure'); var KeyVault = require('azure-keyvault')
..
node.js:程序意外退出或只是挂起
我在node.js中编写了一个执行一些网络操作的模块.我编写了一个使用此模块的小脚本(下面的变量check).看起来像这样: check(obj, function (err, results) { // ... console.log("Check completed"); }); 现在这是有趣的事情.当此代码作为mocha测试的一部分执行时，测试将按预期方式退出.我看
..
使用流作为Node.js中异步队列的输入，如何确保只调用一次queue.drain
我将从流中读取一系列输入，并对每个输入执行HTTP GET请求.为了避免一次创建太多连接，我使用 async.queue 将这些输入排队 读取所有输入(将end发送到流中)之后，我想收集以前的结果并生成概述. 我目前正在为此目的使用queue.drain.但是queue.drain在我的情况下可能会被多次调用，因为该过程可能在输入时被阻塞，并且在发生这种情况时队列将为空. 那么，
..
Node.js/Async-如何避免异步回调地狱?
我是后端的Node.Js和JavaScript Web开发的新手.我看到回调内部的回调可能会很痛苦，并且有一些模块可以避免这种情况.这些模块之一是异步的， https://github.com/caolan/async 我已经阅读了文档，但是很难开始并了解如何操作. 例如，我有此功能"check_aut_user"，如何使用异步方式转换此代码? function check_au
..
无法使用“地图"异步模块中的功能
我正在使用node.js“异步"模块，需要使用“映射"方法. 基本上我有一个包含其他数组的数组.内部数组包含2个元素，一个类型和一个图像文件名. var arr0 = []; var arr1 = ["type1", "image1.jpg"]; jsonArr.push(obj1); var arr2 = ["type2", "image2.jpg"]; jsonArr.push(obj
..
Node.JS async.parallel不会等待所有任务完成
我正在使用 aync.parallel 并行运行两个功能.这些功能要求RSS提要.然后解析RSS feed，并将其添加到我的网页中. 但是由于某些原因，async.parallel在不等待两个函数完成之前运行回调方法 文档说: 任务完成后，结果将传递到最终结果 作为数组回调. 我的代码. require('async').parallel([ function(cal
..
选择适当的异步方法进行批处理，以获得最大请求数/秒
我需要对某些外部API进行一些延迟的循环调用，以防止出现“超出用户速率限制"的限制. Google Maps Geocoding API对"req/sec"敏感，允许10 req/sec.我应该对数百个联系人进行地理编码，因此需要这样的延迟.因此，我需要有10个异步地理编码功能，每个功能要延迟1秒.因此，我收集数组中的所有联系人，然后以异步方式遍历数组. 通常，我需要有N个并发线程，每
..
async.apply在async.waterfall中
我有以下代码片段 async.waterfall（[ //阅读目录 async.apply（fs.readdir，'.. / testdata'）， //从每个文件加载数据 函数（文件，回调）{ async.each（files，loadDataFromFile） ，回调）; } ]，函数（错误）{ if（错误）{ api.logger.error（'插入测试数据时出错'，
..
使用nodeJS进行异步http调用
我想在我的服务器节点上启动异步http调用，我看到 async 节点模块，我想 async.parallel 使我们能够做到这一点。 文档化的示例非常清楚，但我不知道如何管理多个http调用。 我尝试了以下示例，但它甚至没有启动http调用： var http = require（'http'）; var Calls = []; Calls.push（函数（回调）{
..
为什么async.map功能与本地fs.stat功能工作？
async.map（['文件1'，'文件2'，'file3的']，fs.stat，功能（错了，结果）{ //结果是现在的统计资料为每个文件的数组 }）; 根据文档，第二个参数是： 迭代器（项目，回调） - 该功能可应用到每个项目 数组。 精细。 该迭代器传递一个回调（ERR，转化），必须 一旦它已经与一个错误（其可以为空）完成调用和 转化项目。 我觉得
..
使用异步模块触发一个回调，一旦所有文件都读
我使用 caolan的“异步”模块打开文件名的数组（在这种情况下，模板文件名）。 每文档，我使用 async.forEach（），这样我就可以开火回调一旦所有操作完成。 一个简单的测试案例是： VAR异步=要求（“异步”） 变种FS =要求（“FS”）file_names = [“一”，“二”，“三化”//所有这些文件确实存在async.forEach（file_names， 功能
..
async.js各获得迭代指数
我使用 caolan的async.js 库，具体的方法。每个 你如何获得访问索引中的迭代器？ async.each（元，函数（元素，回调）{ //为进制每个元素做的东西在这里 //我如何才能访问索引？ }，功能（错误）{ //此处最终的回调 }） 解决方案 您可以使用 async.forEachOf - 它所谓的迭代器回调的指数作为其第二个参数。 ＆GT; async
..
是什么async.waterfall和async.series之间的区别
在异步的NodeJS模块： https://github.com/caolan/async 提供了2个类似的方法， async.waterfall 和 async.series 。 它们之间有什么区别呢？ 解决方案 看来， async.waterfall 允许每个功能传递到下一个功能它的结果，而 async.series 通过所有结果到最后的回调。在一个较高的水平， async.wate
..
Node.js的 - 使用异步LIB - async.foreach与对象
我使用的节点异步的LIB - https://github.com/caolan/async#的forEach 并想通过一个对象进行迭代并打印出它的索引键。一旦完成，我想执行的回调。 下面是我到目前为止，但“迭代完成”是从未见过的： async.forEach（Object.keys（dataObj），功能（ERR，回调）{ 的console.log（'*****'）;
..