nodejs: использование дочернего процесса в aws lambda для запуска скрипта python не работает

Использование фреймворка бессерверного и этот пост в качестве руководства Я хотел бы распечатать некоторую информацию из скрипта python, у меня есть этот соответствующий код в мой обработчик.js

const path = await require('path')
const { spawn } = await require('child_process')

/**
 * Run python script, pass in `-u` to not buffer console output 
 * @return {ChildProcess}
 */
runScript() {
    return spawn('python', [
        "-u",
        path.join(__dirname, 'script.py'),
        "--foo", "some value for foo",
    ]);
}
const subprocess = await runScript()

// print output of script
await subprocess.stdout.on('data', (data) => {
    console.log(`data:${data}`);
});
await subprocess.stderr.on('data', (data) => {
    console.log(`error:${data}`);
});
await subprocess.stderr.on('close', () => {
    console.log("Closed");
});

а еще у меня script.py

#!/usr/bin/python
import sys, getopt, time

def main(argv):
    argument = ''
    usage = 'usage: script.py -f <sometext>'

    # parse incoming arguments
    try:
        opts, args = getopt.getopt(argv,"hf:",["foo="])
    except getopt.GetoptError:
        print(usage)
        sys.exit(2)
    for opt, arg in opts:
        if opt == '-h':
            print(usage)
            sys.exit()
        elif opt in ("-f", "--foo"):
            argument = arg

    # print output
    print("Start : %s" % time.ctime())
    time.sleep( 5 )
    print('Foo is')
    time.sleep( 5 )
    print(argument)
    print("End : %s" % time.ctime())

if __name__ == "__main__":
    main(sys.argv[1:])

Я ожидаю, что моя консоль покажет вывод или ошибку, когда я вызову функцию обработчика, но она ничего не печатает


python node.js serverless-framework
person imlearningcode    schedule 21.08.2019    source источник

Ответы (1)


arrow_upward
2
arrow_downward

Вот как это сделать:

const path = require("path");
const { spawn } = require("child_process");

const runScript = () => {
  return spawn("python", [
    "-u",
    path.join(__dirname, "script.py"),
    "--foo",
    "some value for foo"
  ]);
};

const promise = new Promise((resolve, reject) => {
  const subprocess = runScript();

  subprocess.stdout.on("data", data => {
    console.log(`data:${data}`);
  });

  subprocess.stderr.on("data", data => {
    console.log(`error:${data}`);
  });

  subprocess.on("close", code => {
    if (code !== 0) {
      reject(code);
    } else {
      resolve(code);
    }
  });
});

await promise;

Нет необходимости использовать await для синхронных функций, и, обернув subprocess промисом, вы можете await использовать его.

person Erez    schedule 21.08.2019
comment
Спасибо, это сработало отлично! но я пытался вернуть data после 'subprocess.stdout.on(data, data => {', но вместо этого он возвращает '0' - person imlearningcode; 22.08.2019
comment
Не могли бы вы опубликовать свой новый код? Может быть, в новом вопросе. Если вы используете return data внутри обратного вызова stdout.on, он возвращает данные вызывающей стороне, которые являются внутренним кодом spawn. Вы можете сделать let allData = ''; subprocess.stdout.on("data", data => { allData = allData + data.toString(); }); resolve({ code, allData }); или что-то подобное - person Erez; 22.08.2019