async.js

    0熱度

    1回答

    我遇到了使用async.eachLimit的問題。它適用於前10個元素,但它不會繼續過去;它只是結束。所以,如果有100個元素,它只會在前10個元素。這顯然是我誤解回調的問題。使用eachLimit和不包含回調的外部函數的正確方法是什麼?還是這樣的功能需要一個? async.eachLimit(items, 10, function(item, callback) { outsideF

    0熱度

    1回答

    我有一個項目數組: var myArr = ['item1', 'item2', 'item3']; 我試圖遍歷這些項目,並檢查它們是否存在於我的數據庫中。如果該項目不存在,那麼我將它添加到數據庫中。 var sql = 'Select * from DB where item="' + myArr[i] + '"'; connection.query(sql, function(e, r,

    1熱度

    1回答

    我想將所有從數據庫中取出的數據存儲在arr_obj中,然後使用這個變量int async.forEachLimit函數。出於這個原因,我使用async.series函數,除睡眠(1000)以外,一切正常,只要調用了async.series的第二個函數,代碼就會休眠,然後將所有結果一起給出。在NodeJs中,我沒有初學者對這一切有很多想法。 var sleep = require('system-s

    0熱度

    1回答

    嘗試寫入所有文件,然後結束響應,但在完成所有寫入之前以某種方式調用res.end。 我如何解決它,做所有的寫作,並在那之後調用res.end()? 錯誤味精大氣壓:錯誤:結束後寫 app.get('/api/upload', function (req, res) { gfs.files.find({}).toArray(function (err, files) { if

    0熱度

    1回答

    我嘗試發送多個HTTP PUT請求到我的服務器,但我只管理一個JSON發送到數據庫,我是缺少在這裏 var data1 = JSON.stringify(require('./abc.json')), data2 = JSON.stringify(require('./abe.json')), data3 = JSON.stringify(require('./abd.json

    0熱度

    3回答

    我正在使用mongodb和bigquery的nodejs。 因爲它似乎bigquery只允許每個命令10k插入。 所以我做了主要查詢計數,並循環到從10K多少頁。 我得到500k與計數查詢,所以50頁或500循環。 如何讓循環等待直到運行循環的下一頁? 代碼: var limit = 9999; mongo_client.connect(mongo_url, function(err, db)

    0熱度

    1回答

    async.map(map, function(item, mnext){ async.waterfall([ function(wnext){ console.log("1"); //mongodb queryies something like db.collection.find().toArray(function(err){

    -2熱度

    2回答

    我有我的查詢陣列 var array = [ 'UPDATE EVALUATION SET mark = "16" WHERE id_eval = "21" AND id_usr = "125"', 'UPDATE EVALUATION SET mark = "9" WHERE id_eval = "22" AND id_usr = "125"', 'UPDATE

    0熱度

    1回答

    我是nodejs開發人員。我正在使用Mongodb和waterline ORM和異步庫來執行更新任務。以下是我關注的步驟 function update(task, payload, next) { const self = this; async.auto({ createUpdateObj : (callback) => { let update

    1熱度

    1回答

    我對Node.js比較陌生,仍然圍繞着回調和Node.js的異步本質進行了包裝。我遇到了一個我無法解決的問題;我已經徹底搜索了溢出並閱讀了支持文檔,但仍無法使其工作。 本質上,問題是我有一個對象數組,我想對每個對象應用一系列的異步操作。我查看了Async.js並嘗試了各種回調結構,但是我的編譯器只是不停地向我大喊。 我的代碼的最新版本是: function processObjects(objec