如何从 NodeJs 调用 python 脚本

How to call python script from NodeJs

提问by GPrathap

I need to call this python script in NodeJs.

我需要在 NodeJs 中调用这个 python 脚本。

Read.py

读取文件

#!/usr/bin/env python
# -*- coding: utf8 -*-

import RPi.GPIO as GPIO
import MFRC522
import signal

continue_reading = True

# Capture SIGINT for cleanup when the script is aborted
def end_read(signal,frame):
    global continue_reading
    print "Ctrl+C captured, ending read."
    continue_reading = False
    GPIO.cleanup()

# Hook the SIGINT
signal.signal(signal.SIGINT, end_read)

# Create an object of the class MFRC522
MIFAREReader = MFRC522.MFRC522()

# Welcome message
print "Welcome to the MFRC522 data read example"
print "Press Ctrl-C to stop."

# This loop keeps checking for chips. If one is near it will get the UID and authenticate
while continue_reading:

    # Scan for cards    
    (status,TagType) = MIFAREReader.MFRC522_Request(MIFAREReader.PICC_REQIDL)

    # If a card is found
    if status == MIFAREReader.MI_OK:
    # Get the UID of the card
    (status,uid) = MIFAREReader.MFRC522_Anticoll()

    # If we have the UID, continue
    if status == MIFAREReader.MI_OK:

        # Print UID
        print "Card read UID: "+str(uid[0])+","+str(uid[1])+","+str(uid[2])+","+str(uid[3])

        # This is the default key for authentication
        key = [0xFF,0xFF,0xFF,0xFF,0xFF,0xFF]

        # Select the scanned tag
        MIFAREReader.MFRC522_SelectTag(uid)

        # Authenticate
        status = MIFAREReader.MFRC522_Auth(MIFAREReader.PICC_AUTHENT1A, 8, key, uid)

        # Check if authenticated
        if status == MIFAREReader.MI_OK:
            MIFAREReader.MFRC522_Read(8)
            MIFAREReader.MFRC522_StopCrypto1()
        else:
            print "Authentication error"

I used python-shell, here is the NodeJs code for that

我使用了 python-shell，这里是 NodeJs 代码

Test.js

测试.js

var PythonShell = require('python-shell');

var options = {
scriptPath: '/home/pi/gpio-admin/MFRC522-python/'
};
var pyshell = new PythonShell('Read.py',options);


pyshell.on('message', function (message) {

    console.log(message);
});

But when I ran this code I didn't see anything in Node side. I think problem occurs when python script comes to this level.

但是当我运行这段代码时，我在 Node 端没有看到任何东西。我认为当 python 脚本达到这个级别时会出现问题。

   (status,TagType) = MIFAREReader.MFRC522_Request(MIFAREReader.PICC_REQIDL)

Because I just ran with while loop which has only print statement then it works. After that I tried another way to achieve this. But I got same problem which I have with above.Here is another method

因为我刚刚运行了只有打印语句的 while 循环，然后它就可以工作了。之后，我尝试了另一种方法来实现这一目标。但是我遇到了与上面相同的问题。这是另一种方法

AltTest.js

测试工具

var python = require('child_process').spawn(
 'python',
 // second argument is array of parameters, e.g.:
 ["/home/pi/gpio-admin/MFRC522-python/Read.py"]
 );
 var output = "";
 python.stdout.on('data', function(){ 

    output += data ;
    console.log(data);
});
 python.on('close', function(code){ 

   console.log("Here you are there...");
 });

Any help would be appreciated

任何帮助，将不胜感激

回答by Tejus Prasad

There are multiple ways of doing this.

有多种方法可以做到这一点。

• first way is by doing npm install python-shell

• 第一种方法是做 npm install python-shell

and here's the code

这是代码

var PythonShell = require('python-shell');
//you can use error handling to see if there are any errors
PythonShell.run('my_script.py', options, function (err, results) { 
//your code

you can send a message to python shell using pyshell.send('hello');

您可以使用 pyshell.send('hello');

you can find the API reference here- https://github.com/extrabacon/python-shell

你可以在这里找到 API 参考 - https://github.com/extrabacon/python-shell

• second way - another package you can refer to is node python , you have to do npm install node-python

• third way - you can refer to this question where you can find an example of using a child process- How to invoke external scripts/programs from node.js

• 第二种方式 - 你可以参考的另一个包是 node python ，你必须这样做 npm install node-python

• 第三种方式 - 您可以参考这个问题，您可以在其中找到使用子进程的示例 - How to invoke external scripts/programs from node.js

a few more references - https://www.npmjs.com/package/python

还有一些参考资料 - https://www.npmjs.com/package/python

if you want to use service-oriented architecture - http://ianhinsdale.com/code/2013/12/08/communicating-between-nodejs-and-python/

如果你想使用面向服务的架构 - http://ianhinsdale.com/code/2013/12/08/communicating-between-nodejs-and-python/

回答by Tanmay Shrivastava

• install python-shell :- npm install python-shell

  Index.js

  let {PythonShell} = require('python-shell')
  
  function runPy(){
      return new Promise(async function(resolve, reject){
            let options = {
            mode: 'text',
            pythonOptions: ['-u'],
            scriptPath: './test.py',//Path to your script
            args: [JSON.stringify({"name": ["xyz", "abc"], "age": ["28","26"]})]//Approach to send JSON as when I tried 'json' in mode I was getting error.
           };
  
            await PythonShell.run('test.py', options, function (err, results) {
            //On 'results' we get list of strings of all print done in your py scripts sequentially. 
            if (err) throw err;
            console.log('results: ');
            for(let i of results){
                  console.log(i, "---->", typeof i)
            }
        resolve(results[1])//I returned only JSON(Stringified) out of all string I got from py script
       });
     })
   } 
  
  function runMain(){
      return new Promise(async function(resolve, reject){
          let r =  await runPy()
          console.log(JSON.parse(JSON.stringify(r.toString())), "Done...!@")//Approach to parse string to JSON.
      })
   }
  
  runMain() //run main function
  

• 安装 python-shell :- npm install python-shell

  索引.js

  let {PythonShell} = require('python-shell')
  
  function runPy(){
      return new Promise(async function(resolve, reject){
            let options = {
            mode: 'text',
            pythonOptions: ['-u'],
            scriptPath: './test.py',//Path to your script
            args: [JSON.stringify({"name": ["xyz", "abc"], "age": ["28","26"]})]//Approach to send JSON as when I tried 'json' in mode I was getting error.
           };
  
            await PythonShell.run('test.py', options, function (err, results) {
            //On 'results' we get list of strings of all print done in your py scripts sequentially. 
            if (err) throw err;
            console.log('results: ');
            for(let i of results){
                  console.log(i, "---->", typeof i)
            }
        resolve(results[1])//I returned only JSON(Stringified) out of all string I got from py script
       });
     })
   } 
  
  function runMain(){
      return new Promise(async function(resolve, reject){
          let r =  await runPy()
          console.log(JSON.parse(JSON.stringify(r.toString())), "Done...!@")//Approach to parse string to JSON.
      })
   }
  
  runMain() //run main function
  

test.py

测试文件

    import sys #You will get input from node in sys.argv(list)
    import json
    import pandas as pd #Import just to check if you dont have pandas module you can comment it or install pandas using pip install pandas

    def add_two(a, b):
        sum = 0
        for i in range(a, b):
            sum += i
        print(sum)  

    if __name__ == "__main__":
        print("Here...!")
        # print(sys.argv)
        j = json.loads(sys.argv[1]) #sys.argv[0] is filename
        print(j)
        add_two(20000, 5000000) #I make this function just to check 
    # So for all print done here you will get a list for all print in node, here-> console.log(i, "---->", typeof i)

回答by Adam

Adopt a micro-services approach. Host the Python script as a HTTP REST API service. Consume the API from node.js - you do not need to integrate the technologies; it's not scalable.

采用微服务方法。将 Python 脚本作为 HTTP REST API 服务托管。从 node.js 使用 API - 您不需要集成这些技术；它不可扩展。

回答by Archil Labadze

Well yoy can run pythonscript from node.jsin way like this. Use child_process.spawn(this is build in node.js library)

好吧，你可以像这样从node.js运行python脚本。使用child_process.spawn（这是在 node.js 库中构建的）

router.get('/', (req, res) => {
    const {spawn} = require('child_process');
    const path = require('path');
    function runScript(){
        return spawn('python', [
              path.join(__dirname, '../../scripts/myscript.py'),
              '-some_arg',
              '--another_arg',
        ]);
    }
    const subprocess = runScript();
    // print output of script
    subprocess.stdout.on('data', (data) => {
            console.log(`data:${data}`);
    });
    subprocess.stderr.on('data', (data) => {
           console.log(`error:${data}`);
    });
    subprocess.stderr.on('close', () => {
               console.log("Closed");
    });
    // const subprocess = runScript()
    res.set('Content-Type', 'text/plain');
    subprocess.stdout.pipe(res);
    subprocess.stderr.pipe(res);
});