limiting number of parallel request to cassandra db in nodejs












1















I currently parsing a file and getting its data in order tu push them in my db. To do that I made an array of query and I execute them through a loop.



The problem is that I'm limited to 2048 parallel requests.



This is the code I made:



index.js=>



const ImportClient = require("./scripts/import_client_leasing")
const InsertDb = require("./scripts/insertDb")

const cassandra = require('cassandra-driver');
const databaseConfig = require('./config/database.json');


const authProvider = new cassandra.auth.PlainTextAuthProvider(databaseConfig.cassandra.username, databaseConfig.cassandra.password);

const db = new cassandra.Client({
contactPoints: databaseConfig.cassandra.contactPoints,
authProvider: authProvider
});

ImportClient.clientLeasingImport().then(queries => { // this function parse the data and return an array of query
return InsertDb.Clients(db, queries); //inserting in the database returns something when all the promises are done
}).then(result => {
return db.shutdown(function (err, result) {});
}).then(result => {
console.log(result);
}).catch(error => {
console.log(error)
});


insertDb.js =>



module.exports = {
Clients: function (db, queries) {
DB = db;
return insertClients(queries);
}
}

function insertClients(queries) {
return new Promise((resolve, reject) => {
let promisesArray = ;

for (let i = 0; i < queries.length; i++) {
promisesArray.push(new Promise(function (resolve, reject) {
DB.execute(queries[i], function (err, result) {
if (err) {
reject(err)
} else {
resolve("success");
}
});
}));
}
Promise.all(promisesArray).then((result) => {
resolve("success");
}).catch((error) => {
resolve("error");
});
});
}


I tried multiple things, like adding an await function thats set a timout in my for loop every x seconds (but it doesn't work because i'm already in a promise), i also tried with p-queue and p-limit but it doesn't seems to work either.



I'm kinda stuck here, I'm think I'm missing something trivial but I don't really get what.



Thanks










share|improve this question





























    1















    I currently parsing a file and getting its data in order tu push them in my db. To do that I made an array of query and I execute them through a loop.



    The problem is that I'm limited to 2048 parallel requests.



    This is the code I made:



    index.js=>



    const ImportClient = require("./scripts/import_client_leasing")
    const InsertDb = require("./scripts/insertDb")

    const cassandra = require('cassandra-driver');
    const databaseConfig = require('./config/database.json');


    const authProvider = new cassandra.auth.PlainTextAuthProvider(databaseConfig.cassandra.username, databaseConfig.cassandra.password);

    const db = new cassandra.Client({
    contactPoints: databaseConfig.cassandra.contactPoints,
    authProvider: authProvider
    });

    ImportClient.clientLeasingImport().then(queries => { // this function parse the data and return an array of query
    return InsertDb.Clients(db, queries); //inserting in the database returns something when all the promises are done
    }).then(result => {
    return db.shutdown(function (err, result) {});
    }).then(result => {
    console.log(result);
    }).catch(error => {
    console.log(error)
    });


    insertDb.js =>



    module.exports = {
    Clients: function (db, queries) {
    DB = db;
    return insertClients(queries);
    }
    }

    function insertClients(queries) {
    return new Promise((resolve, reject) => {
    let promisesArray = ;

    for (let i = 0; i < queries.length; i++) {
    promisesArray.push(new Promise(function (resolve, reject) {
    DB.execute(queries[i], function (err, result) {
    if (err) {
    reject(err)
    } else {
    resolve("success");
    }
    });
    }));
    }
    Promise.all(promisesArray).then((result) => {
    resolve("success");
    }).catch((error) => {
    resolve("error");
    });
    });
    }


    I tried multiple things, like adding an await function thats set a timout in my for loop every x seconds (but it doesn't work because i'm already in a promise), i also tried with p-queue and p-limit but it doesn't seems to work either.



    I'm kinda stuck here, I'm think I'm missing something trivial but I don't really get what.



    Thanks










    share|improve this question



























      1












      1








      1








      I currently parsing a file and getting its data in order tu push them in my db. To do that I made an array of query and I execute them through a loop.



      The problem is that I'm limited to 2048 parallel requests.



      This is the code I made:



      index.js=>



      const ImportClient = require("./scripts/import_client_leasing")
      const InsertDb = require("./scripts/insertDb")

      const cassandra = require('cassandra-driver');
      const databaseConfig = require('./config/database.json');


      const authProvider = new cassandra.auth.PlainTextAuthProvider(databaseConfig.cassandra.username, databaseConfig.cassandra.password);

      const db = new cassandra.Client({
      contactPoints: databaseConfig.cassandra.contactPoints,
      authProvider: authProvider
      });

      ImportClient.clientLeasingImport().then(queries => { // this function parse the data and return an array of query
      return InsertDb.Clients(db, queries); //inserting in the database returns something when all the promises are done
      }).then(result => {
      return db.shutdown(function (err, result) {});
      }).then(result => {
      console.log(result);
      }).catch(error => {
      console.log(error)
      });


      insertDb.js =>



      module.exports = {
      Clients: function (db, queries) {
      DB = db;
      return insertClients(queries);
      }
      }

      function insertClients(queries) {
      return new Promise((resolve, reject) => {
      let promisesArray = ;

      for (let i = 0; i < queries.length; i++) {
      promisesArray.push(new Promise(function (resolve, reject) {
      DB.execute(queries[i], function (err, result) {
      if (err) {
      reject(err)
      } else {
      resolve("success");
      }
      });
      }));
      }
      Promise.all(promisesArray).then((result) => {
      resolve("success");
      }).catch((error) => {
      resolve("error");
      });
      });
      }


      I tried multiple things, like adding an await function thats set a timout in my for loop every x seconds (but it doesn't work because i'm already in a promise), i also tried with p-queue and p-limit but it doesn't seems to work either.



      I'm kinda stuck here, I'm think I'm missing something trivial but I don't really get what.



      Thanks










      share|improve this question
















      I currently parsing a file and getting its data in order tu push them in my db. To do that I made an array of query and I execute them through a loop.



      The problem is that I'm limited to 2048 parallel requests.



      This is the code I made:



      index.js=>



      const ImportClient = require("./scripts/import_client_leasing")
      const InsertDb = require("./scripts/insertDb")

      const cassandra = require('cassandra-driver');
      const databaseConfig = require('./config/database.json');


      const authProvider = new cassandra.auth.PlainTextAuthProvider(databaseConfig.cassandra.username, databaseConfig.cassandra.password);

      const db = new cassandra.Client({
      contactPoints: databaseConfig.cassandra.contactPoints,
      authProvider: authProvider
      });

      ImportClient.clientLeasingImport().then(queries => { // this function parse the data and return an array of query
      return InsertDb.Clients(db, queries); //inserting in the database returns something when all the promises are done
      }).then(result => {
      return db.shutdown(function (err, result) {});
      }).then(result => {
      console.log(result);
      }).catch(error => {
      console.log(error)
      });


      insertDb.js =>



      module.exports = {
      Clients: function (db, queries) {
      DB = db;
      return insertClients(queries);
      }
      }

      function insertClients(queries) {
      return new Promise((resolve, reject) => {
      let promisesArray = ;

      for (let i = 0; i < queries.length; i++) {
      promisesArray.push(new Promise(function (resolve, reject) {
      DB.execute(queries[i], function (err, result) {
      if (err) {
      reject(err)
      } else {
      resolve("success");
      }
      });
      }));
      }
      Promise.all(promisesArray).then((result) => {
      resolve("success");
      }).catch((error) => {
      resolve("error");
      });
      });
      }


      I tried multiple things, like adding an await function thats set a timout in my for loop every x seconds (but it doesn't work because i'm already in a promise), i also tried with p-queue and p-limit but it doesn't seems to work either.



      I'm kinda stuck here, I'm think I'm missing something trivial but I don't really get what.



      Thanks







      node.js asynchronous cassandra promise






      share|improve this question















      share|improve this question













      share|improve this question




      share|improve this question








      edited Nov 20 '18 at 10:30







      lanetrotro

















      asked Nov 20 '18 at 10:22









      lanetrotrolanetrotro

      799




      799
























          1 Answer
          1






          active

          oldest

          votes


















          0














          Ok, so I found a workaround to reach my goal.
          I wrote in a file all my queries



          const fs = require('fs')
          fs.appendFileSync('my_file.cql', queries[i] + "n");


          and i then used



          child_process.exec("cqls --file my_file", function(err, stdout, stderr){})"


          to insert in cassandra all my queries






          share|improve this answer























            Your Answer






            StackExchange.ifUsing("editor", function () {
            StackExchange.using("externalEditor", function () {
            StackExchange.using("snippets", function () {
            StackExchange.snippets.init();
            });
            });
            }, "code-snippets");

            StackExchange.ready(function() {
            var channelOptions = {
            tags: "".split(" "),
            id: "1"
            };
            initTagRenderer("".split(" "), "".split(" "), channelOptions);

            StackExchange.using("externalEditor", function() {
            // Have to fire editor after snippets, if snippets enabled
            if (StackExchange.settings.snippets.snippetsEnabled) {
            StackExchange.using("snippets", function() {
            createEditor();
            });
            }
            else {
            createEditor();
            }
            });

            function createEditor() {
            StackExchange.prepareEditor({
            heartbeatType: 'answer',
            autoActivateHeartbeat: false,
            convertImagesToLinks: true,
            noModals: true,
            showLowRepImageUploadWarning: true,
            reputationToPostImages: 10,
            bindNavPrevention: true,
            postfix: "",
            imageUploader: {
            brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
            contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
            allowUrls: true
            },
            onDemand: true,
            discardSelector: ".discard-answer"
            ,immediatelyShowMarkdownHelp:true
            });


            }
            });














            draft saved

            draft discarded


















            StackExchange.ready(
            function () {
            StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53390876%2flimiting-number-of-parallel-request-to-cassandra-db-in-nodejs%23new-answer', 'question_page');
            }
            );

            Post as a guest















            Required, but never shown

























            1 Answer
            1






            active

            oldest

            votes








            1 Answer
            1






            active

            oldest

            votes









            active

            oldest

            votes






            active

            oldest

            votes









            0














            Ok, so I found a workaround to reach my goal.
            I wrote in a file all my queries



            const fs = require('fs')
            fs.appendFileSync('my_file.cql', queries[i] + "n");


            and i then used



            child_process.exec("cqls --file my_file", function(err, stdout, stderr){})"


            to insert in cassandra all my queries






            share|improve this answer




























              0














              Ok, so I found a workaround to reach my goal.
              I wrote in a file all my queries



              const fs = require('fs')
              fs.appendFileSync('my_file.cql', queries[i] + "n");


              and i then used



              child_process.exec("cqls --file my_file", function(err, stdout, stderr){})"


              to insert in cassandra all my queries






              share|improve this answer


























                0












                0








                0







                Ok, so I found a workaround to reach my goal.
                I wrote in a file all my queries



                const fs = require('fs')
                fs.appendFileSync('my_file.cql', queries[i] + "n");


                and i then used



                child_process.exec("cqls --file my_file", function(err, stdout, stderr){})"


                to insert in cassandra all my queries






                share|improve this answer













                Ok, so I found a workaround to reach my goal.
                I wrote in a file all my queries



                const fs = require('fs')
                fs.appendFileSync('my_file.cql', queries[i] + "n");


                and i then used



                child_process.exec("cqls --file my_file", function(err, stdout, stderr){})"


                to insert in cassandra all my queries







                share|improve this answer












                share|improve this answer



                share|improve this answer










                answered Nov 22 '18 at 16:31









                lanetrotrolanetrotro

                799




                799






























                    draft saved

                    draft discarded




















































                    Thanks for contributing an answer to Stack Overflow!


                    • Please be sure to answer the question. Provide details and share your research!

                    But avoid



                    • Asking for help, clarification, or responding to other answers.

                    • Making statements based on opinion; back them up with references or personal experience.


                    To learn more, see our tips on writing great answers.




                    draft saved


                    draft discarded














                    StackExchange.ready(
                    function () {
                    StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53390876%2flimiting-number-of-parallel-request-to-cassandra-db-in-nodejs%23new-answer', 'question_page');
                    }
                    );

                    Post as a guest















                    Required, but never shown





















































                    Required, but never shown














                    Required, but never shown












                    Required, but never shown







                    Required, but never shown

































                    Required, but never shown














                    Required, but never shown












                    Required, but never shown







                    Required, but never shown







                    Popular posts from this blog

                    android studio warns about leanback feature tag usage required on manifest while using Unity exported app?

                    SQL update select statement

                    'app-layout' is not a known element: how to share Component with different Modules