How to use read and write streams in node.js for BIG CSV files

An overview on how to use a read and write stream in node when you want to read in a very large csv file and process it quickly.
------------
🔔 Newsletter eepurl.com/hnderP
💬 Discord / discord
📁. GitHub github.com/codyseibert/youtube

Пікірлер: 27

  • @officialabdulrehman
    @officialabdulrehman Жыл бұрын

    This was very helpful. Thank you

  • @sameerbharadwaj11
    @sameerbharadwaj11 Жыл бұрын

    Thank You! This helped a lot with writing 20mil records to solr.

  • @WebDevCody

    @WebDevCody

    Жыл бұрын

    Oh wow this actually helped? I’m glad 😂

  • @bipinshukla5222
    @bipinshukla5222 Жыл бұрын

    Awesome explaination

  • @CarlosHonorioBriones
    @CarlosHonorioBriones2 жыл бұрын

    nice! This is good to know. Thanks!

  • @LarsRyeJeppesen
    @LarsRyeJeppesen10 ай бұрын

    Super stuff, thanks. Subbed

  • @rorycawley
    @rorycawley2 жыл бұрын

    Great video, thanks

  • @YOUdudex
    @YOUdudex Жыл бұрын

    Cool video, thanks subscribed

  • @SeibertSwirl
    @SeibertSwirl2 жыл бұрын

    Good job babe!!!

  • @user-xw6jr7ue4b
    @user-xw6jr7ue4b Жыл бұрын

    thank u, buddy!

  • @lucanthony2209
    @lucanthony22092 жыл бұрын

    Hello @vJunkie, Thanks for the great content. CAn you make a video using csv-parser & fs libraries to read & write csv files ?

  • @martinmingosuarez8690
    @martinmingosuarez86902 жыл бұрын

    there is a core module called readline that works with streams to read one line at a time, no need to write the logic yourself, otherwise great explanation and video. Cheers

  • @veremox

    @veremox

    Жыл бұрын

    im not an expert but a chunk is not necessarily a line...

  • @oscarmamani5996

    @oscarmamani5996

    Жыл бұрын

    martinmingosuarez8690 thank you for this comment! it help me

  • @LegendKopper

    @LegendKopper

    8 ай бұрын

    -----The topic "NodeJS streams----> (your head)

  • @pranjaldoorwar9743
    @pranjaldoorwar97432 жыл бұрын

    This might be helpful to me i am trying to read csv data and insert it into mongodb first before parsing it

  • @PhuTran-nb7me
    @PhuTran-nb7me2 жыл бұрын

    Hello Sir, I have a question, much appreciated If you can address my doubt. Do chunks come in sequence, in other words, does the read stream wait for the current chunk to finish the operations before it emit the "data" event to process the next chunk? You have a potentially long running iteration there and more importantly, each chunk is interdependent to each other as the last If statement is used to assign the last incomplete row to "unprocessed" variable for the next chunk to use.

  • @WebDevCody

    @WebDevCody

    2 жыл бұрын

    Yes they should come in order.

  • @empty8537empty

    @empty8537empty

    2 жыл бұрын

    It should be in order..which is taken care by your transport layer..

  • @Tony.Nguyen137
    @Tony.Nguyen1373 күн бұрын

    What if I want to read data of users - User{age:20………height:7“} - and save it into a database, but that chunk of data miss some properties that a user have like height:7“ ? Could this happen if yes how to solve it

  • @mtuchidev
    @mtuchidev Жыл бұрын

    How do you pass a chunk size ?

  • @boople2snoot
    @boople2snoot2 жыл бұрын

    them jump cuts

  • @boople2snoot

    @boople2snoot

    2 жыл бұрын

    also no sub, your variable is overWatermark, you're waiting for an event emitter if not overWatermark, the function therefore must return true if it is not over the watermark and var should be named underWatermark. Or it would run if not overWatermark, which is under the watermark, which? shit you just ramble, bye.

  • @himaliamit8698
    @himaliamit86982 жыл бұрын

    if you show us the format of the csv file it would have made much more sense.

  • @majidshah48

    @majidshah48

    2 жыл бұрын

    i think opening the file will take time or it might just crash

  • @haohong5141
    @haohong5141 Жыл бұрын

    node version?

  • @ViktosB
    @ViktosB4 ай бұрын

    Hi, I really enjoy your videos. One of the most productive publisher on KZread. But in that video the name "overWatermark" is highly misleading. I struggled understand the whole structure only because of that naming. This would be better if you use instead "canWrite". canWrite is true when we can write and false when the buffer is full. Then we stop -> !canWrite. const canWrite = writeStream.write(`${i}, `); if (!canWrite) { await new Promise((resolve) => writeStream.once('drain', resolve)); } } I might be wrong of course. Other than that - great job again. Continue watching you content 🙂