1

更新：我在写入文件后添加了一个短暂的暂停，直到那时 shell 命令才起作用。

async function testRun() {
    await createInsertCurlReq.createInsertCurlReq(process.argv[2]);
    await timeout(3000);
    shell.chmod("+x", "./curl.sh");
    shell.exec("./curl.sh");
  }
}

原始问题

我的.then()块后createInsertCurlReq.createInsertCurlReq(process.argv[2])没有运行。我应该如何重写它才能做到这一点？我注意到如果我不删除文件而只是追加到，脚本就会运行。

    async function testRun() {

        if (fs.existsSync('./curl.sh')) {
          shell.rm('-rf', './curl.sh');
        }

        createInsertCurlReq.createInsertCurlReq(process.argv[2]).then(() => {
           shell.chmod('+x', './curl.sh');
           shell.exec('./curl.sh')
           return
        })

      }
    }

curlCreation.js



     function createInsertCurlReq(filePath) {
          return utils
            .readJSONFileOnDisk(filePath)
            .then(data => {
              obj = JSON.parse(data);
              let resultArr = [];
              for (let key in obj) {
                for (let innerKey in obj[key]) {
                  let arrayNew = {};
                  arrayNew[key] = obj[key][innerKey].resolved;
                  resultArr.push(arrayNew);
                }
              }
              return resultArr;
            })
            .then(data => {
              if (!fs.existsSync("./curl.sh")) {
                shell.touch("./curl.sh");
              }
              return data;
            })
            .then(data => {
              for (let i = 0; i < data.length; i++) {
                for (let key in data[i]) {
                  fs.appendFile(
                    "curl.sh",
                    `curl -X POST -H "xxx",
                    function(err) {
                      if (err) throw err;
                    }
                  );
                }
              }
            });
        }
        module.exports = { createInsertCurlReq: createInsertCurlReq };
4

2 回答 2

0

我相信问题是您在最后一次then调用createInsertCurlReq. 不同但相关的问题：将 async/await 与 forEach 循环一起使用

尝试用类似的东西替换它：

const {promisify} = require('util');

const appendFileAsync = promisify(fs.appendFile);
// ...
.then(data => Promise.all(data.map(() => appendFileAsync(
  "curl.sh",
  `curl -X POST -H "xxx"`
).catch(err => { throw err; }))));

这样，所有fs.appendFile呼叫都会在转到下一个之前解决then。

如果您不介意引入模块，也可以使用async-af重构为异步 forEach 方法：

const {promisify} = require('util');
const AsyncAF = require('async-af');

const appendFileAsync = promisify(fs.appendFile);
// ...
.then(data => AsyncAF(data).forEach(() => appendFileAsync(
  "curl.sh",
  `curl -X POST -H "xxx"`
).catch(err => { throw err; })));
于 2018-10-22T22:30:16.587 回答
0

在createInsertCurlReq中，当没有异步操作时，您使用 then 链接 jsut 来传递数组。试试这种格式：

async function testRun() {
  if (fs.existsSync('./curl.sh')) {
    shell.rm('-rf', './curl.sh');
  }
  await createInsertCurlReq.createInsertCurlReq(process.argv[2])
  shell.chmod('+x', './curl.sh');
  shell.exec('./curl.sh');
}

async function createInsertCurlReq(filePath) {
  const data = await utils.readJSONFileOnDisk(filePath);
  const obj = JSON.parse(data);
  let resultArr = [];
  for (let key in obj) {
    for (let innerKey in obj[key]) {
      let arrayNew = {};
      arrayNew[key] = obj[key][innerKey].resolved;
      resultArr.push(arrayNew);
    }
  }
  if (!fs.existsSync("./curl.sh")) {
    shell.touch("./curl.sh");
  }
  for (let i = 0; i < resultArr.length; i++) {
    for (let key in resultArr[i]) {
      fs.appendFileSync(
        "curl.sh",
        `curl -X POST -H "xxx"`
      );
    }
  }
}
于 2018-10-22T22:44:13.527 回答