Node.js tập tin ghi trong vòng lặp không ngẫu nhiên

Question

Đây là mã của tôi:

function aCallbackInLoop(dataArray) { 
     dataArray.forEach(function (item, index) { 

      fs.appendFile(fileName, JSON.stringify(item) + "\r\n", function (err) { 
       if (err) { 
        console.log('Error writing data ' + err); 
       } else { 
        console.log('Data written'); 
       } 
      }); 
     }); 
    } 

tôi nhận được lỗi ngẫu nhiên:

Data written 
Data written 
. 
. 
Error writing data Error: UNKNOWN, open 'output/mydata.json' 
Error writing data Error: UNKNOWN, open 'output/mydata.json' 
. 
. 
Data written 
Error writing data Error: UNKNOWN, open 'output/mydata.json' 

Chức năng (aCallbackInLoop) là một callback cho một yêu cầu dịch vụ web , trả về các khối dữ liệu trong dataArray. Nhiều yêu cầu dịch vụ web đang được thực hiện trong một vòng lặp, do đó, cuộc gọi lại này có lẽ được gọi song song. Tôi nghi ngờ đó là một số vấn đề khóa tập tin, nhưng tôi không chắc chắn làm thế nào để giải quyết.

PS: Tôi đã thực hiện chắc chắn nó không phải là một vấn đề dữ liệu (Tôi đăng nhập tất cả các mục trong dataArray)

Chỉnh sửa: Mã sau khi cố gắng ghi dòng:

function writeDataToFile(fileName, data) { 
    try { 
     var wStream = fs.createWriteStream(fileName); 
     wStream.write(JSON.stringify(data) + "\r\n"); 
     wStream.end(); 
    } catch (err) { 
     console.log(err.message); 
    } 
} 

function aCallbackInLoop(dataArray){ 
    dataArray.forEach(function(item, index){ 
     writeDataToFile(filename, item); //filename is global var 
    }); 
} 

Answer 1

Hãy thử sử dụng phiên bản đồng bộ appendFile - https://nodejs.org/api/fs.html#fs_fs_appendfilesync_filename_data_options

Answer 2

Như bạn đã quan sát thấy, nhiều cuộc gọi appendFile không thể tiếp tục do các cuộc gọi trước đây appendFile. Trong trường hợp cụ thể này, sẽ tốt hơn nếu tạo một write stream.

var wstream = fs.createWriteStream(fileName); 

dataArray.forEach(function (item) { 
    wstream.write(JSON.stringify(item + "\r\n"); 
}); 

wstream.end(); 

Nếu bạn muốn biết khi nào tất cả các dữ liệu được ghi, sau đó bạn có thể đăng ký một chức năng với sự kiện finish, như thế này

var wstream = fs.createWriteStream(fileName); 

wstream.on("finish", function() { 
    // Writing to the file is actually complete. 
}); 

dataArray.forEach(function (item) { 
    wstream.write(JSON.stringify(item + "\r\n"); 
}); 

wstream.end();