使用 python-shell 持续交换数据答案

【问题标题】：Continuously exchange data using python-shell使用 python-shell 持续交换数据
【发布时间】：2018-05-07 22:01:59
【问题描述】：

我需要从 node.js 运行一些 python 脚本。由于我的 python 脚本使用复杂的结构，我认为如果我只加载这些结构一次然后使用这些结构运行一些特定的脚本（任务）会更好。

在节点上我想永远运行一个脚本（或者直到我说它可以终止）并继续向这个脚本发送按需消息。该脚本将使用 python multiprocessing 创建一个进程来运行特定任务并再次开始监听。

一个用例是：

节点启动，并唤醒 python 脚本
节点客户端上的某些操作导致它向 python 脚本发送command
python 脚本计算它需要什么并返回数据

我认为python-shell 可以帮助我解决这个问题

在节点上我有这样的东西：

var app = express();
app.listen(8000, function () {
    console.log('Example app listening on port 8000!');
});

var pyshell = new PythonShell('start.py', options);
pyshell.on('message', function (message) {
    handleAnswer(message);
});

pyshell.end(function (err, code, signal) {
    handleEnd(err, code, signal);
});

app.get('/hello', function (req, res) {
    pyshell.send('hello');
});

我的start.py 脚本是：

import sys

def listen():
    while True:
        command = sys.stdin.readline()
        command = command.split('\n')[0]
        if command:
            print("Received CMD " + command)

if __name__ == '__main__':
    data = json.loads(sys.argv[1])
    listen()

我在similar question 上尝试了解决方案，但在将hello 消息包装到端点时出现错误。

我正确地需要python-shell 模块，并且我能够执行python 脚本并返回数据（使用print）。我的问题是在（随机）时间段后启动脚本并发送消息。

当我打开localhost:8000/hello 时，我得到Error: write after end

完全错误：

    Error: write after end
    at writeAfterEnd (_stream_writable.js:236:12)
    at Socket.Writable.write (_stream_writable.js:287:5)
    at Socket.write (net.js:717:40)
    at PythonShell.send (C:\Users\leonardo.schettini\Documents\recrutai\client\node_modules\python-shell\index.js:206:16)
    at C:\Users\leonardo.schettini\Documents\recrutai\client\app.js:27:12
    at Layer.handle [as handle_request] (C:\Users\leonardo.schettini\Documents\recrutai\client\node_modules\express\lib\router\layer.js:95:5)
    at next (C:\Users\leonardo.schettini\Documents\recrutai\client\node_modules\express\lib\router\route.js:137:13)
    at Route.dispatch (C:\Users\leonardo.schettini\Documents\recrutai\client\node_modules\express\lib\router\route.js:112:3)
    at Layer.handle [as handle_request] (C:\Users\leonardo.schettini\Documents\recrutai\client\node_modules\express\lib\router\layer.js:95:5)
    at C:\Users\leonardo.schettini\Documents\recrutai\client\node_modules\express\lib\router\index.js:281:22

【问题讨论】：

标签： python node.js python-3.x stdin

【解决方案1】：

好吧，我查看了我为 python-shell 所做的包装，并在脚本创建后发现了一个 pyshell.end(callback) 调用。

我很确定 end 只会在 python 脚本完成时执行，但它碰巧在不终止脚本的情况下关闭了输入流。

抱歉我没有引起注意。

【讨论】：