0

我已经使用 express(WebStorm 默认)设置了一个基本的 Node.js 服务器,并尝试根据请求(来自 pebble 手表)运行 python 脚本,并以以下形式发送返回的 json:

{"willCollide": 1, "time": 6000, "strength": "NA"}

回到手表。我刚刚开始研究 JavaScript,所以经验很少,并且希望我做的大部分都不正确。目前我遇到“错误:发送后无法设置标头”,并且想知道根据请求向用户发送 json 的正确方法是什么?我还想知道这是否确实是将数据从 python 脚本发送到 Pebble 手表的最佳方法。下面是在请求中调用的 JavaScript 文件中的代码:

var express = require('express');
var router = express.Router();
var PythonShell = require('python-shell');

var options = {
    mode: 'json'
};

var rain_data;

function run_py_script(data){

    var pyshell = new PythonShell('dummy.py', options);
    var ret_val;
    /* Dummy data doesnt matter atm */
    pyshell.send("dummy data"); // change to data

    pyshell.on('message', function(message){
        console.log(message);
        ret_val = message;
        console.log(message["willCollide"]); // debug check
    });

    pyshell.end(function(err){
        if (err) {
            console.log('error received from python script');
        }
        console.log('finished script');
    });

    return ret_val;
}

/* GET rain_track data. */

router.get('/', function(req, res, next) {

    rain_data = run_py_script(null);

    res.write(rain_data);
    res.end();
});

module.exports = router;
4

1 回答 1

0

似乎您在异步执行方面遇到了麻烦。

在触发事件之前,您的函数run_py_script(data)不会返回最终值。end然后,您将能够将响应返回给用户。
在这里,您有两种可能的解决方案:

  1. 回调
  2. 承诺

我将使用回调方法

首先,run_py_script将有 2 个参数,data以及一个要与响应一起调用的函数,让我们调用它cbcb最终将使用最终数据调用。

function run_py_script(data, cb) {
  // I'm going to summarize this code 
  var ret_val;

  pyshell.on('message', function(message){ 
    ret_val = message; 
  });

  pyshell.end(function(err){ 
     return err ? cb(null) : cb(ret_val);
  });

  // note there is no return statement
}

现在,让我们创建您的控制器:

router.get('/', function(req, res, next) {
    run_py_script(null, function(rain_data) {
      res.json(rain_data); // same as write().end() but more elegant
    });
});

最后的奖励:节点约定cb是一个 2 参数函数;第一个参数是一个错误,如果null一切正常,第二个参数是数据本身,null如果出错。

考虑到这一点,最终代码将是(总结)

function run_py_script(data, cb) {
  // ...
  pyshell.end(function(err){
    return err ? cb(err, null) : cb(null, ret_val);
  });
} 
run_py_script(null, function(err, rain_data){ 
  if (err){ return res.json(null); }
  return res.json(data);
});
于 2016-07-27T13:23:48.033 回答