[python] node.js와 Python 결합

2019 업데이트

이를 달성하는 방법에는 여러 가지가 있으며 여기에는 복잡성이 증가하는 목록이 있습니다.

1. Python Shell, python 콘솔에 스트림을 작성하고 다시 작성합니다.
2. Redis Pub Sub, Node js 게시자가 데이터를 푸시하는 동안 Python에서 채널 청취를 할 수 있습니다
3. Node가 클라이언트로 작동하고 Python이 서버로 작동하거나 그 반대로 작동하는 Websocket 연결
4. Express / Flask / Tornado 등과의 API 연결은 다른 쪽이 쿼리에 노출 된 API 엔드 포인트와 별도로 작동

접근법 1 Python Shell 가장 간단한 접근법

source.js 파일

const ps = require('python-shell')
// very important to add -u option since our python script runs infinitely
var options = {
    pythonPath: '/Users/zup/.local/share/virtualenvs/python_shell_test-TJN5lQez/bin/python',
    pythonOptions: ['-u'], // get print results in real-time
    // make sure you use an absolute path for scriptPath
    scriptPath: "./subscriber/",
    // args: ['value1', 'value2', 'value3'],
    mode: 'json'
};

const shell = new ps.PythonShell("destination.py", options);

function generateArray() {
    const list = []
    for (let i = 0; i < 1000; i++) {
        list.push(Math.random() * 1000)
    }
    return list
}

setInterval(() => {
    shell.send(generateArray())
}, 1000);

shell.on("message", message => {
    console.log(message);
})

destination.py 파일

import datetime
import sys
import time
import numpy
import talib
import timeit
import json
import logging
logging.basicConfig(format='%(asctime)s : %(levelname)s : %(message)s', level=logging.INFO)

size = 1000
p = 100
o = numpy.random.random(size)
h = numpy.random.random(size)
l = numpy.random.random(size)
c = numpy.random.random(size)
v = numpy.random.random(size)

def get_indicators(values):
    # Return the RSI of the values sent from node.js
    numpy_values = numpy.array(values, dtype=numpy.double)
    return talib.func.RSI(numpy_values, 14)

for line in sys.stdin:
    l = json.loads(line)
    print(get_indicators(l))
    # Without this step the output may not be immediately available in node
    sys.stdout.flush()

참고 : source.js 파일과 동일한 수준에있는 subscriber라는 폴더를 만들고 destination.py를 그 안에 넣으십시오. virtualenv 환경을 변경하는 것을 잊지 마십시오

---